KeyBy против GroupBy в Apache Flink

В чем сходство и различие KeyBy и GroupBy во Flink? Если в программе только для таблиц используется API таблиц / SQL, является ли GroupBy эквивалентом KeyBy?


apache-flink flink-streaming flink-sql
person Aeden    schedule 04.09.2020    source источник

Ответы (2)


arrow_upward
5
arrow_downward

Потоковая GroupBy в Table / SQL API - это keyBy из DataStream API.

person David Anderson    schedule 05.09.2020

arrow_upward
1
arrow_downward

KeyBy используется для данных потоков (в случае потоков с ключами), а GroupBy используется для API набора данных для пакетной обработки.

person Murtaza Zaveri    schedule 05.09.2020