Modifier and Type | Method and Description |
---|---|
static SchedulerNGFactory |
SchedulerNGFactoryFactory.createSchedulerNGFactory(Configuration configuration,
RestartStrategyFactory restartStrategyFactory) |
Modifier and Type | Class and Description |
---|---|
static class |
FailureRateRestartStrategy.FailureRateRestartStrategyFactory |
static class |
FixedDelayRestartStrategy.FixedDelayRestartStrategyFactory |
class |
NoOrFixedIfCheckpointingEnabledRestartStrategyFactory
Default restart strategy that resolves either to
NoRestartStrategy or FixedDelayRestartStrategy
depending if checkpointing was enabled. |
static class |
NoRestartStrategy.NoRestartStrategyFactory |
static class |
ThrowingRestartStrategy.ThrowingRestartStrategyFactory
Factory for
ThrowingRestartStrategy . |
Modifier and Type | Method and Description |
---|---|
static RestartStrategyFactory |
RestartStrategyFactory.createRestartStrategyFactory(Configuration configuration)
Creates a
RestartStrategy instance from the given Configuration . |
Modifier and Type | Method and Description |
---|---|
static RestartStrategy |
RestartStrategyResolving.resolve(RestartStrategies.RestartStrategyConfiguration clientConfiguration,
RestartStrategyFactory serverStrategyFactory,
boolean isCheckpointingEnabled)
Resolves which
RestartStrategy to use. |
Modifier and Type | Method and Description |
---|---|
RestartStrategyFactory |
JobManagerSharedServices.getRestartStrategyFactory() |
Constructor and Description |
---|
JobManagerSharedServices(ScheduledExecutorService scheduledExecutorService,
LibraryCacheManager libraryCacheManager,
RestartStrategyFactory restartStrategyFactory,
BackPressureRequestCoordinator backPressureSampleCoordinator,
BackPressureStatsTracker backPressureStatsTracker,
BlobWriter blobWriter) |
Constructor and Description |
---|
LegacyScheduler(org.slf4j.Logger log,
JobGraph jobGraph,
BackPressureStatsTracker backPressureStatsTracker,
Executor ioExecutor,
Configuration jobMasterConfiguration,
SlotProvider slotProvider,
ScheduledExecutorService futureExecutor,
ClassLoader userCodeLoader,
CheckpointRecoveryFactory checkpointRecoveryFactory,
Time rpcTimeout,
RestartStrategyFactory restartStrategyFactory,
BlobWriter blobWriter,
JobManagerJobMetricGroup jobManagerJobMetricGroup,
Time slotRequestTimeout,
ShuffleMaster<?> shuffleMaster,
JobMasterPartitionTracker partitionTracker) |
LegacySchedulerFactory(RestartStrategyFactory restartStrategyFactory) |
SchedulerBase(org.slf4j.Logger log,
JobGraph jobGraph,
BackPressureStatsTracker backPressureStatsTracker,
Executor ioExecutor,
Configuration jobMasterConfiguration,
SlotProvider slotProvider,
ScheduledExecutorService futureExecutor,
ClassLoader userCodeLoader,
CheckpointRecoveryFactory checkpointRecoveryFactory,
Time rpcTimeout,
RestartStrategyFactory restartStrategyFactory,
BlobWriter blobWriter,
JobManagerJobMetricGroup jobManagerJobMetricGroup,
Time slotRequestTimeout,
ShuffleMaster<?> shuffleMaster,
JobMasterPartitionTracker partitionTracker,
ExecutionVertexVersioner executionVertexVersioner,
boolean legacyScheduling) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.