public class DefaultVertexParallelismDecider extends Object implements VertexParallelismDecider
VertexParallelismDecider
. Currently, in order to make the
number of subpartitions evenly consumed by downstream tasks, we will normalize the decided
parallelism to a power of 2.Modifier and Type | Method and Description |
---|---|
int |
decideParallelismForVertex(JobVertexID jobVertexId,
List<BlockingResultInfo> consumedResults,
int vertexMaxParallelism)
Computing the parallelism.
|
public int decideParallelismForVertex(JobVertexID jobVertexId, List<BlockingResultInfo> consumedResults, int vertexMaxParallelism)
VertexParallelismDecider
decideParallelismForVertex
in interface VertexParallelismDecider
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.