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

Question

Java流新手在这里。目前我正在完成本书中关于收集者的第6章（用流收集数据）。

我的对象是这样的。

    public class Report {

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

这样做的目的是得到某种总体总结报告。基本上是一个HashMap

关键1：

投影-表示每个报告中所有投影的总和。

关键2：

<代码>票据-表示每个报表中所有票据的总和。

关键3：

收入-表示每个报表的所有收入之和。

现在，我实际上通过创建自定义收集器来进行赋值，称为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());

所以，我的问题是，为什么不创建新的收集器对象而以不同的方式执行此操作？也许，可以通过某种方式使用分组方式，或者使用减少？或者其他（更好）更可读的方式？

Answer 1

实际上，您不需要自定义收集器来实现此目的。您只需要供应商、累加器和合路器。

您可以将它们与流放在同一个类中，并按如下方式调用它：

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));
}