核心代码:
根据stationIdC对数据分组,通过对每组timestamp进行比较,获取每组timestamp最大的那条记录,返回结果为Map。
Map<String, AtstationDTO> latestStations = stations.parallelStream().collect(Collectors.toMap(Atstation::getStationIdC, Function.identity(), (c1, c2) -> c1.getTimestamp() > c2.getTimestamp() ? c1 : c2));
return new ArrayList<>(latestStations.values());
版权声明:本文为weixin_44917045原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。