流分組由一個字段然後合併所有其他

Question

我有流分組的問題。

List<FAR> listFar = farList.stream().filter(f -> !f.getStatus().equals(ENUM.STATUS.DELETED)) 
      .collect(Collectors.toList()); 
List<HAUL> haulList = listFar.stream().map(f -> f.getHaul()).flatMap(f -> f.stream()) 
      .collect(Collectors.toList()); 

它按物種分組，但一切都很好，但HAUL還有其他屬性。

Map<Specie, List<HAUL>> collect = haulList.stream().collect(Collectors.groupingBy(HAUL::getSpecie)); 

屬性：

1. haul.getFishCount();（整數）
2. haul.getFishWeight();（BigDecimal）的

是否有可能組由HAUL::getSpecie（由種），而且 「合併」 在一起那兩個額外的領域，所以我有總計？

例如：我有3個HAUL元素，其中魚類物種A的重量爲50/30/10千克。

我可以按品種分組並且總重量是多少？

Answer 1

如果我理解正確的：

haulsList 
     .stream() 
     .collect(Collectors.groupingBy(HAUL::getSpecie, 
       Collectors.collectingAndThen(Collectors.toList(), 
        list -> { 
        int left = list.stream().mapToInt(HAUL::getFishCount).sum(); 
        BigDecimal right = list.stream().map(HAUL::getFishWeight).reduce(BigDecimal.ZERO, (x, y) -> x.add(y)); 
        return new AbstractMap.SimpleEntry<>(left, right); 
        }))); 

有做一個表格：

.stream() 
.collect(Collectors.groupingBy(HAUL::getSpecie, 
       Collectors.summingInt(HAUL::getFishCount))); 

或

.stream() 
.collect(Collectors.groupingBy(HAUL::getSpecie, 
      Collectors.mapping(HAUL::getFishWeight, Collectors.reducing((x, y) -> x.add(y))))); 

但你不能真正使這些在該法同時。

Answer 2

您可以使用mapping和reduce例如：

class Foo { int count; double weight; String spice; } 
List<Foo> fooList = Arrays.asList(
    new Foo(1,new BigDecimal(10), "a"), 
    new Foo(2,new BigDecimal(38), "a"), 
    new Foo(5,new BigDecimal(2), "b"), 
    new Foo(4,new BigDecimal(8), "b")); 

Map<String,Optional<BigDecimal>> spieceWithTotalWeight = fooList.stream(). 
     collect(
       groupingBy(
         Foo::getSpice, 
         mapping(
           Foo::getWeight, 
           Collectors.reducing(BigDecimal::add) 
         ) 
       ) 
     ); 
System.out.println(spieceWithTotalWeight); // {a=Optional[48], b=Optional[10]} 

我希望這有助於。

Answer 3

如果我正確地得到你的問題，你想每個物種的總數count * weight。

您可以通過使用Collectors.groupingBy與下游收集器減少了在每個物種的HAUL列表中的haul.getFishCount() * haul.getFishWeight()總和做到這一點：

Map<Specie, BigDecimal> result = haulList.stream() 
    .collect(Collectors.groupingBy(haul -> haul.getSpecie(), 
     Collectors.mapping(haul -> 
       new BigDecimal(haul.getFishCount()).multiply(haul.getFishWeight()), 
      Collectors.reducing(BigDecimal::plus)))); 

這將得到count * weight每個物種的總和。如果你可以將以下方法添加到您的Haul類：

public BigDecimal getTotalWeight() { 
    return new BigDecimal(getFishCount()).multiply(getFishWeight()); 
} 

然後，收集流會更容易和更具可讀性：

Map<Specie, BigDecimal> result = haulList.stream() 
    .collect(Collectors.groupingBy(haul -> haul.getSpecie(), 
     Collectors.mapping(haul -> haul.getTotalWeight(), 
      Collectors.reducing(BigDecimal::plus)))); 

---

編輯：畢竟，似乎你想爲每個領域單獨的總和...

我會使用Collectors.toMap與此合併功能。下面的代碼：

Map<Specie, List<BigDecimal>> result = haulList.stream() 
    .collect(Collectors.toMap(
     haul -> haul.getSpecie(), 
     haul -> Arrays.asList(
      new BigDecimal(haul.getFishCount()), 
      haul.getFishWeight()), 
     (list1, list2) -> { 
      list1.set(0, list1.get(0).plus(list2.get(0))); 
      list1.set(1, list1.get(1).plus(list2.get(1))); 
      return list1; 
     })); 

它使用2個元素的列表，以存儲在索引0魚計數和魚體重索引1每一個硬幣。