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
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? a
