从Java Stream of Map中,按键对它们进行分组,并发现最大值没有按预期工作



从输入Stream<Map<String,Float>中,我试图找到唯一的分析物,以及具有最大值的分析物。我尝试了以下操作,但没有得到预期的结果。我在收集价值时犯了一些错误。

样本输入数据:List<Map<String,Float>

{HNO3=2.005}
{HNO3=2.009}
{HCl=10.2}
{F-=0.0, HNO3=50.0}
Actual result   : {HCl=Optional[HCl=10.2], F-=Optional[F-=0.0], HNO3=Optional[HNO3=50.0]}
Expected result : {HCl=10.2, F-=0.0, HNO3=50.0}

我尝试过的Java代码:-

finalResponse.getChosenStartingMaterials()
.stream()
.map(Analyte::getMatrixUtilisationMap)  // Stream<Map<String,Float>>
.flatMap(it -> it.entrySet().stream())   
.collect(Collectors.groupingBy(Map.Entry::getKey, Collectors.maxBy((m1, m2) -> m1.getValue().compareTo(m2.getValue()))))

Collectors.maxBy()生成一个Optional,因为如果在空的Stream上应用maxBy,则必须返回一个空Optional

您可以使用Collectors.toMap而不是Collectors.groupingBy来避免Optionals:

finalResponse.getChosenStartingMaterials()
.stream()
.map(Analyte::getMatrixUtilisationMap)  // Stream<Map<String,Float>>
.flatMap(it -> it.entrySet().stream())   
.collect(Collectors.toMap(Map.Entry::getKey,
Map.Entry::getValue,
(v1, v2) -> v1.compareTo(v2) >= 0 ? v1 : v2));

finalResponse.getChosenStartingMaterials()
.stream()
.map(Analyte::getMatrixUtilisationMap)  // Stream<Map<String,Float>>
.flatMap(it -> it.entrySet().stream())   
.collect(Collectors.toMap(Map.Entry::getKey,
Map.Entry::getValue,
Float::max));

最新更新