[FLINK-28469] Setting a timer within broadcast applyToKeyedState()

• Type: Improvement
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Affects Version/s: 1.16.0
• Component/s: API / DataStream
• Assignee: Unassigned
• Reporter: James
• Created: 08/Jul/22 16:09
• Updated: 03/Nov/22 08:00

Description

I know we can’t set a timer in the processBroadcastElement() of the KeyedBroadcastProcessFunction as there is no key.

 

However, there is a context.applyToKeyedState() method which allows us to iterate over the keyed state in the scope of a key. So it is possible to add access to the TimerService onto the Context parameter passed into that delegate?

 

Since the code running in the applyToKeyedState() method is scoped to a key we should be able to set up timers for that key too.