使用Java8流进行分组

Question

我正在使用Java8流我有一个类，如下所示：

public class ShareDao {
    private String senderId;
    private String receiverId;

    public String getSenderId() {
        return senderId;
    }

    public String sharingMode(){
        return this.receiverId != null && !this.receiverId.trim().isEmpty() ? "incoming" : "outgoing";
    }
}

现在我想做的是：

1. 筛选出senderId无效的记录（使用映射）

下面是我的代码：

Map<String, Map<String, List<ShareDao>>> p = records.stream()
            .filter(shared -> userMap.containsKey(shared.getSenderId()))
            .collect(Collectors.groupingBy(ShareDao::getSenderId), Collectors.groupingBy(ShareDao::sharingMode, Function.identity()));

这给我带来了一个错误：

错误：（105，90）java:找不到适用于groupingBy（共享[…]的方法gMode，java。util。作用函数）方法java。util。流动收藏家。groupingBy（java.util.function.function）不适用（无法推断类型变量T，K（实际参数列表和形式参数列表长度不同））方法java。util。流动收藏家。groupingBy（java.util.function.function，java.util.stream.Collector）不适用（不存在变量类型的实例，因此java。util。作用函数符合java。util。流动收集器）方法。util。流动收藏家。groupingBy（java.util.function.function、java.util.function.Supplier、java.util.stream.Collector）不适用（无法推断类型变量T、K、D、A、M（实际参数列表和形式参数列表长度不同））

当Intellij Idea引发错误时

不能从静态上下文引用非静态方法

Answer 1

基于你想达到的目的

• 筛选出senderId无效的记录（使用映射）

您可以使用：

Map<String, Map<String, List<ShareDao>>> p = records.stream()
        .filter(shared -> userMap.containsKey(shared.getSenderId())) // filter records
        .collect(Collectors.groupingBy(ShareDao::getSenderId, // grouping by senderId
                Collectors.groupingBy(ShareDao::sharingMode)));  //further grouping by sharingMode

注：

>

GroupingBy属性导致值被聚合为List。

Collector在集合中定义，因为它与您的尝试不同。