org.apache.flink.runtime.state

Class UncompressedStreamCompressionDecorator

java.lang.Object

org.apache.flink.runtime.state.StreamCompressionDecorator

org.apache.flink.runtime.state.UncompressedStreamCompressionDecorator

All Implemented Interfaces:

Serializable

@Internal
public class UncompressedStreamCompressionDecorator
extends StreamCompressionDecorator

This implementation does not decorate the stream with any compression.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static StreamCompressionDecorator	INSTANCE

Constructor Summary

Constructors

Constructor and Description
UncompressedStreamCompressionDecorator()

Method Summary

Modifier and Type	Method and Description
protected InputStream	decorateWithCompression(NonClosingInputStreamDecorator stream)
protected OutputStream	decorateWithCompression(NonClosingOutpusStreamDecorator 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

UncompressedStreamCompressionDecorator

public UncompressedStreamCompressionDecorator()

Method Detail

decorateWithCompression

protected OutputStream decorateWithCompression(NonClosingOutpusStreamDecorator 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