java - 如何使用 Java 8 Stream API 减少组并返回排序列表

Question

是否有更简单的方法来执行以下 groupBy 的归约和排序？我不明白如何避免打开可选的包装，也不知道为什么可选的一开始就在那里。

给定的List<Response>包含许多回复。对于每组Response实体(按 taskId 分组)，我只想要 Response为该组提供最新的 submissionDateTime 。 submissionDateTime是 Optional<OffsetDateTime>关于Response实体。

Comparator<Response> bySubmissionDate = Comparator.comparing(
    r -> r.getSubmissionDateTime().orElse(OffsetDateTime.MAX)
);
List<Response> responses = responses.stream()
        .collect(Collectors.groupingBy(
            Response::getTaskId,
            Collectors.reducing(maxBy(bySubmissionDate))
        )).values().stream()
        .map(Optional::get)
        .sorted(bySubmissionDate)
        .collect(Collectors.toList());

肯定有更好的方法来做到这一点。最终的排序很重要，因此最终的 .sorted(bySubmissionDate)标准。

编辑鉴于响应，我已经能够按如下方式减少代码:

List<Response> responses = responses.stream()
            .collect(Collectors.groupingBy(
                ResponseComplete::getTaskId,
                Collectors.maxBy(bySubmissionDate)
            )).values().stream()
            .map(Optional::get)
            .sorted(bySubmissionDate)
            .collect(Collectors.toList());

还值得注意的是，submissionDateTime是 Optional<OffsetDateTime>关于Response界面。实际submissionDateTime不是字段级别 Optional .

Answer 1

... or why the Optional is even there to begin with.

这是减少空流时的安全措施。这种情况下的最大值是多少？这是未知的，因此可能有也可能没有实际的返回值。这就是可选的用武之地。

但在这种情况下，您始终可以安全地调用 Optional.get，因为 groupingBy 生成的组永远不会为空。如果组中没有元素，则永远不会为其创建列表。 (但是，还原收集器不知道这一点。)

你的方法很好。

<小时/>

P.S.，您也可以直接使用 maxBy 收集器。