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