Thanks for the super-helpful reply!
Would the late-firing from the "hourly" window be considered an on-time
arrival for the subsequent "daily" window operator? Since, its windowing
duration is much longer (1 day), I'd expect the "on-time/default" result
emitted from the "daily" window to include
k at, I'd appreciate
that as well. Thank you for the help.
--
Jagadish V,
Graduate Student,
Department of Computer Science,
Stanford University
Hi,
I have been recently into the application development with flink. We are
trying to use the flink-apache connectors to get the data in and out from
Cassandra.
We attempted both Datastax drivers and Flink-cassandra connectors. In this
process felt that flink-cassandra connector is more of a wr
x27;s implementations
everywhere.
So what is the reason that ProcessFunction.Context uses TimerService? Any
reason 'deleteEventTimeTimer' is not exposed to users? If I want to use the
deleteEvent functionality how should I go about it?
--
Thanks and Regards,
Jagadish Bihani
