Flink 指定 keys 的几种方法
Posted @SmartSi
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Flink 指定 keys 的几种方法相关的知识，希望对你有一定的参考价值。
Flink 版本：1.13.6
一些转换(例如，join，coGroup，keyBy，groupBy)可以在一组元素上定义一个 key，其他转换(Reduce，GroupReduce，Aggregate，Windows)就可以在使用这些函数之前根据指定的 key 对数据进行分组。
一个 DataSet 进行如下分组:
DataSet<...> input = // [...]
DataSet<..以上是关于Flink 指定 keys 的几种方法的主要内容，如果未能解决你的问题，请参考以下文章