public class LegacySchedulerFactory extends Object implements SchedulerNGFactory
LegacyScheduler
.Constructor and Description |
---|
LegacySchedulerFactory(RestartStrategyFactory restartStrategyFactory) |
Modifier and Type | Method and Description |
---|---|
SchedulerNG |
createInstance(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,
JobMasterPartitionTracker partitionTracker) |
public LegacySchedulerFactory(RestartStrategyFactory restartStrategyFactory)
public SchedulerNG createInstance(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, JobMasterPartitionTracker partitionTracker) throws Exception
createInstance
in interface SchedulerNGFactory
Exception
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.