Uses of Interface
org.apache.flink.runtime.io.compression.BlockCompressionFactory

Packages that use BlockCompressionFactory

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

Uses of BlockCompressionFactory in org.apache.flink.runtime.io.compression

Classes in org.apache.flink.runtime.io.compression that implement BlockCompressionFactory

Modifier and Type	Class and Description
class	Lz4BlockCompressionFactory Implementation of BlockCompressionFactory for Lz4 codec.

Methods in org.apache.flink.runtime.io.compression that return BlockCompressionFactory

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

Uses of BlockCompressionFactory in org.apache.flink.table.runtime.hashtable

Fields in org.apache.flink.table.runtime.hashtable declared as BlockCompressionFactory

Modifier and Type	Field and Description
protected BlockCompressionFactory	BaseHybridHashTable.compressionCodecFactory

Methods in org.apache.flink.table.runtime.hashtable that return BlockCompressionFactory

Modifier and Type	Method and Description
BlockCompressionFactory	LongHybridHashTable.compressionCodecFactory()

Uses of BlockCompressionFactory in org.apache.flink.table.runtime.io

Constructors in org.apache.flink.table.runtime.io with parameters of type BlockCompressionFactory

Constructor and Description
CompressedBlockChannelReader(IOManager ioManager, FileIOChannel.ID channel, LinkedBlockingQueue<MemorySegment> blockQueue, BlockCompressionFactory codecFactory, int preferBlockSize, int segmentSize)
CompressedBlockChannelWriter(IOManager ioManager, FileIOChannel.ID channel, LinkedBlockingQueue<MemorySegment> blockQueue, BlockCompressionFactory codecFactory, int preferBlockSize, int segmentSize)
CompressedHeaderlessChannelReaderInputView(FileIOChannel.ID id, IOManager ioManager, BlockCompressionFactory compressionCodecFactory, int compressionBlockSize, int numBlocks)
CompressedHeaderlessChannelWriterOutputView(BufferFileWriter writer, BlockCompressionFactory compressionCodecFactory, int compressionBlockSize)

Uses of BlockCompressionFactory in org.apache.flink.table.runtime.operators.sort

Constructors in org.apache.flink.table.runtime.operators.sort with parameters of type BlockCompressionFactory

Constructor and Description
AbstractBinaryExternalMerger(IOManager ioManager, int pageSize, int maxFanIn, SpillChannelManager channelManager, boolean compressionEnable, BlockCompressionFactory compressionCodecFactory, int compressionBlockSize)
BinaryExternalMerger(IOManager ioManager, int pageSize, int maxFanIn, SpillChannelManager channelManager, BinaryRowSerializer serializer, RecordComparator comparator, boolean compressionEnable, BlockCompressionFactory compressionCodecFactory, int compressionBlockSize)
BinaryKVExternalMerger(IOManager ioManager, int pageSize, int maxFanIn, SpillChannelManager channelManager, BinaryRowSerializer keySerializer, BinaryRowSerializer valueSerializer, RecordComparator comparator, boolean compressionEnable, BlockCompressionFactory compressionCodecFactory, int compressionBlockSize)

Uses of BlockCompressionFactory in org.apache.flink.table.runtime.util

Methods in org.apache.flink.table.runtime.util with parameters of type BlockCompressionFactory

Modifier and Type	Method and Description
static BlockChannelReader<MemorySegment>	FileChannelUtil.createBlockChannelReader(IOManager ioManager, FileIOChannel.ID channel, LinkedBlockingQueue<MemorySegment> bufferReturnQueue, boolean compressionEnable, BlockCompressionFactory compressionCodecFactory, int compressionBlockSize, int segmentSize)
static BlockChannelWriter<MemorySegment>	FileChannelUtil.createBlockChannelWriter(IOManager ioManager, FileIOChannel.ID channel, LinkedBlockingQueue<MemorySegment> bufferReturnQueue, boolean compressionEnable, BlockCompressionFactory compressionCodecFactory, int compressionBlockSize, int segmentSize)
static AbstractChannelReaderInputView	FileChannelUtil.createInputView(IOManager ioManager, ChannelWithMeta channel, List<FileIOChannel> channels, boolean compressionEnable, BlockCompressionFactory compressionCodecFactory, int compressionBlockSize, int segmentSize)
static AbstractChannelWriterOutputView	FileChannelUtil.createOutputView(IOManager ioManager, FileIOChannel.ID channel, boolean compressionEnable, BlockCompressionFactory compressionCodecFactory, int compressionBlockSize, int segmentSize)