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); 

私は、すべてのproductMsgsを取得し、productStatusが新しいかどうかを確認する必要があります。例えば一例では私が与えた： 私は新しいステータスを持つすべてproductStatusについて

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

のマップを必要とするだろう、それをリストに追加し続けます。基本的には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());