Package org.apache.flink.runtime.scheduler

Class TaskBalancedExecutionSlotSharingGroupBuilder

java.lang.Object

org.apache.flink.runtime.scheduler.TaskBalancedExecutionSlotSharingGroupBuilder

public class TaskBalancedExecutionSlotSharingGroupBuilder
extends Object

Execute slot sharing groups builder based on the balanced scheduling strategy.

Field Summary

Fields

Modifier and Type	Field	Description
static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor	Description
TaskBalancedExecutionSlotSharingGroupBuilder(Map<JobVertexID,List<ExecutionVertexID>> allVertices, Collection<SlotSharingGroup> slotSharingGroups, Collection<CoLocationGroup> coLocationGroups)

Method Summary

Modifier and Type	Method	Description
Map<ExecutionVertexID,ExecutionSlotSharingGroup>	build()

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final org.slf4j.Logger LOG

Constructor Detail

TaskBalancedExecutionSlotSharingGroupBuilder

public TaskBalancedExecutionSlotSharingGroupBuilder(Map<JobVertexID,List<ExecutionVertexID>> allVertices,
                                                    Collection<SlotSharingGroup> slotSharingGroups,
                                                    Collection<CoLocationGroup> coLocationGroups)

Method Detail

build

public Map<ExecutionVertexID,ExecutionSlotSharingGroup> build()