Modifier and Type | Method and Description |
---|---|
SchedulingTopology |
DefaultExecutionGraph.getSchedulingTopology() |
SchedulingTopology |
ExecutionGraph.getSchedulingTopology() |
Modifier and Type | Method and Description |
---|---|
FailoverStrategy |
FailoverStrategy.Factory.create(SchedulingTopology topology,
ResultPartitionAvailabilityChecker resultPartitionAvailabilityChecker)
Instantiates the
FailoverStrategy . |
FailoverStrategy |
RestartPipelinedRegionFailoverStrategy.Factory.create(SchedulingTopology topology,
ResultPartitionAvailabilityChecker resultPartitionAvailabilityChecker) |
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 |
---|---|
PartitionGroupReleaseStrategy |
RegionPartitionGroupReleaseStrategy.Factory.createInstance(SchedulingTopology schedulingStrategy) |
PartitionGroupReleaseStrategy |
PartitionGroupReleaseStrategy.Factory.createInstance(SchedulingTopology schedulingStrategy) |
PartitionGroupReleaseStrategy |
NotReleasingPartitionGroupReleaseStrategy.Factory.createInstance(SchedulingTopology schedulingStrategy) |
void |
RegionPartitionGroupReleaseStrategy.notifySchedulingTopologyUpdated(SchedulingTopology schedulingTopology,
List<ExecutionVertexID> newExecutionVertices) |
Constructor and Description |
---|
RegionPartitionGroupReleaseStrategy(SchedulingTopology schedulingTopology) |
Modifier and Type | Method and Description |
---|---|
protected SchedulingTopology |
SchedulerBase.getSchedulingTopology() |
Modifier and Type | Method and Description |
---|---|
void |
SchedulingTopologyListener.notifySchedulingTopologyUpdated(SchedulingTopology schedulingTopology,
List<ExecutionVertexID> newExecutionVertices)
Notifies that the scheduling topology is just updated.
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultExecutionTopology
Adapter of
ExecutionGraph to SchedulingTopology . |
Modifier and Type | Method and Description |
---|---|
SchedulingStrategy |
PipelinedRegionSchedulingStrategy.Factory.createInstance(SchedulerOperations schedulerOperations,
SchedulingTopology schedulingTopology) |
SchedulingStrategy |
SchedulingStrategyFactory.createInstance(SchedulerOperations schedulerOperations,
SchedulingTopology schedulingTopology) |
SchedulingStrategy |
VertexwiseSchedulingStrategy.Factory.createInstance(SchedulerOperations schedulerOperations,
SchedulingTopology schedulingTopology) |
void |
VertexwiseSchedulingStrategy.notifySchedulingTopologyUpdated(SchedulingTopology schedulingTopology,
List<ExecutionVertexID> newExecutionVertices) |
Constructor and Description |
---|
PipelinedRegionSchedulingStrategy(SchedulerOperations schedulerOperations,
SchedulingTopology schedulingTopology) |
VertexwiseSchedulingStrategy(SchedulerOperations schedulerOperations,
SchedulingTopology schedulingTopology) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.