I also ran into a similar use case. Is this possible?
On 15 July 2015 at 18:12, Michel Hubert mich...@vsnsystemen.nl wrote:
Hi,
I want to implement a time-out mechanism in de updateStateByKey(…)
routine.
But is there a way the retrieve the time of the start of the batch
Hi,
I want to implement a time-out mechanism in de updateStateByKey(...) routine.
But is there a way the retrieve the time of the start of the batch
corresponding to the call to my updateStateByKey routines?
Suppose the streaming has build up some delay then a System.currentTimeMillis()
will
