Число созданий Flink KeyedProcessFunction ⇐ JAVA

[Anonymous]

Я новичок в 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