Java 流 - 合并过滤器并收集

Question

ColumnFamily column = tokens.getColumnFamilies().stream()
    .filter(family -> family.getName().equals("this_family"))
    .findAny()
    .get();

Map<String, String> tokenized = column.getColumns().stream()
    .collect(Collectors.toMap(
        Column::getQualifier,
        Column::getValue
    ));

有什么方法可以将这两个流合二为一吗？我正在使用第一个流在我的嵌套列表中进行过滤和查找，并使用第二个流根据流的结果创建地图。我想知道是否有一种方法可以使用单个流来完成此操作。

像这样

Map<String, String> tokenized = tokens.getColumnFamilies().stream()
    .filter(family -> family.getName().equals("this_family"))
    .collect(Collectors.toMap(
        //
    ));

Answer 1

您可以使用 flatMap 来嵌套 Stream 并展平结构：

Map<String, String> tokenized = tokens.getColumnFamilies().stream()
    .filter(family -> family.getName().equals("this_family"))
    .limit(1)  // equivalent of findAny
    .flatMap(cf -> cf.getColumns().stream())
    .collect(Collectors.toMap(
        Column::getQualifier,
        Column::getValue
    ));

Answer 2

使用Optional#map()并合并

Map<String, String> tokenized = tokens.getColumnFamilies().stream()
                    .filter(family -> family.getName().equals("this_family"))
                    .findAny()
                    .map(cf -> cf.getColumns().stream()).get()
                    .collect(Collectors.toMap(Column::getQualifier, Column::getValue));

Java 流 - 合并过滤器并收集

Java Stream - Combine filter and collect

java

lambda

java-8

java-stream

collectors