pyflink.datastream.data_stream.DataStream.slot_sharing_group#
- DataStream.slot_sharing_group(slot_sharing_group: str | SlotSharingGroup) DataStream[source]#
Sets the slot sharing group of this operation. Parallel instances of operations that are in the same slot sharing group will be co-located in the same TaskManager slot, if possible.
Operations inherit the slot sharing group of input operations if all input operations are in the same slot sharing group and no slot sharing group was explicitly specified.
Initially an operation is in the default slot sharing group. An operation can be put into the default group explicitly by setting the slot sharing group to ‘default’.
- Parameters:
slot_sharing_group – The slot sharing group name or which contains name and its resource spec.
- Returns:
This operator.