Re: KeyedStream and keyedProcessFunction

[1048262223]

Hi


+1. Because there is no need to generate an instance for each key, flink just 
maintain the key collection in one instance. Imagine what would happen if the 
number of keys were unlimited.



Best,
Yichao Yang




------------------ Original ------------------
From:&nbsp;"Tzu-Li (Gordon) Tai"<tzuli...@apache.org&gt;;
Date:&nbsp;Tue, Jun 9, 2020 06:33 PM
To:&nbsp;"user"<user@flink.apache.org&gt;;

Subject:&nbsp;Re: KeyedStream and keyedProcessFunction



Hi,

Records with the same key will be processed by the same partition.
Note there isn't an instance of a keyed process function for each key.
There is a single instance per partition, and all keys that are distributed
to the same partition will get processed by the same keyed process function
instance.

Gordon



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/