Apache Flink中的KeyBy与GroupBy

问题描述

Flink中的KeyBy和GroupBy有何异同？如果仅在Table程序中使用Table / sql API，GroupBy是否等效于KeyBy？

解决方法

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

,

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