Stream、Map、Reduce……它是怎么做的？

Question

我正在尝试深入研究 Java 8 流，但时不时仍会卡住。我目前有一个问题，我知道它可以通过流来完成，但我似乎无法理解如何正确使用它们。

我有一个字符串 A 的列表，并尝试通过某个规则找到与 A 的另一个元素 b 匹配的 A 的所有元素 a，然后从中创建一个 Map<String, List<String>>，其中包含所有 a -> 所有匹配的 b。

详细说明：

• 对于 A 中的每个 a，使用谓词 P 与 A 中的每个 b 进行比较。
• 如果 P(a,b) 匹配，则从 a 和 b 生成一对 (x, y)。
• 将所有对按 x 分组并作为地图返回。

你能给我一个有效的 Java 8 流示例吗？

编辑：我将如何以不必要的昂贵方式做到这一点：

Pairs(x,y) = forEach(a,b in A) 
  where (a != b && P(a, b)) 
  generatePairXY(a, b)
Map(x -> List(y)) = group(Pairs(x,y)) by x

这种方法的问题是我首先需要构建一个巨大的对列表，考虑到我的数百万字数据集，这可能会耗尽内存。

Answer 1

List<String> list = ...;
Map<String, List<String>> map = 
  list.stream()
      .collect(Collectors.toMap(a -> a, a -> list.stream()
                                                 .filter(b -> P(a,b))
                                                 .collect(Collectors.toList()))
               );

这个想法是为原始列表的每个字符串创建一个映射，其中一个值是与该键匹配的所有字符串的过滤列表。

编辑：

这是一个完整的工作示例，如果两个字符串不相等但长度相同，则谓词 P 返回 true：

package com.test;

import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

public class Test
{

  public static boolean P (String a, String b)
  {
    return a.length() == b.length() && !a.equals(b);
  }

  public static void main (String[] args)
  {
    List<String> list = new ArrayList<String>();
    list.add ("aaa");
    list.add ("bbb");
    list.add ("ccc");
    list.add ("cccc");
    list.add ("dddd");
    list.add ("ddd");

    Map<String, List<String>> map = 
      list.stream()
          .collect(Collectors.toMap(a -> a, a -> list.stream()
                                                     .filter(b -> P(a,b))
                                                     .collect(Collectors.toList()))
               );
    for (String key : map.keySet ()) {
      System.out.print (key + ": " );
      for (String value : map.get(key)) {
        System.out.print (value+ " ");
      }
      System.out.println("");
    }
  }

}

输出：

aaa: bbb ccc ddd
ccc: aaa bbb ddd
bbb: aaa ccc ddd
ddd: aaa bbb ccc
dddd: cccc
cccc: dddd