使用 Java 流在复杂数据结构中搜索

Question

[
 {"productStatus":
    [
     {"status": "spoilt"},
     {"status": "used"}
    ],
 "productMsg":
    [
    {"msg": "Valid"}
    ]
 },
 {"productStatus":
    [
     {"status": "new"},
    ],
 "productMsg":
    [
    {"msg": "Ok"},
    {"customMsg" : "blah blah"}
    ]
 }
]

我将上述数据存储在List<Map<String, List<Map<String, String>>>>；

例如：

val is represented by Lombok library.
val firstObj = ImmutableList.of(ImmutableMap.of("status", "spoilt"),
                ImmutableMap.of("status", "new"),
                ImmutableMap.of("status", "used"));
val secondObj = ImmutableList.of(ImmutableMap.of("msg", "Valid"));
val productStatus1 = ImmutableMap.of("productStatus", firstObj,
                "productMsg", secondObj);

val firstObj_1 = ImmutableList.of(ImmutableMap.of("status", "new"));
val secondObj_2 = ImmutableList.of(ImmutableMap.of("msg", "Ok"));
val productStatus_2 = ImmutableMap.of("productStatus", firstObj_1,
                "productMsg", secondObj_2);

val testObj = ImmutableList.of(productStatus1, productStatus_2);

我需要确定一个 productStatus 是否是新的，然后获取所有 productMsgs。例如在我给出的示例中： 我将需要

的地图

{"msg": "Ok"},
{"customMsg" : "blah blah"}

对于每个状态为 new 的 productStatus，继续将其添加到列表中。基本上我需要返回一个List<Map<String, String>>。

我知道如何在传统的 Java for 循环方法中执行此操作，我觉得这太笨拙和冗长。有没有使用 Streams 的巧妙方法？

Answer 1

未经测试，但我认为这会满足您的要求：

List<Map<String, String>> msgs = testObj.stream()
        .filter(obj -> obj.get("productStatus").stream()
                .anyMatch(s -> s.get("status").equals("new")))
        .flatMap(obj -> obj.get("productMsg").stream())
        .collect(Collectors.toList());