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(org.apache.flink.api.common.JobID jobId, java.util.function.Consumer<? super Collection<ResourceRequirement>> notifyNewResourceRequirements, org.apache.flink.api.common.time.Time idleSlotTimeout, org.apache.flink.api.common.time.Time rpcTimeout)
DeclarativeSlotPool	DeclarativeSlotPoolFactory.create(org.apache.flink.api.common.JobID jobId, java.util.function.Consumer<? super Collection<ResourceRequirement>> notifyNewResourceRequirements, org.apache.flink.api.common.time.Time idleSlotTimeout, org.apache.flink.api.common.time.Time rpcTimeout)
DeclarativeSlotPool	DefaultDeclarativeSlotPoolFactory.create(org.apache.flink.api.common.JobID jobId, java.util.function.Consumer<? super Collection<ResourceRequirement>> notifyNewResourceRequirements, org.apache.flink.api.common.time.Time idleSlotTimeout, org.apache.flink.api.common.time.Time rpcTimeout)
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)

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

Constructor

Description

AdaptiveScheduler(JobGraph jobGraph, JobResourceRequirements jobResourceRequirements, org.apache.flink.configuration.Configuration configuration, DeclarativeSlotPool declarativeSlotPool, SlotAllocator slotAllocator, Executor ioExecutor, ClassLoader userCodeClassLoader, CheckpointsCleaner checkpointsCleaner, CheckpointRecoveryFactory checkpointRecoveryFactory, java.time.Duration initialResourceAllocationTimeout, java.time.Duration resourceStabilizationTimeout, JobManagerJobMetricGroup jobManagerJobMetricGroup, RestartBackoffTimeStrategy restartBackoffTimeStrategy, long initializationTimestamp, org.apache.flink.runtime.concurrent.ComponentMainThreadExecutor mainThreadExecutor, org.apache.flink.runtime.rpc.FatalErrorHandler fatalErrorHandler, JobStatusListener jobStatusListener, Collection<org.apache.flink.core.failure.FailureEnricher> failureEnrichers, ExecutionGraphFactory executionGraphFactory)