Apache Flink 中的 KeyBy 与 GroupBy

Question

Flink中KeyBy和GroupBy的异同点是什么？如果一个人在 Table 中使用 Table/SQL API 只有程序是 GroupBy 等同于 KeyBy?

Answer 1

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

Answer 2

KeyBy 用于流数据（如果是键控流），GroupBy 用于数据集 API 用于批处理。