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

Method Summary

Modifier and Type	Method and Description
static PreviousAllocationSlotSelectionStrategy	create()
static PreviousAllocationSlotSelectionStrategy	create(SlotSelectionStrategy fallbackSlotSelectionStrategy)
Optional<SlotSelectionStrategy.SlotInfoAndLocality>	selectBestSlotForProfile(FreeSlotInfoTracker freeSlotInfoTracker, SlotProfile slotProfile) 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.

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
                                                                                    FreeSlotInfoTracker freeSlotInfoTracker,
                                                                                    @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:

freeSlotInfoTracker - 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)