Java Collectors.filtering 怎样在分组收集时过滤值

如果你要“先按部门分组，再只保留工资达标的员工”，但还希望没有达标员工的部门继续出现在结果里，应该把 Collectors.filtering 放到 groupingBy 的下游。它会让谓词只影响每个分组里收集的元素，不会自动删除分组键。

相反，先调用 Stream.filter 再分组，过滤发生在分组之前；某个部门没有任何匹配员工时，这个部门键就不会进入 Map。两种写法都正确，区别在于结果数据是否需要保留空分组。

官方资料：https://docs.oracle.com/en/java/javase/25/docs/api/java.base/java/util/stream/Collectors.html

先确认分组键是否必须保留

把“没有匹配值”分成两种业务含义：如果页面要展示所有部门，即使结果数量为零，也要保留部门；如果只关心有达标员工的部门，则可以在分组前过滤。这个决定比 API 写法更重要。

把 filtering 放到 groupingBy 的下游

filtering 接收两个参数：一个 Predicate，以及负责真正收集结果的下游 Collector。它本身不决定最终容器，容器由第二个参数决定。

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

record Employee(String name, String department, int salary) {}

Map> result = employees.stream()
    // 先按部门建立分组，保留输入中出现过的每个部门键
    .collect(Collectors.groupingBy(
        Employee::department,
        // 只让工资达标的员工进入当前部门的下游列表
        Collectors.filtering(
            employee -> employee.salary() >= 20000,
            // 下游 Collector 决定每个部门最终使用 List
            Collectors.toList()
        )
    ));

这里的类型关系可以按三层理解：groupingBy 负责产生部门键，filtering 负责对每个桶应用谓词，toList 负责保存通过谓词的员工。假设“平台”部门存在但没有人达到 20000，结果仍会包含 "平台" -> []。

按结果容器选择下游 Collector

需要保留重复记录时使用 Collectors.toList()；只关心去重后的对象可以使用 Collectors.toSet()；需要数量、求和或其他汇总时，也可以把统计类 Collector 放在第二个参数位置。

Map qualifiedCount = employees.stream()
    .collect(Collectors.groupingBy(
        Employee::department,
        // 过滤动作仍在每个部门内部完成
        Collectors.filtering(
            employee -> employee.salary() >= 20000,
            // 直接把通过条件的员工归约为数量
            Collectors.counting()
        )
    ));

这种组合的好处是“筛选规则”和“结果形状”分开。后续从列表改成集合或计数时，只替换下游 Collector，不必重新组织分组逻辑。

对比先 filter 再 groupingBy 的边界

Map> onlyNonEmpty = employees.stream()
    // 先过滤，未达标员工在分组前就被移除
    .filter(employee -> employee.salary() >= 20000)
    // 因此没有达标员工的部门不会创建 Map 键
    .collect(Collectors.groupingBy(Employee::department));

如果业务需要“只返回有数据的部门”，这段代码更直接；如果需要“所有部门都能显示，并对空结果做提示”，就使用前面的下游 filtering。不要为了让 Map 看起来更紧凑而误删业务上有意义的空键。

常见问题

filtering 和 filter 是替代关系吗？

不是。filter 作用于整个 Stream，filtering 是一个下游 Collector 适配器，常用于 groupingBy 或 partitioningBy 内部。

为什么空部门还会出现在 Map 中？

因为分组键先被创建，谓词只决定下游容器是否接收元素。若改成先 filter 再 groupingBy，没有匹配元素的部门才会消失。

小结

• 需要保留空分组时，用 groupingBy(..., filtering(predicate, downstream))。
• 只想保留有匹配数据的分组时，先用 Stream.filter。
• filtering 负责筛选，下游 Collector 负责结果形状，二者可以独立调整。