I can use filtering to do it but I preferred process function because I
don't have to do a KeyBy again to do the windowing or use reinterpret. The
problem I'm having is if I use the processFunction and registered a timer
and before the timer is fired if I have more input records, how can I avoid
cr
Hi Navneeth,
You could also apply filtering on the incoming records before windowing.
This might save you some development effort but I do not know full details
of your requirement whether filtering is sufficient.
In general, you can use timers as you suggested as the windowing itself
works in a s
Hi All,
I'm currently using a tumbling window of 5 seconds using TumblingTimeWindow
but due to change in requirements I would not have to window every incoming
data. With that said I'm planning to use process function to achieve this
selective windowing.
I looked at the example provided in the do
