Java流过滤器值之和

Question

我有一个名为monitoreddata的类，用它描述活动及其开始时间和结束时间。这些属性是ActivityLabel、StartTime、EndTime。我必须使用流对这些活动进行分组和过滤，这些活动的总持续时间超过10小时。我成功地计算了持续时间的总和，并根据活动将它们分组：

Map<String, Long> map4 = new HashMap<String, Long>();

map4 = data.stream()
    .collect(
        Collectors.groupingBy(
            MonitoredData::getActivity, 
            Collectors.summingLong(MonitoredData::getDuration)
        )
    ); //getDuration returns end Time - startTime in milliseconds

.filter(Collectors.summingLong(MonitoredData::getDuration) > whatever)

Answer 1

我将首先像您已经做的那样做：我将monitoreddata实例流收集到一个映射中，按活动分组，并将每个活动的持续时间加在每个值中：

Map<String, Long> map4 = data.stream()
    .collect(Collectors.groupingBy(
        MonitoredData::getActivity, 
        HashMap::new,
        Collectors.summingLong(MonitoredData::getDuration)));

细微差别在于，我使用的是collectors.groupingby的重载版本，它接受映射的工厂，因为在下一步中，我希望删除持续时间小于10小时的条目，并且规范不能保证接受一个或两个参数的collectors.groupingby方法返回的映射是可变的。

这就是我删除不匹配项的方式：

public static final long TEN_HOURS_MS = 10 * 60 * 60 * 1000;

map4.values().removeIf(v -> v < TEN_HOURS_MS);

如果要在一行中完成所有操作，可能需要使用collectors.collectingandthen:

Map<String, Long> map4 = data.stream()
    .collect(Collectors.collectingAndThen(
        Collectors.groupingBy(
            MonitoredData::getActivity, 
            HashMap::new,
            Collectors.summingLong(MonitoredData::getDuration)),
        m -> { m.values().removeIf(v -> v < TEN_HOURS_MS); return m; } ));

这里我使用collectors.collectingandthen修改collectors.groupingby返回的映射。而且，在finisher函数中，我使用了collection.removeif，它接受一个谓词并删除与该谓词匹配的所有条目。