Я новичок в Flink и пытаюсь понять, меняется ли количество созданных экземпляров
KeyedProcessFunction в зависимости от того, где я создал функцию.
Код: Выделить всё
MyProcessFunction myFunction = new MyProcessFunction()
events.keyBy(value -> value.getKey())
.process(myFunction)
Из документации я понимаю, что если вместо этого я создам его вот так
Код: Выделить всё
events.keyBy(value -> value.getKey())
.process(new MyProcessFunction())
он создаст MyProcessFunction для каждого элемента в потоке. Однако я написал тестовый код, и он создал только один. Я что-то пропустил? Кроме того, если он создает более одного, создается ли он по одному для каждого элемента или по одному для каждого
KeyedStream, созданного в методе keyBy?
Подробнее здесь:
https://stackoverflow.com/questions/787 ... tion-count