public final class DefaultParallelismPass extends AnnotatingPass
| Constructor and Description |
|---|
DefaultParallelismPass()
Default constructor with desired number of source parallelism 1, shuffle decreasing factor 2.
|
DefaultParallelismPass(int desiredSourceParallelism,
int shuffleDecreaseFactor)
Default constructor.
|
| Modifier and Type | Method and Description |
|---|---|
DAG<IRVertex,IREdge> |
apply(DAG<IRVertex,IREdge> dag) |
boolean |
equals(Object o) |
int |
hashCode() |
getExecutionPropertyToModify, getPrerequisiteExecutionPropertiespublic DefaultParallelismPass()
public DefaultParallelismPass(int desiredSourceParallelism,
int shuffleDecreaseFactor)
desiredSourceParallelism - the desired number of source parallelism.shuffleDecreaseFactor - the parallelism decrease factor for shuffle edge.Copyright © 2018. All rights reserved.