public class DefaultExecutionTopology extends Object implements SchedulingTopology<org.apache.flink.runtime.scheduler.adapter.DefaultExecutionVertex,org.apache.flink.runtime.scheduler.adapter.DefaultResultPartition>, FailoverTopology<org.apache.flink.runtime.scheduler.adapter.DefaultExecutionVertex,org.apache.flink.runtime.scheduler.adapter.DefaultResultPartition>
Constructor and Description |
---|
DefaultExecutionTopology(ExecutionGraph graph) |
Modifier and Type | Method and Description |
---|---|
boolean |
containsCoLocationConstraints()
Returns whether the topology contains co-location constraints.
|
Optional<org.apache.flink.runtime.scheduler.adapter.DefaultResultPartition> |
getResultPartition(IntermediateResultPartitionID intermediateResultPartitionId)
Looks up the
SchedulingResultPartition for the given IntermediateResultPartitionID . |
Optional<org.apache.flink.runtime.scheduler.adapter.DefaultExecutionVertex> |
getVertex(ExecutionVertexID executionVertexId)
Looks up the
SchedulingExecutionVertex for the given ExecutionVertexID . |
Iterable<org.apache.flink.runtime.scheduler.adapter.DefaultExecutionVertex> |
getVertices()
Returns an iterable over all vertices, topologically sorted.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getResultPartitionOrThrow, getVertexOrThrow
public DefaultExecutionTopology(ExecutionGraph graph)
public Iterable<org.apache.flink.runtime.scheduler.adapter.DefaultExecutionVertex> getVertices()
Topology
getVertices
in interface Topology<ExecutionVertexID,IntermediateResultPartitionID,org.apache.flink.runtime.scheduler.adapter.DefaultExecutionVertex,org.apache.flink.runtime.scheduler.adapter.DefaultResultPartition>
public boolean containsCoLocationConstraints()
Topology
containsCoLocationConstraints
in interface Topology<ExecutionVertexID,IntermediateResultPartitionID,org.apache.flink.runtime.scheduler.adapter.DefaultExecutionVertex,org.apache.flink.runtime.scheduler.adapter.DefaultResultPartition>
public Optional<org.apache.flink.runtime.scheduler.adapter.DefaultExecutionVertex> getVertex(ExecutionVertexID executionVertexId)
SchedulingTopology
SchedulingExecutionVertex
for the given ExecutionVertexID
.getVertex
in interface SchedulingTopology<org.apache.flink.runtime.scheduler.adapter.DefaultExecutionVertex,org.apache.flink.runtime.scheduler.adapter.DefaultResultPartition>
executionVertexId
- identifying the respective scheduling vertexpublic Optional<org.apache.flink.runtime.scheduler.adapter.DefaultResultPartition> getResultPartition(IntermediateResultPartitionID intermediateResultPartitionId)
SchedulingTopology
SchedulingResultPartition
for the given IntermediateResultPartitionID
.getResultPartition
in interface SchedulingTopology<org.apache.flink.runtime.scheduler.adapter.DefaultExecutionVertex,org.apache.flink.runtime.scheduler.adapter.DefaultResultPartition>
intermediateResultPartitionId
- identifying the respective scheduling result partitionCopyright © 2014–2020 The Apache Software Foundation. All rights reserved.