public interface SlotPoolServiceSchedulerFactory
SlotPoolService
and SchedulerNG
.Modifier and Type | Method and Description |
---|---|
SchedulerNG |
createScheduler(org.slf4j.Logger log,
JobGraph jobGraph,
ScheduledExecutorService scheduledExecutorService,
Configuration configuration,
SlotPoolService slotPoolService,
ScheduledExecutorService executorService,
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)
Creates a
SchedulerNG . |
SlotPoolService |
createSlotPoolService(JobID jid)
Creates a
SlotPoolService . |
JobManagerOptions.SchedulerType |
getSchedulerType()
Returns the scheduler type this factory is creating.
|
SlotPoolService createSlotPoolService(JobID jid)
SlotPoolService
.jid
- jid is the JobID to pass to the serviceJobManagerOptions.SchedulerType getSchedulerType()
SchedulerNG createScheduler(org.slf4j.Logger log, JobGraph jobGraph, ScheduledExecutorService scheduledExecutorService, Configuration configuration, SlotPoolService slotPoolService, ScheduledExecutorService executorService, 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) throws Exception
SchedulerNG
.Exception
- if the scheduler creation failsCopyright © 2014–2022 The Apache Software Foundation. All rights reserved.