Interface MutableVertexParallelismStore
-
- All Superinterfaces:
VertexParallelismStore
- All Known Implementing Classes:
DefaultVertexParallelismStore
public interface MutableVertexParallelismStore extends VertexParallelismStore
Mutability extension to theVertexParallelismStore
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
setParallelismInfo(JobVertexID vertexId, VertexParallelismInformation info)
Sets the parallelism properties for the given vertex.-
Methods inherited from interface org.apache.flink.runtime.scheduler.VertexParallelismStore
getParallelismInfo
-
-
-
-
Method Detail
-
setParallelismInfo
void setParallelismInfo(JobVertexID vertexId, VertexParallelismInformation info)
Sets the parallelism properties for the given vertex.- Parameters:
vertexId
- vertex to set parallelism forinfo
- parallelism information for the given vertex
-
-