使用Java 8流聚合信息

Question

我仍在努力完全掌握如何使用Java 8中的流包，并希望得到一些帮助。

我有一个类，如下所述，我在列表中接收到作为数据库调用一部分的实例。

class VisitSummary {
    String source;
    DateTime timestamp;
    Integer errorCount;
    Integer trafficCount;
    //Other fields
}

为了生成一些可能有用的信息，我有一个类VisitSummaryBySource，它保存所有访问的总和（在给定的时间范围内）：

class VisitSummaryBySource {
    String sourceName;
    Integer recordCount;
    Integer errorCount;
}

我希望构建一个列表

有没有一种方法可以在单个操作中使用流来实现这一点？或者我是否需要将其分解为多个操作？我能想到的最好方法是：

Map<String, Integer> recordsBySrc = data.parallelStream().collect(Collectors.groupingBy(VisitSummaryBySource::getSource,
                    Collectors.summingInt(VisitSummaryBySource::getRecordCount)));

并计算误差

Map<String, Integer> errorsBySrc = data.parallelStream().collect(Collectors.groupingBy(VisitSummaryBySource::getSource,
                    Collectors.summingInt(VisitSummaryBySource::getErrorCount)));

并将这两张地图合并，得出我要查找的列表。

Answer 1

您走在正确的轨道上。Collectors.summingInt的使用是外部groupingBy收集器的下游收集器的示例。此操作从同一组中的每个VisitSummaryBySource实例中提取一个整数值，并对其求和。这本质上是对整数的减少。

正如您所注意到的，问题是您只能提取/减少其中一个整数值，因此您必须执行第二次传递来提取/减少其他整数值。

关键是不要考虑对单个整数值进行约简，而是对整个VisitSummaryBySource对象进行约简。还原需要一个BinarySwitator，它需要有关类型的两个实例并将它们组合成一个。以下是如何做到这一点，通过向VisitSummaryBySource添加静态方法：

static VisitSummaryBySource merge(VisitSummaryBySource a,
                                  VisitSummaryBySource b) {
    assert a.getSource().equals(b.getSource());
    return new VisitSummaryBySource(a.getSource(), 
                                    a.getRecordCount() + b.getRecordCount(),
                                    a.getErrorCount() + b.getErrorCount());
}

请注意，我们实际上并没有合并源名称。由于这种减少仅在源名称相同的组中执行，因此我们断言我们只能合并名称相同的两个实例。我们还假设明显的构造函数接受名称、记录计数和错误计数，并调用它来创建合并的对象，其中包含计数的总和。

现在，我们的流如下所示：

    Map<String, Optional<VisitSummaryBySource>> map =
        data.stream()
            .collect(groupingBy(VisitSummaryBySource::getSource,
                                reducing(VisitSummaryBySource::merge)));

请注意，此减少会产生可选类型的映射值

我们真的不在乎地图；它只需要保留足够长的时间，以减少VisitSummaryBySource实例。完成后，我们可以使用values（）拉出贴图值，然后扔掉贴图。

我们还可以将其转换回流，并通过映射它们来展开可选的。这是安全的，因为除非组中至少有一个成员，否则值永远不会出现在映射中。

最后，我们将结果收集到一个列表中。

最终代码如下所示：

    List<VisitSummaryBySource> output =
        data.stream()
            .collect(groupingBy(VisitSummaryBySource::getSource,
                                reducing(VisitSummaryBySource::merge)))
            .values().stream()
            .map(Optional::get)
            .collect(toList());