org.apache.flink.runtime.scheduler.adaptive

Class AdaptiveSchedulerFactory

java.lang.Object

org.apache.flink.runtime.scheduler.adaptive.AdaptiveSchedulerFactory

All Implemented Interfaces:

SchedulerNGFactory

public class AdaptiveSchedulerFactory
extends Object
implements SchedulerNGFactory

Factory for the adaptive scheduler.

Constructor Summary

Constructors

Constructor and Description
AdaptiveSchedulerFactory(java.time.Duration initialResourceAllocationTimeout, java.time.Duration resourceStabilizationTimeout)

Method Summary

Modifier and Type	Method and Description
SchedulerNG	createInstance(org.slf4j.Logger log, JobGraph jobGraph, Executor ioExecutor, Configuration jobMasterConfiguration, SlotPoolService slotPoolService, ScheduledExecutorService futureExecutor, ClassLoader userCodeLoader, CheckpointRecoveryFactory checkpointRecoveryFactory, Time rpcTimeout, BlobWriter blobWriter, JobManagerJobMetricGroup jobManagerJobMetricGroup, Time slotRequestTimeout, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker, ExecutionDeploymentTracker executionDeploymentTracker, long initializationTimestamp, ComponentMainThreadExecutor mainThreadExecutor, FatalErrorHandler fatalErrorHandler, JobStatusListener jobStatusListener, BlocklistOperations blocklistOperations)
static SlotSharingSlotAllocator	createSlotSharingSlotAllocator(DeclarativeSlotPool declarativeSlotPool)
JobManagerOptions.SchedulerType	getSchedulerType()

Methods inherited from class java.lang.Object

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

Constructor Detail

AdaptiveSchedulerFactory

public AdaptiveSchedulerFactory(java.time.Duration initialResourceAllocationTimeout,
                                java.time.Duration resourceStabilizationTimeout)

Method Detail

createInstance

public SchedulerNG createInstance(org.slf4j.Logger log,
                                  JobGraph jobGraph,
                                  Executor ioExecutor,
                                  Configuration jobMasterConfiguration,
                                  SlotPoolService slotPoolService,
                                  ScheduledExecutorService futureExecutor,
                                  ClassLoader userCodeLoader,
                                  CheckpointRecoveryFactory checkpointRecoveryFactory,
                                  Time rpcTimeout,
                                  BlobWriter blobWriter,
                                  JobManagerJobMetricGroup jobManagerJobMetricGroup,
                                  Time slotRequestTimeout,
                                  ShuffleMaster<?> shuffleMaster,
                                  JobMasterPartitionTracker partitionTracker,
                                  ExecutionDeploymentTracker executionDeploymentTracker,
                                  long initializationTimestamp,
                                  ComponentMainThreadExecutor mainThreadExecutor,
                                  FatalErrorHandler fatalErrorHandler,
                                  JobStatusListener jobStatusListener,
                                  BlocklistOperations blocklistOperations)
                           throws Exception

Specified by:

createInstance in interface SchedulerNGFactory

Throws:

Exception

getSchedulerType

public JobManagerOptions.SchedulerType getSchedulerType()

Specified by:

getSchedulerType in interface SchedulerNGFactory

createSlotSharingSlotAllocator

public static SlotSharingSlotAllocator createSlotSharingSlotAllocator(DeclarativeSlotPool declarativeSlotPool)