Package | Description |
---|---|
org.apache.flink.runtime.executiongraph.failover.adapter | |
org.apache.flink.runtime.executiongraph.failover.flip1 |
Modifier and Type | Method and Description |
---|---|
Iterable<? extends FailoverVertex> |
DefaultFailoverTopology.getFailoverVertices() |
Modifier and Type | Method and Description |
---|---|
FailoverVertex |
FailoverEdge.getSourceVertex()
Returns the source vertex, i.e., the producer of the result partition.
|
FailoverVertex |
FailoverEdge.getTargetVertex()
Returns the target vertex, i.e., the consumer of the result partition.
|
Modifier and Type | Method and Description |
---|---|
static Set<Set<FailoverVertex>> |
PipelinedRegionComputeUtil.computePipelinedRegions(FailoverTopology topology) |
Set<FailoverVertex> |
FailoverRegion.getAllExecutionVertices()
Returns all vertices in this region.
|
Iterable<? extends FailoverVertex> |
FailoverTopology.getFailoverVertices()
Returns an iterable over all vertices, topologically sorted.
|
Modifier and Type | Method and Description |
---|---|
static Set<PipelinedRegion> |
PipelinedRegionComputeUtil.toPipelinedRegionsSet(Set<Set<FailoverVertex>> distinctRegions) |
Constructor and Description |
---|
FailoverRegion(Set<FailoverVertex> executionVertices)
Creates a new failover region containing a set of vertices.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.