使用自定义收集器对象对 Java Stream 中的哈希映射中的值进行分组？

Question

Java Stream 新手在这里。目前，我正在通过 book 完成有关收集器的第 6 章（使用流收集数据）。

我的对象看起来像这样。

    public class Report {

    private String movie;
    private int movieId;
    private int projections;
    private int tickets;
    private double income;
}

我们的想法是获得某种一般性的总结报告。基本上，HashMap<String, Double> 它将具有三个键值对。

键 1：

projections - 代表每个报告中所有预测的总和。

键 2：

tickets - 代表每个报告中所有工单的总和。

键 3：

income - 这将代表每个报告的所有收入的总和。

现在，我实际上是通过创建名为 MapCollector 的自定义收集器来完成分配的。

    public class MapCollector implements Collector<Report, Map<String, Double>, Map<String, Double>>{

    @SuppressWarnings("serial")
    @Override
    public Supplier<Map<String, Double>> supplier() {

        return () ->  new HashMap<String, Double>() {{
            put("projections", 0.0);
            put("tickets", 0.0);
            put("income", 0.0);
        }};
    }

    @Override
    public BiConsumer<Map<String, Double>, Report> accumulator() {

        return (map, report) -> 
        {
            map.put("projections", map.get("projections") + report.getProjections());
            map.put("tickets", map.get("tickets") + report.getTickets());
            map.put("income", map.get("income") + report.getIncome());          
        };
    }

    @Override
    public BinaryOperator<Map<String, Double>> combiner() {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public Function<Map<String, Double>, Map<String, Double>> finisher() {
        // TODO Auto-generated method stub
        return Function.identity();
    }

    @Override
    public Set<Characteristics> characteristics() {
        // TODO Auto-generated method stub
        return Collections.unmodifiableSet(EnumSet.of(
                IDENTITY_FINISH, CONCURRENT));
    }
}

所以我得到的结果是这样的：

HashMap<String, Double> result = (HashMap<String, Double>) reports.stream().collect(new MapCollector());

所以我的问题是为什么要在不创建新的 Collector 对象的情况下以不同的方式执行此操作？也许，用groupingBy 或reduce 以某种方式做到这一点？或者任何其他（更好）更具可读性的方式？

Answer 1

您实际上不需要为此目的使用自定义收集器。您只需要supplier、accumulator 和combiner。

您可以将它们与流放在同一个类中，然后像下面这样调用它：

HashMap<String, Double> result = (HashMap<String, Double>) 
                                 reports.stream()
                                        .collect(
                                          this::supplier,
                                          this::acumulator,
                                          this::combiner);

方法如下所示：

private Map<String, Double> supplier() {
    return new HashMap<String, Double>() {{
        put("projections", 0.0);
        put("tickets", 0.0);
        put("income", 0.0);
    }};
}

private void accumulator(Map<String, Double> map, Report report) {
    map.merge("projections", report.getProjections(), Double::sum);
    map.merge("tickets", report.getTickets(), Double::sum);
    map.merge("income", report.getIncome(), Double::sum);
}

private void combiner(Map<String, Double> firstMap, Map<String, Double> secondMap) {
    secondMap.forEach((k, v) -> firstMap.merge(k, v, Double::sum));
}