BlockCompressionFactory (Flink : 2.0-preview1 API)

All Known Implementing Classes:

AirCompressorFactory, Lz4BlockCompressionFactory
```
public interface BlockCompressionFactory
```
Each compression codec has a implementation of BlockCompressionFactory to create compressors and decompressors.

Method Summary

All Methods Static Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`static BlockCompressionFactory`	`createBlockCompressionFactory(NettyShuffleEnvironmentOptions.CompressionCodec compressionName)`	Creates `BlockCompressionFactory` according to the configuration.
`BlockCompressor`	`getCompressor()`
`BlockDecompressor`	`getDecompressor()`

Method Detail

getCompressor
```
BlockCompressor getCompressor()
```

getDecompressor
```
BlockDecompressor getDecompressor()
```

createBlockCompressionFactory
```
static BlockCompressionFactory createBlockCompressionFactory(NettyShuffleEnvironmentOptions.CompressionCodec compressionName)
```
Creates BlockCompressionFactory according to the configuration.

Parameters:

compressionName - supported compression codecs.