CompressionStreamChainer (Nemo Project 0.4 API)

java.lang.Object
- org.apache.nemo.runtime.executor.data.streamchainer.CompressionStreamChainer

All Implemented Interfaces:: EncodeStreamChainer

public class CompressionStreamChainer
extends java.lang.Object
implements EncodeStreamChainer

EncodeStreamChainer for applying compression.

Constructor Summary

Constructors
Constructor Description

CompressionStreamChainer(CompressionProperty.Value compression)
Constructor.

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`java.io.OutputStream`	`chainOutput(java.io.OutputStream out)`	Chain `OutputStream` and returns chained `OutputStream`.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - CompressionStreamChainer
```
public CompressionStreamChainer(CompressionProperty.Value compression)
```
    Constructor.
    
    Parameters:
    
    compression - compression method.
- Method Detail
  - chainOutput
```
public final java.io.OutputStream chainOutput(java.io.OutputStream out)
                                       throws java.io.IOException
```
    Description copied from interface: EncodeStreamChainer
    
    Chain OutputStream and returns chained OutputStream.
    
    Specified by:
    
    chainOutput in interface EncodeStreamChainer
    
    Parameters:
    
    out - the stream which will be chained.
    
    Returns:
    
    chained OutputStream.
    
    Throws:
    
    java.io.IOException - if fail to chain the stream.