Hi! I want a window which should be fired each 5 seconds, whether or not there events.
env.socketTextStream("192.168.1.101", 9999)
.map(new mapper())
.keyBy(0)
.timeWindow(Time.seconds(5))
.apply(new MyRichWindowFunction())
It works if the window has events, but, it doesn't if there aren't events.
Somebody knows how I could force it. I tried with a trigger and
ContinuousProcessingTimeTrigger, but, I don't know how use it.
Regards,
Toletum
