Search code examples
apache-flinkflink-streamingflink-sql

KeyBy vs GroupBy in Apache Flink


What are the similarities and differences of KeyBy and GroupBy in Flink? If one is using the Table/SQL API in a Table only program is GroupBy equivalent to KeyBy?


Solution

  • The streaming GroupBy in the Table/SQL API is the keyBy from the DataStream API.