1

我正在尝试使用流 api groupingby 收集器来获取映射groupId -> List of elements。我的案例的特殊之处在于一个元素可以属于多个组。

用一个简单的例子来演示它：假设我想使用数字2 - 10作为分组的标识符，并且想要对数字进行分组，2 - 40以便它们可以被看作是我的标识符的倍数。传统上我会这样做：

Map<Integer,List<Integer>> map = new HashMap<>();
    for(int i = 2; i < 11; i++){
        for(int j = 2; j < 41; j++){
            if(j%i == 0)
            map.computeIfAbsent(i, k -> new ArrayList<>()).add(j);
        }
    }
    map.forEach((k,v) -> {
        System.out.println(k + " : " + v);
    });

并得到类似的东西

2 : [2, 4, 6, 8, 10, 12, 14, 16, 18, 20, 22, 24, 26, 28, 30, 32, 34, 36, 38, 40]
3 : [3, 6, 9, 12, 15, 18, 21, 24, 27, 30, 33, 36, 39]
4 : [4, 8, 12, 16, 20, 24, 28, 32, 36, 40]
5 : [5, 10, 15, 20, 25, 30, 35, 40]
6 : [6, 12, 18, 24, 30, 36]
7 : [7, 14, 21, 28, 35]
8 : [8, 16, 24, 32, 40]
9 : [9, 18, 27, 36]
10 : [10, 20, 30, 40]

为了用流来做到这一点，我试图将这个问题的答案应用到我的案例中，但没有成功。

IntStream.range(2, 11).boxed()
            .flatMap(g -> IntStream.range(2, 41)
                .boxed()
                .filter(i -> i%g == 0)
                .map(i -> new AbstractMap.SimpleEntry<>(g,i))
            .collect(Collectors.groupingBy(Map.Entry::getKey, 
                    Collectors.mapping(Map.Entry::getValue, Collectors.toList()))));

我得到一个编译错误

不兼容的类型：推理变量 R#1 具有不兼容的边界等式约束：Map<K,D> 下限：Stream<? extends R#2>,Object 其中 R#1,A#1,T#1,K,T#2,A#2,D,R#2 是类型变量：R#1 扩展在方法 <R 中声明的对象#1,A#1>collect(Collector<? super T#1,A#1,R#1>) A#1 扩展方法中声明的对象 <R#1,A#1>collect(Collector<? super T #1,A#1,R#1>) T#1 扩展接口 Stream K 中声明的对象 扩展方法 <T#2,K,A#2,D>groupingBy(Function<? super T#2, ? extends K>,Collector<? super T#2,A#2,D>) T#2 extends Object 在方法 <T#2,K,A#2,D>groupingBy(Function<? super T#2 ,? extends K>,Collector<? super T#2,A#2,D>) A#2 扩展方法中声明的对象 <T#2,K,A#2,D>groupingBy(Function<? super T# 2,? 扩展 K>,Collector< ? super T#2,A#2,D>) D 扩展方法中声明的对象 <T#2,K,A#2,D>groupingBy(Function<? super T#2,? extends K>,Collector<? super T#2,A#2,D>) R#2 扩展在方法 <R#2>flatMap(Function<? super T#1,? extends Stream<? extends R#2>>) 中声明的对象

我究竟做错了什么？

请注意，我原来的情况不是将数字分配给它们的倍数。实际上，我的组 id 具有长值，并且列表包含自定义对象。但是当我解决了上面的例子时，我想我可以将它应用到我的案例中。我只是想用简单的方式描述问题

4

1 回答 1

1

你的意思是这样的？

Map<Integer,List<Integer>> v = IntStream.range(2, 11).boxed()
               .map(g -> IntStream.range(2, 41)
                       .boxed()
                       .filter(i -> i % g == 0)
                       .map(i -> new AbstractMap.SimpleEntry<>(g, i))
                       .collect(Collectors.groupingBy(AbstractMap.SimpleEntry::getKey,
                               Collectors.mapping(AbstractMap.SimpleEntry::getValue, Collectors.toList()))))
               .flatMap(m -> m.entrySet().stream())
               .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
于 2020-10-30T12:36:59.930 回答