Modifier and Type | Class and Description |
---|---|
class |
DefaultFailoverTopology
Default implementation of
FailoverTopology which is an adaptor of ExecutionGraph . |
Modifier and Type | Method and Description |
---|---|
static Set<Set<FailoverVertex>> |
PipelinedRegionComputeUtil.computePipelinedRegions(FailoverTopology topology) |
FailoverStrategy |
FailoverStrategy.Factory.create(FailoverTopology topology)
Instantiates the
FailoverStrategy . |
Constructor and Description |
---|
RestartPipelinedRegionStrategy(FailoverTopology topology)
Creates a new failover strategy to restart pipelined regions that works on the given topology.
|
RestartPipelinedRegionStrategy(FailoverTopology 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 |
PartitionReleaseStrategy.Factory.createInstance(SchedulingTopology schedulingStrategy,
FailoverTopology failoverTopology) |
PartitionReleaseStrategy |
NotReleasingPartitionReleaseStrategy.Factory.createInstance(SchedulingTopology schedulingStrategy,
FailoverTopology failoverTopology) |
PartitionReleaseStrategy |
RegionPartitionReleaseStrategy.Factory.createInstance(SchedulingTopology schedulingStrategy,
FailoverTopology failoverTopology) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.