Uses of Interface
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPool

Packages that use DeclarativeSlotPool

Package	Description
org.apache.flink.runtime.jobmaster.slotpool
org.apache.flink.runtime.scheduler.adaptive

Uses of DeclarativeSlotPool in org.apache.flink.runtime.jobmaster.slotpool

Classes in org.apache.flink.runtime.jobmaster.slotpool that implement DeclarativeSlotPool

Modifier and Type	Class	Description
class	BlocklistDeclarativeSlotPool	A DeclarativeSlotPool implementation that supports blocklist.
class	DefaultDeclarativeSlotPool	Default DeclarativeSlotPool implementation.

Methods in org.apache.flink.runtime.jobmaster.slotpool that return DeclarativeSlotPool

Modifier and Type	Method	Description
DeclarativeSlotPool	BlocklistDeclarativeSlotPoolFactory.create(JobID jobId, Consumer<? super Collection<ResourceRequirement>> notifyNewResourceRequirements, Duration idleSlotTimeout, Duration rpcTimeout, Duration slotRequestMaxInterval, ComponentMainThreadExecutor componentMainThreadExecutor)
DeclarativeSlotPool	DeclarativeSlotPoolFactory.create(JobID jobId, Consumer<? super Collection<ResourceRequirement>> notifyNewResourceRequirements, Duration idleSlotTimeout, Duration rpcTimeout, Duration slotRequestMaxInterval, ComponentMainThreadExecutor componentMainThreadExecutor)
DeclarativeSlotPool	DefaultDeclarativeSlotPoolFactory.create(JobID jobId, Consumer<? super Collection<ResourceRequirement>> notifyNewResourceRequirements, Duration idleSlotTimeout, Duration rpcTimeout, Duration slotRequestMaxInterval, ComponentMainThreadExecutor componentMainThreadExecutor)
protected DeclarativeSlotPool	DeclarativeSlotPoolService.getDeclarativeSlotPool()

Uses of DeclarativeSlotPool in org.apache.flink.runtime.scheduler.adaptive

Methods in org.apache.flink.runtime.scheduler.adaptive with parameters of type DeclarativeSlotPool

Modifier and Type	Method	Description
static SlotSharingSlotAllocator	AdaptiveSchedulerFactory.createSlotSharingSlotAllocator(DeclarativeSlotPool declarativeSlotPool, boolean localRecoveryEnabled)

Constructors in org.apache.flink.runtime.scheduler.adaptive with parameters of type DeclarativeSlotPool

Constructor

Description

AdaptiveScheduler(AdaptiveScheduler.Settings settings, JobGraph jobGraph, JobResourceRequirements jobResourceRequirements, Configuration configuration, DeclarativeSlotPool declarativeSlotPool, SlotAllocator slotAllocator, Executor ioExecutor, ClassLoader userCodeClassLoader, CheckpointsCleaner checkpointsCleaner, CheckpointRecoveryFactory checkpointRecoveryFactory, JobManagerJobMetricGroup jobManagerJobMetricGroup, RestartBackoffTimeStrategy restartBackoffTimeStrategy, long initializationTimestamp, ComponentMainThreadExecutor mainThreadExecutor, FatalErrorHandler fatalErrorHandler, JobStatusListener jobStatusListener, Collection<FailureEnricher> failureEnrichers, ExecutionGraphFactory executionGraphFactory)