org.apache.flink.runtime.io.compression

Interface BlockCompressionFactory

All Known Implementing Classes:

AirCompressorFactory, Lz4BlockCompressionFactory

public interface BlockCompressionFactory

Each compression codec has a implementation of BlockCompressionFactory to create compressors and decompressors.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	BlockCompressionFactory.CompressionFactoryName Name of BlockCompressionFactory.

Method Summary

Modifier and Type	Method and Description
static BlockCompressionFactory	createBlockCompressionFactory(String compressionFactoryName) Creates BlockCompressionFactory according to the configuration.
BlockCompressor	getCompressor()
BlockDecompressor	getDecompressor()

Method Detail

getCompressor

BlockCompressor getCompressor()

getDecompressor

BlockDecompressor getDecompressor()

createBlockCompressionFactory

static BlockCompressionFactory createBlockCompressionFactory(String compressionFactoryName)

Creates BlockCompressionFactory according to the configuration.

Parameters:

compressionFactoryName - supported compression codecs or user-defined class name inherited from BlockCompressionFactory.