Java流过滤器值之和

我有一堂课叫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)

但显然这是行不通的。我该如何解决这个问题才能使其返回Map<String, Long>?

我首先会像你已经做的那样：我会收集流MonitoredData将实例映射到地图，按活动分组并对每个值中每个活动的持续时间求和：

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

细微差别是我正在使用的重载版本Collectors.groupingBy接受地图工厂 http://docs.oracle.com/javase/8/docs/api/java/util/stream/Collectors.html#groupingBy-java.util.function.Function-java.util.function.Supplier-java.util.stream.Collector-，因为下一步我想删除持续时间小于 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 http://docs.oracle.com/javase/8/docs/api/java/util/stream/Collectors.html#collectingAndThen-java.util.stream.Collector-java.util.function.Function-修改返回的地图Collectors.groupingBy。而且，在整理器功能中，我使用了Collection.removeIf https://docs.oracle.com/javase/8/docs/api/java/util/Collection.html#removeIf-java.util.function.Predicate-，它接受一个谓词并删除与该谓词匹配的所有条目。