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

使用可选的#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));

Answer 2

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