Package org.apache.flink.runtime.jobmaster.slotpool

Interface RequestSlotMatchingStrategy

All Known Implementing Classes:

PreferredAllocationRequestSlotMatchingStrategy, SimpleRequestSlotMatchingStrategy, TasksBalancedRequestSlotMatchingStrategy

public interface RequestSlotMatchingStrategy

Strategy to match slot requests to slots.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	RequestSlotMatchingStrategy.RequestSlotMatch	Result class representing matches.

Method Summary

Modifier and Type	Method	Description
Collection<RequestSlotMatchingStrategy.RequestSlotMatch>	matchRequestsAndSlots(Collection<? extends PhysicalSlot> slots, Collection<org.apache.flink.runtime.jobmaster.slotpool.PendingRequest> pendingRequests, Map<ResourceID,LoadingWeight> taskExecutorsLoadingWeight)	Match the given slots with the given collection of pending requests.

Method Detail

matchRequestsAndSlots

Collection<RequestSlotMatchingStrategy.RequestSlotMatch> matchRequestsAndSlots(Collection<? extends PhysicalSlot> slots,
                                                                               Collection<org.apache.flink.runtime.jobmaster.slotpool.PendingRequest> pendingRequests,
                                                                               Map<ResourceID,LoadingWeight> taskExecutorsLoadingWeight)

Match the given slots with the given collection of pending requests.

Parameters:

slots - slots to match

pendingRequests - slot requests to match

taskExecutorsLoadingWeight - current task executors loading weight information

Returns:

resulting matches of this operation