pyflink.datastream.stream_execution_environment.StreamExecutionEnvironment.register_slot_sharing_group

StreamExecutionEnvironment.register_slot_sharing_group(slot_sharing_group: SlotSharingGroup) → StreamExecutionEnvironment

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.