我試圖在兩個不同的列表之間找到匹配的元素，然后我試圖映射到不同對象的列表，該列表包含來自列表和某些選定元素的元素。這是我的兩個豆子——public class LogsData { LocalDate eventDate ; String correlationId; String authId; int numberofSQL; // getter and setter}public class DistributionData { LocalDate eventDate; String correlationId; String callingProId; long transactionCount ; // getter and setter }public class ResultBean { LocalDate eventDate; String correlationId; String callingProId; long transactionCount ; String authId ; int numberOfSQL;}我如何獲得包含與 匹配的最終列表correlationId，eventDate在結果中，我想要ResultBean.有人可以幫忙嗎？
3 回答
浮云間
TA貢獻1829條經驗 獲得超4個贊
我改變了一點點設計以使其工作，我將分發列表添加到 Logs Beans 中，因為它具有一對多的關系，我能夠合并來自兩個列表的數據，但它運行速度非常慢，因為集合大小非常大，尤其是分發列表，有人可以建議一些高性能或任何更好的設計。
List<LogsData> logsData = logs.stream()
.filter(e -> (distributionData.stream()
.filter(d ->
d.getCorrelationId.equals(e.getCorrelationId))
.filter(d-> d.getEventDate().equals(e.getEventDate()))
.map(mapper-> e.getDistribution().add(mapper); return e; })
.count())<1)
.collect(Collectors.toList());
智慧大石
TA貢獻1946條經驗 獲得超3個贊
根據Louis Wasserman 的評論，可能可以在 Streams 有優勢的地方使用它?？紤]擁有LogsData和DistributionData（和可選的ResultBean）擴展基類型：
class Data {
LocalDate eventDate ;
String correlationId;
Data(LocalDate eventDate, String correlationId) {
this.eventDate = eventDate;
this.correlationId = correlationId;
}
LocalDate getEventDate() { return eventDate; }
String getCorrelationId(){ return correlationId; }
@Override
public boolean equals(Object o) {
if(!(o instanceof Data)) { return false; }
Data d = (Data) o;
return eventDate.equals(d.getEventDate())
&& correlationId.equals(d.getCorrelationId() );
}
}
列出：
List<LogsData> logsData = new ArrayList<>();
List<DistributionData> dData = new ArrayList<>();
您可以簡單地將兩個列表相交
logsData.retainAll(dData);
dData.retainAll(logsData);
讓它們以相同的順序排序：
//sort so two lists have the same order. If correlationId is not unique you may need
//to enhance the comperator
Collections.sort(dData, (a, b) -> a.getCorrelationId().compareToIgnoreCase(b.getCorrelationId()));
Collections.sort(logsData, (a, b) -> a.getCorrelationId().compareToIgnoreCase(b.getCorrelationId()));
并用于Stream構造ResultBean對象列表：
List<ResultBean> resultList = IntStream.range(0, logsData.size())
.mapToObj( i ->
new ResultBean(dData.get(i).getEventDate(), dData.get(i).getCorrelationId(),
dData.get(i).getCallingProId(), dData.get(i).getTransactionCount(),
logsData.get(i).getAuthId(), logsData.get(i).getNumberofSQL())
)
.collect(Collectors.toList());
UYOU
TA貢獻1878條經驗 獲得超4個贊
一種方法是將logsData列表的元素累積到一個映射中，其中鍵logsData#getEventDate與logsData#getCorrelationId.
Map<String, LogsData> accumulator =
logsData.stream()
.collect(toMap(l -> l.getEventDate() + l.getCorrelationId(), Function.identity()));
然后流過distributionData列表并獲取地圖中的相應元素，然后將它們轉換為ResultBean.
List<ResultBean> resultSet = distributionData.stream()
.map(d -> {
LogsData logs = accumulator.get(d.getEventDate() + d.getCorrelationId());
if (logs != null)
return new ResultBean(d.getEventDate(), d.getCorrelationId(),
d.getCallingProId(), d.getTransactionCount(), logs.getAuthId(), logs.getNumberofSQL());
return null;
})
.filter(Objects::nonNull)
.collect(Collectors.toList());
這假設ResultBean有一個構造函數接受所有必要的參數，如果不是這樣，那么只需調用 setter 方法來設置必要的數據。
進口：
import static java.util.stream.Collectors.*;
import java.util.stream.*;
import java.util.function.*;
另一種方法雖然效率較低：
List<ResultBean> resultSet = logsData.stream()
.map(l -> distributionData.stream()
.filter(d -> l.getEventDate().equals(d.getEventDate()) &&
l.getCorrelationId().equals(d.getCorrelationId()))
.findFirst()
.map(d -> new ResultBean(d.getEventDate(), d.getCorrelationId(),
d.getCallingProId(), d.getTransactionCount(), l.getAuthId(), l.getNumberofSQL()))
.orElse(null))
.filter(Objects::nonNull)
.collect(Collectors.toList());
略有不同，在 JDK9 中避免了這種.orElse(null)).filter(Objects::nonNull)模式：
List<ResultBean> resultSet = logsData.stream()
.flatMap(l -> distributionData.stream()
.filter(d -> l.getEventDate().equals(d.getEventDate()) &&
l.getCorrelationId().equals(d.getCorrelationId()))
.findFirst()
.map(d -> new ResultBean(d.getEventDate(), d.getCorrelationId(),
d.getCallingProId(), d.getTransactionCount(), l.getAuthId(), l.getNumberofSQL()))
.stream()
)
.collect(Collectors.toList());
添加回答
舉報
0/150
提交
取消