Flink 指定 keys 的几种方法

Flink 版本：1.13.6

一些转换(例如，join，coGroup，keyBy，groupBy)可以在一组元素上定义一个 key，其他转换(Reduce，GroupReduce，Aggregate，Windows)就可以在使用这些函数之前根据指定的 key 对数据进行分组。

一个 DataSet 进行如下分组:

DataSet<...> input = // [...]
DataSet<..
1