Package org.apache.flink.runtime.scheduler.adaptive.allocator

Class SlotSharingSlotAllocator.ExecutionSlotSharingGroup

java.lang.Object

org.apache.flink.runtime.scheduler.adaptive.allocator.SlotSharingSlotAllocator.ExecutionSlotSharingGroup

All Implemented Interfaces:

WeightLoadable

Enclosing class:

SlotSharingSlotAllocator

public static class SlotSharingSlotAllocator.ExecutionSlotSharingGroup
extends Object
implements WeightLoadable

The execution slot sharing group for adaptive scheduler.

Constructor Summary

Constructors

Constructor	Description
ExecutionSlotSharingGroup(String id, SlotSharingGroup slotSharingGroup, Set<ExecutionVertexID> containedExecutionVertices)
ExecutionSlotSharingGroup(SlotSharingGroup slotSharingGroup, Set<ExecutionVertexID> containedExecutionVertices)

Method Summary

Modifier and Type	Method	Description
Collection<ExecutionVertexID>	getContainedExecutionVertices()
String	getId()
LoadingWeight	getLoading()	Get the loading weight.
SlotSharingGroup	getSlotSharingGroup()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ExecutionSlotSharingGroup

public ExecutionSlotSharingGroup(SlotSharingGroup slotSharingGroup,
                                 Set<ExecutionVertexID> containedExecutionVertices)

ExecutionSlotSharingGroup

public ExecutionSlotSharingGroup(String id,
                                 SlotSharingGroup slotSharingGroup,
                                 Set<ExecutionVertexID> containedExecutionVertices)

Method Detail

getSlotSharingGroup

@VisibleForTesting
public SlotSharingGroup getSlotSharingGroup()

getId

public String getId()

getContainedExecutionVertices

public Collection<ExecutionVertexID> getContainedExecutionVertices()

getLoading

@Nonnull
public LoadingWeight getLoading()

Description copied from interface: WeightLoadable

Get the loading weight.

Specified by:

getLoading in interface WeightLoadable

Returns:

An implementation object of LoadingWeight.