筛选并合并带有流的对象列表[重复]

Question

我需要筛选我的对象列表：

"elems": [
    {
      "field1": "aaa",
      "field2": "aaa",
      "field3": "a1",
      "field4": 110
    },
    {
      "field1": "aaa",
      "field2": "aaa",
      "field3": "a2",
      "field4": 120
    },
    {
      "field1": "aaa",
      "field2": "aaa",
      "field3": "a3",
      "field4": 140
    },
    {
      "field1": "bbb",
      "field2": "bbb",
      "field3": "b1",
      "field4": 5
    }
]

以便将具有相同字段1和字段2的所有对象合并到具有以下属性的单个对象中：

• 作为field4所有field4值的和
• 作为field3所有field3值的字符串级联

所以结果是：

"elems": [
    {
      "field1": "aaa",
      "field2": "aaa",
      "field3": "a1a2a3",
      "field4": 370
    },
    {
      "field1": "bbb",
      "field2": "bbb",
      "field3": "b1",
      "field4": 5
    }
]

Java 8中的溪流有可能做到吗？

我尝试了几种方法（例如，还使用#reduce)，但我没有找到解决方案！

谢谢

编辑：

下面是我尝试的：

items.stream().
    map(item -> {
        return items.stream().
                reduce(MyClass::filterAndMerge).
                orElse(item);
    }).
    forEach(item -> {
        // ...
    });

private static Item filterAndMerge(
        final Item item1,
        final Item item2) {

    final Item output = new Item();
    output.setField1(item2.getField1());
    output.setField2(item2.getField2());

    if (item1.getField1().equals(item2.getField1())
            && item1.getField2().equals(item2.getField2())) {

        output.setField3(item1.getField3() + item2.getField3());
        output.setField4(item1.getField4() + item2.getField4());
    }

    return output;
}

但由于某种原因，在计算过程中，我在item1.GetField2().equals(item2.GetField2())上得到了NullPointerException，无论如何，我非常肯定这不是一个有效的解决方案。

Answer 1

看来您必须首先按字段1和字段2对项进行分组，并合并与同一键关联的值。可以按照@naman的建议使用tomap来完成

public static void main(String[] args) {
    List<Item> items = List.of(
        new Item("aaa", "aaa", "a1", 110),
        new Item("aaa", "aaa", "a2", 120),
        new Item("aaa", "aaa", "a3", 140),
        new Item("bbb", "bbb", "b1", 5)
    );

    Collection<Item> values = items.stream()
            .collect(Collectors.toMap(
                    item -> item.getField1() + item.getField2(), 
                    Function.identity(), 
                    Main::mergeToOneItem
            )).values();
}

private static Item mergeToOneItem(Item item1, Item item2) {
    return new Item(
            item1.getField1(),
            item1.getField2(),
            item1.getField3() + item2.getField3(),
            item1.getField4() + item2.getField4()
    );
}