基于 Java 8 流 api 键的合并

Question

我最近开始学习流 API。 我正在尝试从以下代码中删除重复项。 是否可以使用基于Predicate 或条件的合并功能？ （我也在考虑使用来自Collectors 的partitioningBy 或groupingBy）

BinaryOperator<LocalDateTime> latestDate = (p, a) -> a.isAfter(p) ? a : p;
BinaryOperator<LocalDateTime> earliestDate = (p, a) -> a.isBefore(p) ? a : p;


         Map<Status,LocalDateTime> latest = history.stream()
                    .filter(isNewOrOpen.negate())
                    .collect(toMap(History::getStatus,
                            History::getChangedtetme,
                            latestDate));

        Map<Status,LocalDateTime> earliest = history.stream()
                    .filter(isNewOrOpen)
                    .collect(toMap(History::getStatus,
                            History::getChangedtetme,
                            earliestDate));

            latest.putAll(earliest);

Answer 1

如果我正确理解您的问题，isNewOrOpen 谓词使用History.getStatus()，并且您希望选择日期最早的历史项目作为新/打开状态，而选择日期最晚的历史项目作为其他状态。最好定义实现这个逻辑的Comparator（这里假设h1和h2的状态相同）：

Comparator<History> comparator = (h1, h2) -> isNewOrOpen.test(h1) ? 
    h2.getChangedtetme().compareTo(h1.getChangedtetme()):
    h1.getChangedtetme().compareTo(h2.getChangedtetme());

使用这个比较器，很容易定义收集器来解决你的任务：

Collector<History, ?, Map<Status, LocalDateTime>> collector
        = groupingBy(History::getStatus, 
                collectingAndThen(maxBy(comparator), 
                opt -> opt.get().getChangedtetme()));

注意collectingAndThen 的用法：maxBy 返回Optional<History>，我们要提取getChangedtetme()（不管它是什么意思）。

所以最后你可以直接使用这个收集器了：

Map<Status, LocalDateTime> result = history.stream().collect(collector);

latestDate 和 earliestDate 似乎没有必要。

Answer 2

正如你所说，你可以使用 Collectors.partitioningBy 来做你想做的事。

BinaryOperator<LocalDateTime> latestDate = (p, a) -> a.isAfter(p) ? a : p;

Map<Boolean, Map<Status,LocalDateTime>> partitions = 
        history.stream()
               .collect(partitioningBy(isNewOrOpen,
                                       toMap(History::getStatus,
                                       History::getChangedtetme,
                                       latestDate));

Map<Status,LocalDateTime> latest = partitions.get(true);
Map<Status,LocalDateTime> earliest = partitions.get(false);