VertexParallelismAndInputInfosDecider (Flink : Runtime 1.18.1-cp1 API)

All Known Implementing Classes:

DefaultVertexParallelismAndInputInfosDecider
```
public interface VertexParallelismAndInputInfosDecider
```
VertexParallelismAndInputInfosDecider is responsible for deciding the parallelism and JobVertexInputInfos of a job vertex, based on the information of the consumed blocking results.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`ParallelismAndInputInfos`	`decideParallelismAndInputInfosForVertex(JobVertexID jobVertexId, List<BlockingResultInfo> consumedResults, int vertexInitialParallelism, int vertexMaxParallelism)`	Decide the parallelism and `JobVertexInputInfo`s for this job vertex.

- Method Detail
  - decideParallelismAndInputInfosForVertex
```
ParallelismAndInputInfos decideParallelismAndInputInfosForVertex(JobVertexID jobVertexId,
                                                                 List<BlockingResultInfo> consumedResults,
                                                                 int vertexInitialParallelism,
                                                                 int vertexMaxParallelism)
```
    Decide the parallelism and JobVertexInputInfos for this job vertex.
    
    Parameters:
    
    jobVertexId - The job vertex id
    
    consumedResults - The information of consumed blocking results
    
    vertexInitialParallelism - The initial parallelism of the job vertex. If it's a positive number, it will be respected. If it's not set(equals to ExecutionConfig.PARALLELISM_DEFAULT), a parallelism will be automatically decided for the vertex.
    
    vertexMaxParallelism - The max parallelism of the job vertex.
    
    Returns:
    
    the parallelism and vertex input infos.