Hi,
As Xingcan responded, you could use already built in operator for that.
If you really want to implement something on your own (need custom feature? For
fun?), you would have to implement some variation of a InternalTimerService
from Flink (you can browse the code for an inspiration). On ea
Hi Dhruv,
there’s no need to implement the window logic with the low-level
`ProcessFunction` yourself. Flink has provided built-in window operators and
you just need to implement the `WindowFunction` for that [1].
Best,
Xingcan
[1]
https://ci.apache.org/projects/flink/flink-docs-master/dev/st
