public final class DefaultSlotPoolServiceSchedulerFactory extends Object implements SlotPoolServiceSchedulerFactory
SlotPoolServiceSchedulerFactory
implementation.public SlotPoolService createSlotPoolService(JobID jid)
SlotPoolServiceSchedulerFactory
SlotPoolService
.createSlotPoolService
in interface SlotPoolServiceSchedulerFactory
jid
- jid is the JobID to pass to the servicepublic JobManagerOptions.SchedulerType getSchedulerType()
SlotPoolServiceSchedulerFactory
getSchedulerType
in interface SlotPoolServiceSchedulerFactory
public 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
SlotPoolServiceSchedulerFactory
SchedulerNG
.createScheduler
in interface SlotPoolServiceSchedulerFactory
Exception
- if the scheduler creation failspublic static DefaultSlotPoolServiceSchedulerFactory create(SlotPoolServiceFactory slotPoolServiceFactory, SchedulerNGFactory schedulerNGFactory)
public static DefaultSlotPoolServiceSchedulerFactory fromConfiguration(Configuration configuration, JobType jobType)
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.