Package | Description |
---|---|
org.apache.flink.runtime.executiongraph.failover.flip1 | |
org.apache.flink.runtime.scheduler |
Modifier and Type | Class and Description |
---|---|
static class |
RestartAllFailoverStrategy.Factory
The factory to instantiate
RestartAllFailoverStrategy . |
static class |
RestartPipelinedRegionFailoverStrategy.Factory
The factory to instantiate
RestartPipelinedRegionFailoverStrategy . |
Modifier and Type | Method and Description |
---|---|
static FailoverStrategy.Factory |
FailoverStrategyFactoryLoader.loadFailoverStrategyFactory(Configuration config)
Loads a
FailoverStrategy.Factory from the given configuration. |
Constructor and Description |
---|
DefaultScheduler(org.slf4j.Logger log,
JobGraph jobGraph,
Executor ioExecutor,
Configuration jobMasterConfiguration,
java.util.function.Consumer<ComponentMainThreadExecutor> startUpAction,
ScheduledExecutor delayExecutor,
ClassLoader userCodeLoader,
CheckpointsCleaner checkpointsCleaner,
CheckpointRecoveryFactory checkpointRecoveryFactory,
JobManagerJobMetricGroup jobManagerJobMetricGroup,
SchedulingStrategyFactory schedulingStrategyFactory,
FailoverStrategy.Factory failoverStrategyFactory,
RestartBackoffTimeStrategy restartBackoffTimeStrategy,
ExecutionVertexOperations executionVertexOperations,
ExecutionVertexVersioner executionVertexVersioner,
ExecutionSlotAllocatorFactory executionSlotAllocatorFactory,
long initializationTimestamp,
ComponentMainThreadExecutor mainThreadExecutor,
JobStatusListener jobStatusListener,
ExecutionGraphFactory executionGraphFactory,
ShuffleMaster<?> shuffleMaster,
Time rpcTimeout,
VertexParallelismStore vertexParallelismStore) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.