Package | Description |
---|---|
org.apache.paimon.compression | |
org.apache.paimon.disk | |
org.apache.paimon.io | |
org.apache.paimon.sort |
Modifier and Type | Class and Description |
---|---|
class |
AirCompressorFactory
Implementation of
BlockCompressionFactory for airlift compressors. |
class |
Lz4BlockCompressionFactory
Implementation of
BlockCompressionFactory for Lz4 codec. |
class |
ZstdBlockCompressionFactory
Implementation of
BlockCompressionFactory for zstd codec. |
Modifier and Type | Method and Description |
---|---|
static BlockCompressionFactory |
BlockCompressionFactory.create(BlockCompressionType compression)
Creates
BlockCompressionFactory according to the BlockCompressionType . |
static BlockCompressionFactory |
BlockCompressionFactory.create(CompressOptions compression)
Creates
BlockCompressionFactory according to the configuration. |
Modifier and Type | Method and Description |
---|---|
static ChannelReaderInputView |
FileChannelUtil.createInputView(IOManager ioManager,
ChannelWithMeta channel,
List<FileIOChannel> channels,
BlockCompressionFactory compressionCodecFactory,
int compressionBlockSize) |
static ChannelWriterOutputView |
FileChannelUtil.createOutputView(IOManager ioManager,
FileIOChannel.ID channel,
BlockCompressionFactory compressionCodecFactory,
int compressionBlockSize) |
Constructor and Description |
---|
ChannelReaderInputView(FileIOChannel.ID id,
IOManager ioManager,
BlockCompressionFactory compressionCodecFactory,
int compressionBlockSize,
int numBlocks) |
ChannelWriterOutputView(BufferFileWriter writer,
BlockCompressionFactory compressionCodecFactory,
int compressionBlockSize) |
Modifier and Type | Method and Description |
---|---|
static PageFileOutput |
PageFileOutput.create(File file,
int pageSize,
BlockCompressionFactory compressionFactory) |
static PageFileInput |
PageFileInput.create(File file,
int pageSize,
BlockCompressionFactory compressionFactory,
long uncompressBytes,
long[] compressPagePositions) |
Constructor and Description |
---|
CompressedPageFileInput(RandomAccessFile file,
int pageSize,
BlockCompressionFactory compressionFactory,
long uncompressedBytes,
long[] pagePositions) |
CompressedPageFileOutput(File file,
int pageSize,
BlockCompressionFactory compressionFactory) |
Constructor and Description |
---|
AbstractBinaryExternalMerger(IOManager ioManager,
int pageSize,
int maxFanIn,
SpillChannelManager channelManager,
BlockCompressionFactory compressionCodecFactory,
int compressionBlockSize) |
BinaryExternalMerger(IOManager ioManager,
int pageSize,
int maxFanIn,
SpillChannelManager channelManager,
BinaryRowSerializer serializer,
RecordComparator comparator,
BlockCompressionFactory compressionCodecFactory,
int compressionBlockSize) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.