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

Interface SlotMatchingResolver

All Known Implementing Classes:

SimpleSlotMatchingResolver, SlotsBalancedSlotMatchingResolver, TasksBalancedSlotMatchingResolver

public interface SlotMatchingResolver

The interface to define the methods for request slot matching resolver.

Field Summary

Fields

Modifier and Type	Field	Description
static Supplier<org.apache.flink.util.FlinkRuntimeException>	NO_SLOTS_EXCEPTION_GETTER

Method Summary

Modifier and Type	Method	Description
Collection<JobSchedulingPlan.SlotAssignment>	matchSlotSharingGroupWithSlots(Collection<SlotSharingSlotAllocator.ExecutionSlotSharingGroup> requestGroups, Collection<PhysicalSlot> freeSlots)	Match slots from the free slots with the given collection of requests execution groups.

Field Detail

NO_SLOTS_EXCEPTION_GETTER

static final Supplier<org.apache.flink.util.FlinkRuntimeException> NO_SLOTS_EXCEPTION_GETTER

Method Detail

matchSlotSharingGroupWithSlots

Collection<JobSchedulingPlan.SlotAssignment> matchSlotSharingGroupWithSlots(Collection<SlotSharingSlotAllocator.ExecutionSlotSharingGroup> requestGroups,
                                                                            Collection<PhysicalSlot> freeSlots)

Match slots from the free slots with the given collection of requests execution groups.

Parameters:

requestGroups - the requested execution slot sharing groups.

freeSlots - the free slots.

Returns:

The assignment result.