Package | Description |
---|---|
org.apache.flink.runtime.executiongraph.failover.flip1 |
Modifier and Type | Interface and Description |
---|---|
interface |
FailoverResultPartition<V extends FailoverVertex<V,R>,R extends FailoverResultPartition<V,R>>
Represents a
IntermediateResultPartition produced by a FailoverVertex . |
interface |
FailoverTopology<V extends FailoverVertex<V,R>,R extends FailoverResultPartition<V,R>>
Represents a topology for failover.
|
interface |
FailoverVertex<V extends FailoverVertex<V,R>,R extends FailoverResultPartition<V,R>>
Represents an
ExecutionVertex . |
Modifier and Type | Method and Description |
---|---|
Set<? extends FailoverVertex<?,?>> |
FailoverRegion.getAllExecutionVertices()
Returns all vertices in this region.
|
Constructor and Description |
---|
FailoverRegion(Set<? extends FailoverVertex<?,?>> executionVertices)
Creates a new failover region containing a set of vertices.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.