- class BroadcastProcessFunction(*args, **kwds)[source]#
A function to be applied to a
BroadcastStream, i.e. a stream with broadcast state, with a non-keyed
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 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.
New in version 1.16.0.
This method is called for each element in the
This method is called for each element in the (non-broadcast)