Package | Description |
---|---|
org.apache.flink.runtime.jobmaster.slotpool | |
org.apache.flink.runtime.scheduler.adaptive |
Modifier and Type | Class and Description |
---|---|
class |
DefaultDeclarativeSlotPool
Default
DeclarativeSlotPool implementation. |
Modifier and Type | Method and Description |
---|---|
DeclarativeSlotPool |
DefaultDeclarativeSlotPoolFactory.create(JobID jobId,
java.util.function.Consumer<? super Collection<ResourceRequirement>> notifyNewResourceRequirements,
Time idleSlotTimeout,
Time rpcTimeout) |
DeclarativeSlotPool |
DeclarativeSlotPoolFactory.create(JobID jobId,
java.util.function.Consumer<? super Collection<ResourceRequirement>> notifyNewResourceRequirements,
Time idleSlotTimeout,
Time rpcTimeout) |
protected DeclarativeSlotPool |
DeclarativeSlotPoolService.getDeclarativeSlotPool() |
Modifier and Type | Method and Description |
---|---|
static SlotSharingSlotAllocator |
AdaptiveSchedulerFactory.createSlotSharingSlotAllocator(DeclarativeSlotPool declarativeSlotPool) |
Constructor and Description |
---|
AdaptiveScheduler(JobGraph jobGraph,
Configuration configuration,
DeclarativeSlotPool declarativeSlotPool,
SlotAllocator slotAllocator,
Executor ioExecutor,
ClassLoader userCodeClassLoader,
CheckpointRecoveryFactory checkpointRecoveryFactory,
java.time.Duration initialResourceAllocationTimeout,
java.time.Duration resourceStabilizationTimeout,
JobManagerJobMetricGroup jobManagerJobMetricGroup,
RestartBackoffTimeStrategy restartBackoffTimeStrategy,
long initializationTimestamp,
ComponentMainThreadExecutor mainThreadExecutor,
FatalErrorHandler fatalErrorHandler,
JobStatusListener jobStatusListener,
ExecutionGraphFactory executionGraphFactory) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.