Package | Description |
---|---|
org.apache.paimon.append | |
org.apache.paimon.compact | |
org.apache.paimon.mergetree | |
org.apache.paimon.mergetree.compact | |
org.apache.paimon.operation |
Modifier and Type | Class and Description |
---|---|
class |
BucketedAppendCompactManager
Compact manager for
AppendOnlyFileStore . |
Constructor and Description |
---|
AppendOnlyWriter(FileIO fileIO,
IOManager ioManager,
long schemaId,
FileFormat fileFormat,
long targetFileSize,
RowType writeSchema,
long maxSequenceNumber,
CompactManager compactManager,
IOFunction<List<DataFileMeta>,RecordReaderIterator<InternalRow>> bucketFileRead,
boolean forceCompact,
DataFilePathFactory pathFactory,
CommitIncrement increment,
boolean useWriteBuffer,
boolean spillable,
String fileCompression,
CompressOptions spillCompression,
SimpleColStatsCollector.Factory[] statsCollectors,
MemorySize maxDiskSize,
FileIndexOptions fileIndexOptions,
boolean asyncFileWrite,
boolean statsDenseStore) |
Modifier and Type | Class and Description |
---|---|
class |
CompactFutureManager
Base implementation of
CompactManager which runs compaction in a separate thread. |
class |
NoopCompactManager
A
CompactManager which never compacts. |
Constructor and Description |
---|
MergeTreeWriter(boolean writeBufferSpillable,
MemorySize maxDiskSize,
int sortMaxFan,
CompressOptions sortCompression,
IOManager ioManager,
CompactManager compactManager,
long maxSequenceNumber,
Comparator<InternalRow> keyComparator,
MergeFunction<KeyValue> mergeFunction,
KeyValueFileWriterFactory writerFactory,
boolean commitForceCompact,
CoreOptions.ChangelogProducer changelogProducer,
CommitIncrement increment,
FieldsComparator userDefinedSeqComparator) |
Modifier and Type | Class and Description |
---|---|
class |
MergeTreeCompactManager
Compact manager for
KeyValueFileStore . |
Modifier and Type | Method and Description |
---|---|
protected CompactManager |
AppendOnlyUnawareBucketFileStoreWrite.getCompactManager(BinaryRow partition,
int bucket,
List<DataFileMeta> restoredFiles,
ExecutorService compactExecutor,
DeletionVectorsMaintainer dvMaintainer) |
protected CompactManager |
AppendOnlyFixedBucketFileStoreWrite.getCompactManager(BinaryRow partition,
int bucket,
List<DataFileMeta> restoredFiles,
ExecutorService compactExecutor,
DeletionVectorsMaintainer dvMaintainer) |
protected abstract CompactManager |
AppendOnlyFileStoreWrite.getCompactManager(BinaryRow partition,
int bucket,
List<DataFileMeta> restoredFiles,
ExecutorService compactExecutor,
DeletionVectorsMaintainer dvMaintainer) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.