org.apache.flink.runtime.scheduler

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

Modifier and Type	Method and 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