Class ExecutionSlotSharingGroup
- java.lang.Object
-
- org.apache.flink.runtime.scheduler.ExecutionSlotSharingGroup
-
- All Implemented Interfaces:
WeightLoadable
public class ExecutionSlotSharingGroup extends Object implements WeightLoadable
Represents execution vertices that will run the same shared slot.
-
-
Constructor Summary
Constructors Constructor Description ExecutionSlotSharingGroup(SlotSharingGroup slotSharingGroup)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidaddVertex(ExecutionVertexID executionVertexId)Set<ExecutionVertexID>getExecutionVertexIds()LoadingWeightgetLoading()Get the loading weight.SlotSharingGroupgetSlotSharingGroup()StringtoString()
-
-
-
Constructor Detail
-
ExecutionSlotSharingGroup
public ExecutionSlotSharingGroup(@Nonnull SlotSharingGroup slotSharingGroup)
-
-
Method Detail
-
addVertex
public void addVertex(ExecutionVertexID executionVertexId)
-
getSlotSharingGroup
@Nonnull public SlotSharingGroup getSlotSharingGroup()
-
getExecutionVertexIds
public Set<ExecutionVertexID> getExecutionVertexIds()
-
getLoading
@Nonnull public LoadingWeight getLoading()
Description copied from interface:WeightLoadableGet the loading weight.- Specified by:
getLoadingin interfaceWeightLoadable- Returns:
- An implementation object of
LoadingWeight.
-
-