Class CompressionPass
- java.lang.Object
-
- org.apache.nemo.common.pass.Pass
-
- org.apache.nemo.compiler.optimizer.pass.compiletime.CompileTimePass
-
- org.apache.nemo.compiler.optimizer.pass.compiletime.annotating.AnnotatingPass
-
- org.apache.nemo.compiler.optimizer.pass.compiletime.annotating.CompressionPass
-
public final class CompressionPass extends AnnotatingPass
A pass for applying compression algorithm for data flowing between vertices.
-
-
Constructor Summary
Constructors Constructor Description CompressionPass()
Default constructor.CompressionPass(CompressionProperty.Value compression)
Constructor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description IRDAG
apply(IRDAG dag)
-
Methods inherited from class org.apache.nemo.compiler.optimizer.pass.compiletime.annotating.AnnotatingPass
getExecutionPropertiesToAnnotate, getPrerequisiteExecutionProperties
-
Methods inherited from class org.apache.nemo.common.pass.Pass
addCondition, getCondition
-
-
-
-
Constructor Detail
-
CompressionPass
public CompressionPass()
Default constructor. Uses LZ4 as default.
-
CompressionPass
public CompressionPass(CompressionProperty.Value compression)
Constructor.- Parameters:
compression
- Compression to apply on edges.
-
-