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

Class PreferredAllocationRequestSlotMatchingStrategy

java.lang.Object

org.apache.flink.runtime.jobmaster.slotpool.PreferredAllocationRequestSlotMatchingStrategy

All Implemented Interfaces:

RequestSlotMatchingStrategy

public class PreferredAllocationRequestSlotMatchingStrategy
extends Object
implements RequestSlotMatchingStrategy

RequestSlotMatchingStrategy that takes the preferred allocations into account. The strategy will try to fulfill the preferred allocations and if this is not possible, then it will fall back to rollbackStrategy.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.runtime.jobmaster.slotpool.RequestSlotMatchingStrategy

RequestSlotMatchingStrategy.RequestSlotMatch

Method Summary

Modifier and Type	Method	Description
static RequestSlotMatchingStrategy	create(RequestSlotMatchingStrategy rollbackStrategy)
boolean	equals(Object o)
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.
String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

create

public static RequestSlotMatchingStrategy create(RequestSlotMatchingStrategy rollbackStrategy)

matchRequestsAndSlots

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

Description copied from interface: RequestSlotMatchingStrategy

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

Specified by:

matchRequestsAndSlots in interface RequestSlotMatchingStrategy

Parameters:

slots - slots to match

pendingRequests - slot requests to match

taskExecutorsLoadingWeight - current task executors loading weight information

Returns:

resulting matches of this operation

equals

public boolean equals(Object o)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object