[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: How to trigger a function on the state periodically?

Hi anna,

I need to trigger a function once every day
If you want to trigger by the function itself, you can use the Timer[1]. Both types of timers (processing-time and event-time) are internally maintained by the TimerService, and onTimer() method will be called once a timer fires.
If you want to trigger the function of different parallelism synchronously, then the broadcast state[2] may be helpful.

Hope this helps.

[1] https://ci.apache.org/projects/flink/flink-docs-master/dev/stream/operators/process_function.html#timers
[2] https://ci.apache.org/projects/flink/flink-docs-master/dev/stream/state/broadcast_state.html

On Tue, Jul 10, 2018 at 7:47 AM, anna stax <annastax80@xxxxxxxxx> wrote:
Hi all,

I need to trigger a function once every day to read the state and create kafka events and also remove some records from state if they are too old.

Is there a way to do this? I am new to Flink, appreciate any feedback and suggestions.