Interface VertexParallelismStore
-
- All Known Subinterfaces:
MutableVertexParallelismStore
- All Known Implementing Classes:
DefaultVertexParallelismStore
public interface VertexParallelismStore
Contains the max parallelism per vertex, along with metadata about how these maxes were calculated.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description VertexParallelismInformation
getParallelismInfo(JobVertexID vertexId)
Returns a given vertex's parallelism information.
-
-
-
Method Detail
-
getParallelismInfo
VertexParallelismInformation getParallelismInfo(JobVertexID vertexId)
Returns a given vertex's parallelism information.- Parameters:
vertexId
- vertex for which the parallelism information should be returned- Returns:
- a parallelism information for the given vertex
- Throws:
IllegalStateException
- if there is no parallelism information for the given vertex
-
-