SnappyStreamCompressionDecorator (Flink : 2.0-SNAPSHOT API)

java.lang.Object
- org.apache.flink.runtime.state.StreamCompressionDecorator
- - org.apache.flink.runtime.state.SnappyStreamCompressionDecorator

All Implemented Interfaces:

Serializable
```
@Internal
public class SnappyStreamCompressionDecorator
extends StreamCompressionDecorator
```
This implementation decorates the stream with snappy compression.

See Also:

Serialized Form

Field Summary

Fields
Modifier and Type Field Description

static StreamCompressionDecorator INSTANCE

Constructor Summary

Constructors
Constructor Description

SnappyStreamCompressionDecorator()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`protected InputStream`	`decorateWithCompression(NonClosingInputStreamDecorator stream)`
`protected OutputStream`	`decorateWithCompression(NonClosingOutputStreamDecorator stream)`

Methods inherited from class org.apache.flink.runtime.state.StreamCompressionDecorator
decorateWithCompression, decorateWithCompression

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

- Field Detail
  - INSTANCE
```
public static final StreamCompressionDecorator INSTANCE
```
- Constructor Detail
  - SnappyStreamCompressionDecorator
```
public SnappyStreamCompressionDecorator()
```
- Method Detail
  - decorateWithCompression
```
protected OutputStream decorateWithCompression(NonClosingOutputStreamDecorator stream)
                                        throws IOException
```
    Specified by:
    
    decorateWithCompression in class StreamCompressionDecorator
    
    Parameters:
    
    stream - the stream to decorate
    
    Returns:
    
    an output stream that is decorated by the compression scheme.
    
    Throws:
    
    IOException
  - decorateWithCompression
```
protected InputStream decorateWithCompression(NonClosingInputStreamDecorator stream)
                                       throws IOException
```
    Specified by:
    
    decorateWithCompression in class StreamCompressionDecorator
    
    Parameters:
    
    stream - the stream to decorate.
    
    Returns:
    
    an input stream that is decorated by the compression scheme.
    
    Throws:
    
    IOException