Modifier and Type | Method and Description |
---|---|
SchedulingTopology |
ExecutionGraph.getSchedulingTopology() |
Modifier and Type | Method and Description |
---|---|
FailoverStrategy |
RestartPipelinedRegionFailoverStrategy.Factory.create(SchedulingTopology topology,
ResultPartitionAvailabilityChecker resultPartitionAvailabilityChecker) |
FailoverStrategy |
FailoverStrategy.Factory.create(SchedulingTopology topology,
ResultPartitionAvailabilityChecker resultPartitionAvailabilityChecker)
Instantiates the
FailoverStrategy . |
FailoverStrategy |
RestartAllFailoverStrategy.Factory.create(SchedulingTopology topology,
ResultPartitionAvailabilityChecker resultPartitionAvailabilityChecker) |
Constructor and Description |
---|
ExecutionFailureHandler(SchedulingTopology schedulingTopology,
FailoverStrategy failoverStrategy,
RestartBackoffTimeStrategy restartBackoffTimeStrategy)
Creates the handler to deal with task failures.
|
RestartAllFailoverStrategy(SchedulingTopology topology) |
RestartPipelinedRegionFailoverStrategy(SchedulingTopology topology)
Creates a new failover strategy to restart pipelined regions that works on the given
topology.
|
RestartPipelinedRegionFailoverStrategy(SchedulingTopology topology,
ResultPartitionAvailabilityChecker resultPartitionAvailabilityChecker)
Creates a new failover strategy to restart pipelined regions that works on the given
topology.
|
Modifier and Type | Method and Description |
---|---|
PartitionReleaseStrategy |
RegionPartitionReleaseStrategy.Factory.createInstance(SchedulingTopology schedulingStrategy) |
PartitionReleaseStrategy |
PartitionReleaseStrategy.Factory.createInstance(SchedulingTopology schedulingStrategy) |
PartitionReleaseStrategy |
NotReleasingPartitionReleaseStrategy.Factory.createInstance(SchedulingTopology schedulingStrategy) |
Constructor and Description |
---|
RegionPartitionReleaseStrategy(SchedulingTopology schedulingTopology) |
Modifier and Type | Method and Description |
---|---|
protected SchedulingTopology |
SchedulerBase.getSchedulingTopology() |
Modifier and Type | Class and Description |
---|---|
class |
DefaultExecutionTopology
Adapter of
ExecutionGraph to SchedulingTopology . |
Modifier and Type | Method and Description |
---|---|
SchedulingStrategy |
LazyFromSourcesSchedulingStrategy.Factory.createInstance(SchedulerOperations schedulerOperations,
SchedulingTopology schedulingTopology) |
SchedulingStrategy |
PipelinedRegionSchedulingStrategy.Factory.createInstance(SchedulerOperations schedulerOperations,
SchedulingTopology schedulingTopology) |
SchedulingStrategy |
SchedulingStrategyFactory.createInstance(SchedulerOperations schedulerOperations,
SchedulingTopology schedulingTopology) |
SchedulingStrategy |
EagerSchedulingStrategy.Factory.createInstance(SchedulerOperations schedulerOperations,
SchedulingTopology schedulingTopology) |
Constructor and Description |
---|
EagerSchedulingStrategy(SchedulerOperations schedulerOperations,
SchedulingTopology schedulingTopology) |
LazyFromSourcesSchedulingStrategy(SchedulerOperations schedulerOperations,
SchedulingTopology schedulingTopology) |
PipelinedRegionSchedulingStrategy(SchedulerOperations schedulerOperations,
SchedulingTopology schedulingTopology) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.