org.apache.flink.runtime.jobmaster.slotpool

Class PreviousAllocationSlotSelectionStrategy

java.lang.Object

org.apache.flink.runtime.jobmaster.slotpool.PreviousAllocationSlotSelectionStrategy

All Implemented Interfaces:

SlotSelectionStrategy

public class PreviousAllocationSlotSelectionStrategy
extends Object
implements SlotSelectionStrategy

This class implements a SlotSelectionStrategy that is based on previous allocations and falls back to using location preference hints if there is no previous allocation.

Nested Class Summary

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

SlotSelectionStrategy.SlotInfoAndLocality, SlotSelectionStrategy.SlotInfoAndResources

Method Summary

Modifier and Type	Method and Description
static PreviousAllocationSlotSelectionStrategy	create()
static PreviousAllocationSlotSelectionStrategy	create(SlotSelectionStrategy fallbackSlotSelectionStrategy)
Optional<SlotSelectionStrategy.SlotInfoAndLocality>	selectBestSlotForProfile(Collection<SlotSelectionStrategy.SlotInfoAndResources> availableSlots, SlotProfile slotProfile) Selects the best SlotInfo w.r.t.

Methods inherited from class java.lang.Object

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

Method Detail

selectBestSlotForProfile

public Optional<SlotSelectionStrategy.SlotInfoAndLocality> selectBestSlotForProfile(@Nonnull
                                                                                    Collection<SlotSelectionStrategy.SlotInfoAndResources> availableSlots,
                                                                                    @Nonnull
                                                                                    SlotProfile slotProfile)

Description copied from interface: SlotSelectionStrategy

Selects the best SlotInfo w.r.t. a certain selection criterion from the provided list of available slots and considering the given SlotProfile that describes the requirements.

Specified by:

selectBestSlotForProfile in interface SlotSelectionStrategy

Parameters:

availableSlots - a list of the available slots together with their remaining resources to select from.

slotProfile - a slot profile, describing requirements for the slot selection.

Returns:

the selected slot info with the corresponding locality hint.

create

public static PreviousAllocationSlotSelectionStrategy create()

create

public static PreviousAllocationSlotSelectionStrategy create(SlotSelectionStrategy fallbackSlotSelectionStrategy)