your case?
>
> Am 23.06.2017 um 10:55 schrieb Álvaro Vilaplana García <
> alvaro.vilapl...@gmail.com>:
>
> Hi Stefan,
>
> You meant
>
> /**
> * Registers a timer to be fired when processing time passes the given time.
> *
> * Timers can internally be sco
org.apache.flink.streaming.api.datastream.KeyedStream} then
that context
* will also be active when you receive the timer notification.
*/
void registerProcessingTimeTimer(long time);
Am i right?
Cheers
2017-06-23 9:51 GMT+01:00 Álvaro Vilaplana García <
alvaro.vilapl...@gmail.com>:
> Hi Stefan,
>
> Thank you for your
ation of event time
> and processing time. In the processing function, after each device event,
> you could register a timer so far ahead in processing time that it can
> serve as a signal to check for time outs because you did not receive events
> in a long time.
>
> Best,
e, how else could Flink advance event time without receiving further
> events?
>
> Best,
> Stefan
>
> > Am 22.06.2017 um 16:35 schrieb Álvaro Vilaplana García <
> alvaro.vilapl...@gmail.com>:
> >
> > Hi,
> >
> > Please, can you help me wit
hides the above problem.
I am using Scala 2.11 /Flink versions 1.2.0
Regards
--
______
Álvaro Vilaplana García
