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(List<BlockingResultInfo> consumedResults)
Computing the parallelism.
|
public int decideParallelismForVertex(List<BlockingResultInfo> consumedResults)
VertexParallelismDecider
decideParallelismForVertex
in interface VertexParallelismDecider
consumedResults
- The information of consumed blocking results.Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.