Может ли KeyBy (key1 или key2) в FLINK? - PullRequest
0 голосов
/ 26 апреля 2019

Есть ли в Flink способ использовать keyby (key1 или key2) (клавиши ORing) Я не имею в виду keyBy (0,1) Мне нужно перенаправить элементы с key1 или элементы с key2 на один и тот же узел.

1 Ответ

2 голосов
/ 28 апреля 2019

Самое простое, что вы можете сделать, это написать функцию KeySelector, которая возвращает один и тот же ключ для всех событий, которые вы хотите обрабатывать вместе. События, имеющие один и тот же ключ, будут обрабатываться одним и тем же узлом и совместно использовать состояние ключа и таймеры, если это будет актуально.

Если вы хотите, чтобы события имели разные ключи, но все же обрабатывались одним и тем же узлом (признаюсь, мне любопытно узнать, почему это было бы желательно), то вам нужно будет организовать, чтобы они были в одном и том же ключе группа. Это становится сложным; см. эту ветку списка рассылки для некоторого обсуждения этого.

...