Package | Description |
---|---|
org.apache.flink.runtime.scheduler.adaptivebatch |
Modifier and Type | Method and Description |
---|---|
static BlockingResultInfo |
BlockingResultInfo.createFromIntermediateResult(IntermediateResult intermediateResult) |
Modifier and Type | Method and Description |
---|---|
int |
VertexParallelismDecider.decideParallelismForVertex(List<BlockingResultInfo> consumedResults)
Computing the parallelism.
|
int |
DefaultVertexParallelismDecider.decideParallelismForVertex(List<BlockingResultInfo> consumedResults) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.