org.apache.flink.runtime.jobmaster.slotpool

Class LocationPreferenceSlotSelectionStrategy

java.lang.Object

org.apache.flink.runtime.jobmaster.slotpool.LocationPreferenceSlotSelectionStrategy

All Implemented Interfaces:

SlotSelectionStrategy

public abstract class LocationPreferenceSlotSelectionStrategy
extends Object
implements SlotSelectionStrategy

This class implements a SlotSelectionStrategy that is based on location preference hints.

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
protected abstract double	calculateCandidateScore(int localWeigh, int hostLocalWeigh, double taskExecutorUtilization)
static LocationPreferenceSlotSelectionStrategy	createDefault()
static LocationPreferenceSlotSelectionStrategy	createEvenlySpreadOut()
Optional<SlotSelectionStrategy.SlotInfoAndLocality>	selectBestSlotForProfile(Collection<SlotSelectionStrategy.SlotInfoAndResources> availableSlots, SlotProfile slotProfile) Selects the best SlotInfo w.r.t.
protected abstract Optional<SlotSelectionStrategy.SlotInfoAndLocality>	selectWithoutLocationPreference(Collection<SlotSelectionStrategy.SlotInfoAndResources> availableSlots, ResourceProfile resourceProfile)

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.

selectWithoutLocationPreference

@Nonnull
protected abstract Optional<SlotSelectionStrategy.SlotInfoAndLocality> selectWithoutLocationPreference(@Nonnull
                                                                                                                Collection<SlotSelectionStrategy.SlotInfoAndResources> availableSlots,
                                                                                                                @Nonnull
                                                                                                                ResourceProfile resourceProfile)

calculateCandidateScore

protected abstract double calculateCandidateScore(int localWeigh,
                                                  int hostLocalWeigh,
                                                  double taskExecutorUtilization)

createDefault

public static LocationPreferenceSlotSelectionStrategy createDefault()

createEvenlySpreadOut

public static LocationPreferenceSlotSelectionStrategy createEvenlySpreadOut()