public class ExecutionGraphToSchedulingTopologyAdapter extends Object implements SchedulingTopology
ExecutionGraph
to SchedulingTopology
.Constructor and Description |
---|
ExecutionGraphToSchedulingTopologyAdapter(ExecutionGraph graph) |
Modifier and Type | Method and Description |
---|---|
Optional<SchedulingResultPartition> |
getResultPartition(IntermediateResultPartitionID intermediateResultPartitionId)
Looks up the
SchedulingResultPartition for the given IntermediateResultPartitionID . |
Optional<SchedulingExecutionVertex> |
getVertex(ExecutionVertexID executionVertexId)
Looks up the
SchedulingExecutionVertex for the given ExecutionVertexID . |
Iterable<SchedulingExecutionVertex> |
getVertices()
Returns an iterable over all
SchedulingExecutionVertex in topological
sorted order. |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getResultPartitionOrThrow, getVertexOrThrow
public ExecutionGraphToSchedulingTopologyAdapter(ExecutionGraph graph)
public Iterable<SchedulingExecutionVertex> getVertices()
SchedulingTopology
SchedulingExecutionVertex
in topological
sorted order.getVertices
in interface SchedulingTopology
public Optional<SchedulingExecutionVertex> getVertex(ExecutionVertexID executionVertexId)
SchedulingTopology
SchedulingExecutionVertex
for the given ExecutionVertexID
.getVertex
in interface SchedulingTopology
executionVertexId
- identifying the respective scheduling vertexpublic Optional<SchedulingResultPartition> getResultPartition(IntermediateResultPartitionID intermediateResultPartitionId)
SchedulingTopology
SchedulingResultPartition
for the given IntermediateResultPartitionID
.getResultPartition
in interface SchedulingTopology
intermediateResultPartitionId
- identifying the respective scheduling result partitionCopyright © 2014–2020 The Apache Software Foundation. All rights reserved.