pyflink.datastream.state.OperatorStateStore.get_broadcast_state#
- abstract OperatorStateStore.get_broadcast_state(state_descriptor: MapStateDescriptor) BroadcastState[source]#
Fetches the
BroadcastStatedescribed byMapStateDescriptor, which has read/write access to the broadcast operator state.