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

Interface SlotSharingResolver

All Known Implementing Classes:

DefaultSlotSharingResolver, TaskBalancedSlotSharingResolver

public interface SlotSharingResolver

The resolver to define how to construct execution slot sharing groups from the execution vertices of a job with the vertices parallelisms.

Method Summary

Modifier and Type	Method	Description
Collection<SlotSharingSlotAllocator.ExecutionSlotSharingGroup>	getExecutionSlotSharingGroups(JobInformation jobInformation, VertexParallelism vertexParallelism)	Get the execution slot sharing groups for the job information based on the vertices parallelisms.

Method Detail

getExecutionSlotSharingGroups

Collection<SlotSharingSlotAllocator.ExecutionSlotSharingGroup> getExecutionSlotSharingGroups(JobInformation jobInformation,
                                                                                             VertexParallelism vertexParallelism)

Get the execution slot sharing groups for the job information based on the vertices parallelisms.

Parameters:

jobInformation - the job information.

vertexParallelism - the parallelisms for the vertices of the job information.

Returns:

the all execution slot sharing groups for the deployment of the job.