Java Stream-组合过滤器并收集

问题描述

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

解决方法

您可以使用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
    ));

,

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