public interface SchedulingTopology extends Topology<ExecutionVertexID,IntermediateResultPartitionID,SchedulingExecutionVertex,SchedulingResultPartition,SchedulingPipelinedRegion>
SchedulingExecutionVertex
.Modifier and Type | Method and Description |
---|---|
SchedulingResultPartition |
getResultPartition(IntermediateResultPartitionID intermediateResultPartitionId)
Looks up the
SchedulingResultPartition for the given IntermediateResultPartitionID . |
SchedulingExecutionVertex |
getVertex(ExecutionVertexID executionVertexId)
Looks up the
SchedulingExecutionVertex for the given ExecutionVertexID . |
getAllPipelinedRegions, getPipelinedRegionOfVertex
containsCoLocationConstraints, getVertices
SchedulingExecutionVertex getVertex(ExecutionVertexID executionVertexId)
SchedulingExecutionVertex
for the given ExecutionVertexID
.executionVertexId
- identifying the respective scheduling vertexIllegalArgumentException
- If the vertex does not existSchedulingResultPartition getResultPartition(IntermediateResultPartitionID intermediateResultPartitionId)
SchedulingResultPartition
for the given IntermediateResultPartitionID
.intermediateResultPartitionId
- identifying the respective scheduling result partitionIllegalArgumentException
- If the partition does not existCopyright © 2014–2021 The Apache Software Foundation. All rights reserved.