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/

Thank you

Reply via email to