public class DefaultScheduler extends LegacyScheduler
Constructor and Description |
---|
DefaultScheduler(org.slf4j.Logger log,
JobGraph jobGraph,
BackPressureStatsTracker backPressureStatsTracker,
Executor ioExecutor,
Configuration jobMasterConfiguration,
SlotProvider slotProvider,
ScheduledExecutorService futureExecutor,
ClassLoader userCodeLoader,
CheckpointRecoveryFactory checkpointRecoveryFactory,
Time rpcTimeout,
BlobWriter blobWriter,
JobManagerJobMetricGroup jobManagerJobMetricGroup,
Time slotRequestTimeout,
ShuffleMaster<?> shuffleMaster,
PartitionTracker partitionTracker) |
Modifier and Type | Method and Description |
---|---|
void |
startScheduling() |
acknowledgeCheckpoint, cancel, declineCheckpoint, getTerminationFuture, notifyKvStateRegistered, notifyKvStateUnregistered, registerJobStatusListener, requestJob, requestJobDetails, requestJobStatus, requestKvStateLocation, requestNextInputSplit, requestOperatorBackPressureStats, requestPartitionState, scheduleOrUpdateConsumers, setMainThreadExecutor, stopWithSavepoint, suspend, triggerSavepoint, updateAccumulators, updateTaskExecutionState
public DefaultScheduler(org.slf4j.Logger log, JobGraph jobGraph, BackPressureStatsTracker backPressureStatsTracker, Executor ioExecutor, Configuration jobMasterConfiguration, SlotProvider slotProvider, ScheduledExecutorService futureExecutor, ClassLoader userCodeLoader, CheckpointRecoveryFactory checkpointRecoveryFactory, Time rpcTimeout, BlobWriter blobWriter, JobManagerJobMetricGroup jobManagerJobMetricGroup, Time slotRequestTimeout, ShuffleMaster<?> shuffleMaster, PartitionTracker partitionTracker) throws Exception
Exception
public void startScheduling()
startScheduling
in interface SchedulerNG
startScheduling
in class LegacyScheduler
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.