在这个愚蠢的问题上，你能支持我吗
我有一些java类：

public class ProbePoint implements Serializable, Cloneable {
    private long arrivalTimeMillis = 0;
    private long captureTimeMillis = 0;
//...
}
public class Trip implements Serializable, Cloneable {
    private ArrayList<ProbePoint> points = new ArrayList<>();
//...
}

我有 Dataset[Trip] . 我需要收集一些最小/最大值。下一步的更好实施是什么：

public class DataRanges implements Serializable {
    private long minCaptureTs;
    private long maxArrivalTs;

}

 val timesDs: Dataset[DataRanges] = trips.mapPartitions(t => {
      var minCaptTime = Long.MaxValue
      var maxArrTime = Long.MinValue
      t.foreach(f => {
        if (f.points.head < minCaptTime) minCaptTime = f.points.head
        if (f.points.last.getArrivalTimeMillis > maxArrTime) maxArrTime = f.points.last.getArrivalTimeMillis
      })
      Iterator[DataRanges](
        new DataRanges(minStartTime, maxEndTime, minArrTime, maxArrTime))
    })(Encoders.bean(classOf[DataRanges]))
    val times = timesDs.agg(min("minCaptureTs"), max("maxArrivalTs")).head()
}
}