如何根据Java列表中的maxDate记录进行分组和筛选

Question

我有一个java POJO收集metics如下：

public class Metric {

    Long metricId;
    Long resultKeyId;
    @NonNull DatasetType datasetType;
    @NonNull String datasetName;
    @NonNull String analyzerName;
    @NonNull String constraintAlias;
    @NonNull LocalDateTime entityDate;
    @NonNull long entityDurationSec;
    @NonNull Double metricValue;
    @NonNull String changedBy;
    Long jobId = 0L;
    Long codeArtifactId = 0L;
    LocalDateTime createdAt;
    LocalDateTime lastChanged;

}

我有一个来自上面pojo的度量列表，如List

现在，这个列表可以有多个项目，我只想用maxcreatedAt

SQL的表示方式如下：

select a.* from 
dataval_metric a 
join dataval_metric b 
on a.result_key_id=b.result_key_id 
and a.dataset_type=b.dataset_type 
and a.dataset_name=b.dataset_name 
and a.analyzer_name=b.analyzer_name 
and a.constraint_alias=b.constraint_alias  
where a.result_key_id = 434 
and a.mysql_row_created_at >= b. mysql_row_created_at;

正在寻找指针，以了解如何在Java中以高效的方式实现这一点




Answer 1

这样做的方法之一。

所以我们使用收集器。toMap，它将表示为记录的键映射为一个度量键（基本上这只是需要分组的字段的元组）到一个度量值。由于toMap不允许重复，我们还提供了merge函数，该函数始终在映射中保持最大createdDate的度量。

因此，我建议将getKey方法添加到Metric类中，以便它以记录或自定义类的形式返回密钥，从而覆盖equals和hashCode。

class Metric
{
  // ... all your fields
   
  record MetricKey(Long resultKeyId, String analyzerName,
       DatasetType datasetType, String datasetName, String constraintAlias) {  }
   
  public MetricKey getKey() {
    return new MetricKey(resultKeyId, datasetType, datasetName,
       analyzerName, constraintAlias);
  }

  public LocalDateTime getCreatedAt() {
    return createdAt;
  }
}

以及数据处理管道：

List<Metric> maximums = new ArrayList<>(metrics.stream().collect(
  Collectors.toMap(
    Metric::getKey,
    Function.identity(),
    (m1, m2) -> m1.createdAt > m2.createdAt ? m1 : m2))
  .values());

Answer 2

您必须使用gropingBy方法使用字段作为键。

关键在于：

1. 清单：

Map<List<Object>, Optional<Metric>> map = metrics.stream()
        .collect(Collectors.groupingBy(m ->
                        List.of(m.getResultKeyId(),
                                m.getDatasetType(),
                                m.getDatasetName(),
                                m.getAnalyzerName(),
                                m.getConstraintAlias()),
                Collectors.maxBy(Comparator.comparing(Metric::getCreatedAt))));

Map<Metric, Optional<Metric>> map = metrics.stream()
        .collect(Collectors.groupingBy(m -> m,
                Collectors.maxBy(Comparator.comparing(Metric::getCreatedAt))));

Map<Quintet, Optional<Metric>> map = metrics.stream()
        .collect(Collectors.groupingBy(m ->
                        new Quintet(m.getResultKeyId(),
                                m.getDatasetType(),
                                m.getDatasetName(),
                                m.getAnalyzerName(),
                                m.getConstraintAlias()),
                Collectors.maxBy(Comparator.comparing(Metric::getCreatedAt))));