Есть ли у Flink распространение по команде (похоже на Spark)

Я хочу перетасовать данные по ключу и записать данные в сток.

Я не использую group by, потому что мне не нужно делать агрегаты.

Поэтому мне интересно, есть ли у flink sql ключевое слово вроде «распространять по» в Spark.


apache-flink flink-sql
person yunfan    schedule 05.11.2019    source источник

Ответы (1)


arrow_upward
0
arrow_downward

Мне это кажется хакерским, но этого можно добиться с помощью MATCH_RECOGNIZE и PARTITION BY. Надеюсь, есть более чистый способ, которого я не вижу.

person David Anderson    schedule 05.11.2019