根据流中的另一个字段汇总字段[重复]

Question

我有一个如下所示的对象列表：

{
    value=500
    category="GROCERY"
},
{
    value=300
    category="GROCERY"
},
{
    value=100
    category="FUEL"
},
{
    value=300
    category="SMALL APPLIANCE REPAIR"
},
{
    value=200
    category="FUEL"
}

我想将其转换为如下对象列表：

{
    value=800
    category="GROCERY"
},
{
    value=300
    category="FUEL"
},
{
    value=300
    category="SMALL APPLIANCE REPAIR"
}

基本上将同一类别的所有值相加。

我应该使用平面图吗？减少我不明白这些的细微差别。

帮助

编辑：

这个问题有密切的重复：流中是否有聚合通过方法Java8 api？和带有Stream API的对象的总和属性

但在这两种情况下，最终的结果都是地图，而不是列表

根据@AndrewTobilko和@JBNizet的回答，我使用的最终解决方案是：

List<MyClass> myClassList = list.stream()
    .collect(Collectors.groupingBy(YourClass::getCategory,
                    Collectors.summingInt(YourClass::getValue)))
    .entrySet().stream().map(e -> new MyClass(e.getKey(), e.getValue()).collect(toList());

Answer 1

基于Reduce的方法：

List<Obj> values = list.stream().collect(
        Collectors.groupingBy(Obj::getCategory, Collectors.reducing((a, b) -> new Obj(a.getValue() + b.getValue(), a.getCategory())))
).values().stream().map(Optional::get).collect(Collectors.toList());

不好的是，从中重新映射结果的辅助调用是可选的

我可以使用排序建议其他变体（可读性较差）：

List<Obj> values2 = list.stream()
    .sorted((o1, o2) -> o1.getCategory().compareTo(o2.getCategory()))
    .collect(
        LinkedList<Obj>::new,
        (ll, obj) -> {
            Obj last = null;
            if(!ll.isEmpty()) {
                last = ll.getLast();
            }

            if (last == null || !last.getCategory().equals(obj.getCategory())) {
                ll.add(new Obj(obj.getValue(), obj.getCategory())); //deep copy here
            } else {
                last.setValue(last.getValue() + obj.getValue());
            }
        },
        (list1, list2) -> {
              //for parallel execution do a simple merge join here
              throw new RuntimeException("parallel evaluation not supported"); 
         }
    );

在这里，我们按类别对Objs的列表进行排序，然后按顺序处理它，压缩来自同一类别的连续对象。

不幸的是，Java没有方法在不手动保留最后一个元素或元素列表的情况下做到这一点（另请参阅从流中收集连续对）

可以在此处检查使用这两个片段的工作示例：https://ideone.com/p3bKV8

Answer 2

使用Collection类的静态导入：

list.stream().collect(groupingBy(Class::getCategory, summingInt(Class::getValue)));

你会得到一张地图

public class Class {
    private String category;
    private int value;

    public String getCategory() { return category; }
    public int getValue() { return value; }
}

Answer 3

Collection类提供了一个“groupingBy”，允许您对流执行“group by”操作（类似于数据库中的GROUP BY）。假设您的对象列表是“Object”类型，以下代码应该可以工作：

Map<String, Integer> valueByCategory = myObjects.stream().collect(Collectors.groupingBy(MyObjects::getCategory, Collectors.summingInt(MyObjects::getValue)));

代码基本上按每个类别对您的流进行分组，并在每个组上运行一个收集器，该收集器汇总每个流元素的getValue（）的返回值。请参阅https://docs.oracle.com/javase/8/docs/api/java/util/stream/Collectors.html