org.apache.flink.runtime.executiongraph

Class SlotProviderStrategy

java.lang.Object

org.apache.flink.runtime.executiongraph.SlotProviderStrategy

public abstract class SlotProviderStrategy
extends Object

Strategy to switch between different SlotProvider allocation strategies.

Field Summary

Fields

Modifier and Type	Field and Description
protected SlotProvider	slotProvider

Method Summary

Modifier and Type	Method and Description
abstract CompletableFuture<LogicalSlot>	allocateSlot(SlotRequestId slotRequestId, ScheduledUnit scheduledUnit, SlotProfile slotProfile) Allocating slot with specific requirement.
void	cancelSlotRequest(SlotRequestId slotRequestId, SlotSharingGroupId slotSharingGroupId, Throwable cause) Cancels the slot request with the given SlotRequestId and SlotSharingGroupId.
static SlotProviderStrategy	from(ScheduleMode scheduleMode, SlotProvider slotProvider, Time allocationTimeout)

Methods inherited from class java.lang.Object

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

Field Detail

slotProvider

protected final SlotProvider slotProvider

Method Detail

allocateSlot

public abstract CompletableFuture<LogicalSlot> allocateSlot(SlotRequestId slotRequestId,
                                                            ScheduledUnit scheduledUnit,
                                                            SlotProfile slotProfile)

Allocating slot with specific requirement.

Parameters:

slotRequestId - identifying the slot request

scheduledUnit - The task to allocate the slot for

slotProfile - profile of the requested slot

Returns:

The future of the allocation

cancelSlotRequest

public void cancelSlotRequest(SlotRequestId slotRequestId,
                              @Nullable
                              SlotSharingGroupId slotSharingGroupId,
                              Throwable cause)

Cancels the slot request with the given SlotRequestId and SlotSharingGroupId.

Parameters:

slotRequestId - identifying the slot request to cancel

slotSharingGroupId - identifying the slot request to cancel

cause - of the cancellation

from

public static SlotProviderStrategy from(ScheduleMode scheduleMode,
                                        SlotProvider slotProvider,
                                        Time allocationTimeout)