DecompressionStreamChainer (Nemo Project 0.4 API)

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

All Implemented Interfaces:: DecodeStreamChainer

public class DecompressionStreamChainer
extends java.lang.Object
implements DecodeStreamChainer

DecodeStreamChainer for applying compression.

Constructor Summary

Constructors
Constructor Description

DecompressionStreamChainer(CompressionProperty.Value compression)
Constructor.

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`java.io.InputStream`	`chainInput(java.io.InputStream in)`	Chain `InputStream` and returns chained `InputStream`.

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

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