pyflink.datastream.functions.BroadcastProcessFunction

class BroadcastProcessFunction

A function to be applied to a BroadcastConnectedStream that connects BroadcastStream, i.e. a stream with broadcast state, with a non-keyed DataStream.

The stream with the broadcast state can be created using the DataStream.broadcast() method.

The user has to implement two methods:

• the process_broadcast_element() which will be applied to each element in the broadcast side

• the process_element() which will be applied to the non-broadcasted side.

The 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.

Methods

close()
open(runtime_context)
process_broadcast_element(value, ctx)	This method is called for each element in the BroadcastStream.
process_element(value, ctx)	This method is called for each element in the (non-broadcast) DataStream.