public interface VertexParallelismDecider
VertexParallelismDecider
is responsible for determining the parallelism of a job vertex,
based on the size of the consumed blocking results.Modifier and Type | Method and Description |
---|---|
int |
decideParallelismForVertex(JobVertexID jobVertexId,
List<BlockingResultInfo> consumedResults,
int vertexMaxParallelism)
Computing the parallelism.
|
int decideParallelismForVertex(JobVertexID jobVertexId, List<BlockingResultInfo> consumedResults, int vertexMaxParallelism)
jobVertexId
- The job vertex id.consumedResults
- The information of consumed blocking results.vertexMaxParallelism
- The max parallelism of the job vertex.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.