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, getPrerequisiteExecutionProperties
public 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.