如何分组收集器从数据创建一个新字段？

Question

我有这样的数据（地图列表）：

{
    “name”: “Hello”,
    "source": “One”,
    "status": “Good”,
    “date”: "01-05-2021 7:35:58 PM"
},
{
    “name”: “Hello”,
    "source": “Two”,
    "status": “Good”,
    “date”: "01-05-2021 7:35:58 PM"
},
{
    “name”: “Goodbye”,
    "source": “Three”,
    "status": “Bad”,
    “date”: "01-05-2021 7:35:58 PM"
},
{
    “name”: “Goodbye”,
    "source": “Four”,
    "status": “Bad”,
    “date”: "01-05-2021 7:35:58 PM"
}

因此，我想按“名称”对这些数据进行分组，但也要创建一个新字段，它将“源”和“状态”字段收集到对象列表中。这意味着我还必须将内部数据映射到一个Java类（将这些单独的对象称为“SourceStatus”，我已经为其创建了一个类）。

{
    “name”: “Hello”,
    “sourceStatuses”: [
        {
            “source”: ”One”,
            “status”: ”Good”
        },
        {
            “source”: ”Two”,
            “status”: ”Good”
        }
    ],
    “status”: “Good”,
    “date”: "01-05-2021 7:35:58 PM"
},
{
    “name”: “Goodbye”,
    “sourceStatuses”: [
        {
            “source”: ”Three”,
            “status”: ”Bad”
        },
        {
            “source”: ”Four”,
            “status”: ”Bad”
        }
    ],
    “status” : “Bad,
    “date”: "01-05-2021 7:35:58 PM"
}

我知道groupingBy部分可以用Java的收集器（https://www.baeldung.com/java-groupingby-collector）非常直接地完成，但我不确定如何为我的用例实现结果集，在这里我不仅创建了一个新字段，而且还收集内部数据，然后将其映射到一个类。

编辑：“日期”和“状态”将是相同的所有项目具有相同的“名称”。

Answer 1

GroupingBy收集器的键应该是另一个没有键“source”的可修改映射，值应该是SourceStatus类的列表，可以使用Collectors.Mapping收集器收集这些类。

注意:map用来表示一个键和一个最终结果。

我们假设，sourceStatus有一个自定义构造函数，它使用map 作为参数，以便在 集合中使用它。mapping: object>

public class SourceStatus {
    private String source;
    private String status;

    public SourceStatus(Map<String, Object> map) {
        this.source = (String) map.get("source");
        this.status = (String) map.get("status");
    }
}

那么获取结果映射集的代码如下所示：

Set<Map<String, Object>> mapped = data
    .stream()
    .collect(Collectors.groupingBy(
        m -> {
            Map<String, Object> key = new LinkedHashMap<>();
            key.putAll(m);
            key.remove("source");
            return key;
        },
        Collectors.mapping(SourceStatus::new, Collectors.toList())
    ))
    .entrySet().stream()
    .map(e -> {
        e.getKey().put("sourceStatuses", e.getValue());
        return e.getKey(); 
    })
    .collect(Collectors.toCollection(LinkedHashSet::new)); // maintain insertion order
// convert to json
ObjectMapper mapper = new ObjectMapper();
String json = mapper.writerWithDefaultPrettyPrinter().writeValueAsString(mapped);
System.out.println(json);

输出：

[ {
  "name" : "Hello",
  "date" : "01-05-2021 7:35:58 PM",
  "status" : "Good",
  "sourceStatuses" : [ {
    "source" : "1",
    "status" : "Good"
  }, {
    "source" : "2",
    "status" : "Good"
  } ]
}, {
  "name" : "Bye",
  "date" : "01-05-2021 7:35:58 PM",
  "status" : "Bad",
  "sourceStatuses" : [ {
    "source" : "3",
    "status" : "Bad"
  }, {
    "source" : "4",
    "status" : "Bad"
  } ]
} ]