Hi！ 可以用 SQL 的聚合函数 [1] 实现。内置聚合函数详见 [2]，也可以自定义聚合函数，详见 [3]。
[1] https://nightlies.apache.org/flink/flink-docs-master/zh/docs/dev/table/sql/queries/group-agg/ [2] https://nightlies.apache.org/flink/flink-docs-master/zh/docs/dev/table/functions/systemfunctions/#%E8%81%9A%E5%90%88%E5%87%BD%E6%95%B0 [3] https://nightlies.apache.org/flink/flink-docs-master/zh/docs/dev/table/functions/udfs/#%E8%81%9A%E5%90%88%E5%87%BD%E6%95%B0 Pinjie Huang <[email protected]> 于2021年12月14日周二 15:48写道： > 之前的DataStream API 我们可以通过State进行一些复杂的逻辑。比如所有message的某个field的最大值。Flink > SQL有类似的方法吗？ >
