pyflink.datastream.stream_execution_environment.StreamExecutionEnvironment.register_slot_sharing_group#
- StreamExecutionEnvironment.register_slot_sharing_group(slot_sharing_group: pyflink.datastream.slot_sharing_group.SlotSharingGroup) pyflink.datastream.stream_execution_environment.StreamExecutionEnvironment [source]#
Register a slot sharing group with its resource spec.
Note that a slot sharing group hints the scheduler that the grouped operators CAN be deployed into a shared slot. There’s no guarantee that the scheduler always deploy the grouped operators together. In cases grouped operators are deployed into separate slots, the slot resources will be derived from the specified group requirements.
- Parameters
slot_sharing_group – Which contains name and its resource spec.
- Returns
This object.