Java8:AveragingDouble和到对象的映射

Question

List<Transaction> transactions = Arrays.asList(
                new Transaction(brian, 2011, 300, "X", "M1"),
                new Transaction(raoul, 2012, 1000, "T", "M1"),
                new Transaction(raoul, 2011, 400, "S", "M2"),
                new Transaction(mario, 2012, 710, "X", "M1"),
                new Transaction(mario, 2012, 700, "X", "M2"),
                new Transaction(alan, 2012, 950, "T", "M1")
        );

class Transaction {
    private final Trader trader;
    private final int year;
    private final int value;
    private String type;
    private String method;
}

在计算之前。对列表执行以下操作：

• 将事务处理按年份分组
• 然后按方法分组

最后产生的对象应该有平均值、年份和方法的值。

class Result {
    private Double avg;
    private int year;
    private String method;
}

 Map<Integer, Map<String, Result>> res = transactions.stream().collect(
                groupingBy(Transaction::getYear,
                        groupingBy(Transaction::getMethod),
                            collectingAndThen( averagingDouble( t -> "X".equals(t.getType()) ? 1: 0 ),
                                    v -> new Result(v, GROUP_METHOD? , GROUP_YEAR?))
                )
        );

Answer 1

您可以这样做：

在使用映射收集器按年份和方法进行分组后，将Result对象创建为Collectors.Mapping(t->New Result(...))，正如您所知Mappingcollector将收集器作为第二个参数。因为您希望在分组后合并它们并计算平均值，所以collectingandthencollector是在这里执行该操作的最佳选择。实际上，collectingandthen在收集到列表之后，将一个函数作为完成器（平均函数），并计算列表中所有元素的平均值。

transactions.stream().collect(
      groupingBy(Transaction::getYear,
           groupingBy(Transaction::getMethod,
               mapping(t -> new Result((double) t.getValue(), t.getYear(), t.getMethod()),
                        collectingAndThen(Collectors.toList(), average::apply)))));

而平均函数为：

 Function<List<Result>, Result> average = l -> new Result(l.stream()
            .mapToDouble(Result::getAvg)
            .average().orElse(0d), l.get(0).getYear(), l.get(0).getMethod());