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