Uses of Package
org.apache.flink.runtime.io.compression

Packages that use org.apache.flink.runtime.io.compression

Package	Description
org.apache.flink.runtime.io.compression
org.apache.flink.table.runtime.hashtable
org.apache.flink.table.runtime.io
org.apache.flink.table.runtime.operators.sort
org.apache.flink.table.runtime.util

Classes in org.apache.flink.runtime.io.compression used by org.apache.flink.runtime.io.compression

Class and Description
BlockCompressionFactory Each compression codec has a implementation of BlockCompressionFactory to create compressors and decompressors.
BlockCompressionFactory.CompressionFactoryName Name of BlockCompressionFactory.
BlockCompressor A compressor which compresses a whole byte array each time.
BlockDecompressor A decompressor which decompresses a block each time.
DataCorruptionException A DataCorruptionException is thrown when the decompressed data is corrupted and cannot be decompressed.
InsufficientBufferException An InsufficientBufferException is thrown when there is no enough buffer to serialize or deserialize a buffer to another buffer.

Classes in org.apache.flink.runtime.io.compression used by org.apache.flink.table.runtime.hashtable

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

Classes in org.apache.flink.runtime.io.compression used by org.apache.flink.table.runtime.io

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

Classes in org.apache.flink.runtime.io.compression used by org.apache.flink.table.runtime.operators.sort

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

Classes in org.apache.flink.runtime.io.compression used by org.apache.flink.table.runtime.util

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