public interface SchedulingTopology
SchedulingExecutionVertex
.Modifier and Type | Method and Description |
---|---|
Optional<SchedulingResultPartition> |
getResultPartition(IntermediateResultPartitionID intermediateResultPartitionId)
Looks up the
SchedulingResultPartition for the given IntermediateResultPartitionID . |
default SchedulingResultPartition |
getResultPartitionOrThrow(IntermediateResultPartitionID intermediateResultPartitionId)
Looks up the
SchedulingResultPartition for the given IntermediateResultPartitionID . |
Optional<SchedulingExecutionVertex> |
getVertex(ExecutionVertexID executionVertexId)
Looks up the
SchedulingExecutionVertex for the given ExecutionVertexID . |
default SchedulingExecutionVertex |
getVertexOrThrow(ExecutionVertexID executionVertexId)
Looks up the
SchedulingExecutionVertex for the given ExecutionVertexID . |
Iterable<SchedulingExecutionVertex> |
getVertices()
Returns an iterable over all
SchedulingExecutionVertex in topological
sorted order. |
Iterable<SchedulingExecutionVertex> getVertices()
SchedulingExecutionVertex
in topological
sorted order.Optional<SchedulingExecutionVertex> getVertex(ExecutionVertexID executionVertexId)
SchedulingExecutionVertex
for the given ExecutionVertexID
.executionVertexId
- identifying the respective scheduling vertexdefault SchedulingExecutionVertex getVertexOrThrow(ExecutionVertexID executionVertexId)
SchedulingExecutionVertex
for the given ExecutionVertexID
.executionVertexId
- identifying the respective scheduling vertexIllegalArgumentException
- If the vertex does not existOptional<SchedulingResultPartition> getResultPartition(IntermediateResultPartitionID intermediateResultPartitionId)
SchedulingResultPartition
for the given IntermediateResultPartitionID
.intermediateResultPartitionId
- identifying the respective scheduling result partitiondefault SchedulingResultPartition getResultPartitionOrThrow(IntermediateResultPartitionID intermediateResultPartitionId)
SchedulingResultPartition
for the given IntermediateResultPartitionID
.intermediateResultPartitionId
- identifying the respective scheduling result partitionIllegalArgumentException
- If the partition does not existCopyright © 2014–2020 The Apache Software Foundation. All rights reserved.