- class KeyedBroadcastProcessFunction(*args, **kwds)[source]#
A function to be applied to a
BroadcastStream, i.e. a stream with broadcast state, with a
The stream with the broadcast state can be created using the
The user has to implement two methods:
process_broadcast_element()which will be applied to each element in the broadcast side
process_element()which will be applied to the non-broadcasted/keyed side.
process_broadcast_element()takes a context as an argument (among others), which allows it to read/write to the broadcast state, while the
process_element()has read-only access to the broadcast state, but can read/write to the keyed state and register timers.
New in version 1.16.0.
Called when a timer set using
This method is called for each element in the
This method is called for each element in the (non-broadcast)