public interface SlotPoolServiceSchedulerFactory
SlotPoolService
and SchedulerNG
.Modifier and Type | Method and Description |
---|---|
SchedulerNG |
createScheduler(org.slf4j.Logger log,
JobGraph jobGraph,
Executor ioExecutor,
Configuration configuration,
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)
Creates a
SchedulerNG . |
SlotPoolService |
createSlotPoolService(JobID jid,
DeclarativeSlotPoolFactory declarativeSlotPoolFactory)
Creates a
SlotPoolService . |
JobManagerOptions.SchedulerType |
getSchedulerType()
Returns the scheduler type this factory is creating.
|
SlotPoolService createSlotPoolService(JobID jid, DeclarativeSlotPoolFactory declarativeSlotPoolFactory)
SlotPoolService
.jid
- jid is the JobID to pass to the servicedeclarativeSlotPoolFactory
- the declarative slot pool factoryJobManagerOptions.SchedulerType getSchedulerType()
SchedulerNG createScheduler(org.slf4j.Logger log, JobGraph jobGraph, Executor ioExecutor, Configuration configuration, 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
SchedulerNG
.Exception
- if the scheduler creation failsCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.