Apache Flink 中的 KeyBy 与 GroupBy

【问题标题】：KeyBy vs GroupBy in Apache FlinkApache Flink 中的 KeyBy 与 GroupBy
【发布时间】：2020-12-24 01:21:14
【问题描述】：

Flink 中的 KeyBy 和 GroupBy 有什么异同？如果在 Table only 程序中使用 Table/SQL API，GroupBy 是否等同于 KeyBy？

【问题讨论】：

【解决方案1】：

Table/SQL API 中的流式 GroupBy 是来自 DataStream API 的 keyBy。

【讨论】：

【解决方案2】：

KeyBy 用于 Streams 数据（在 keyed Streams 的情况下），GroupBy 用于 Data set API for Batch Processing。

【讨论】：