AFAIK Flink's source/sink interface do not expose something akin to the
ProcessFunction's TimerService,
so I would suggest to use an ScheduledExecutorService or similar.
Technically you can use process functions as sources, the easiest way
being to create a dummy source which broadcasts a singl
What is the best way to add timer to a source/sink? (Apologies if I’m asking
the question that’s already being answered elsewhere), also is it possible to
use process function as source or sink?
Thanks
Ishwara
