Hi Yuri,
I think you can achieve this by using "normal" flink operators and
sinks. One thing that immediately comes to my mind are timers [1].
It should be simpler to implement and setup rather than with the State
Processor API (though it seems doable via this API too).
[1]
https://ci.apache.org/
Please, someone help me to understand is State Processor Api a solve or not
for a task.
I want to add to state 'Events' some target actions of user and remove them
if cancel action is received.
Every X period I need to check this state if it's time to make some
communication with user. If yes, so
