Re: Implementing a tick service

2020-01-21 Thread Dominik Wosiński
Hey, you have access to context in `onTimer` so You can easily reschedule the timer when it is fired. Best, Dom.

Re: Implementing a tick service

2020-01-21 Thread Benoît Paris
Hello all! Please disregard the last message; I used Thread.sleep() and Stateful Source Functions . But just out of curiosity, can processing-time Timers get rescheduled inside the onTim

Implementing a tick service

2020-01-20 Thread Benoît Paris
Hello all :)! I'm having trouble creating a tick service. Goal: register a TableSource that emits a Row roughly every 200ms in processing time. The Row would contain only one column "counter" that is incremented by 1 each Row. Current attempt: Using TimerService A TableSource with public DataSt