Hi, I am sorry, but I think I don't fully get your question. Could you try to rephrase it? Maybe an example could help.
Generally speaking the KeyedProcessFunction is scoped to a single key. Whenever you access a state (MapState, ValueState, ... ) it keeps the current value of that state for the current key. Best, Dawid On 06/05/2021 12:30, Abdullah bin Omar wrote: > Hi, > > According to [1] example section, > > (i) If we check the stored count of the last modification time against > the previous timestamp count, then emit the count if they (count from > last modification time) match with the previous timestamp count. > > Is there refere about checking the previous count? am I understanding > correctly? help me to understand this part. > > (ii) can the process function be used to look back the previous > key/count? > > [1] > https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/datastream/operators/process_function/ > <https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/datastream/operators/process_function/> > > Thank you >
OpenPGP_signature
Description: OpenPGP digital signature
