Package | Description |
---|---|
org.apache.paimon.compact | |
org.apache.paimon.mergetree.compact | |
org.apache.paimon.utils |
Modifier and Type | Class and Description |
---|---|
static class |
CompactDeletionFile.GeneratedDeletionFile
A generated files implementation of
CompactDeletionFile . |
static class |
CompactDeletionFile.LazyCompactDeletionFile
A lazy generation implementation of
CompactDeletionFile . |
Modifier and Type | Method and Description |
---|---|
CompactDeletionFile |
CompactResult.deletionFile() |
static CompactDeletionFile |
CompactDeletionFile.generateFiles(DeletionVectorsMaintainer maintainer)
Used by async compaction, when compaction task is completed, deletions file will be generated
immediately, so when updateCompactResult, we need to merge old deletion files (just delete
them).
|
static CompactDeletionFile |
CompactDeletionFile.lazyGeneration(DeletionVectorsMaintainer maintainer)
For sync compaction, only create deletion files when prepareCommit.
|
CompactDeletionFile |
CompactDeletionFile.mergeOldFile(CompactDeletionFile old) |
CompactDeletionFile |
CompactDeletionFile.GeneratedDeletionFile.mergeOldFile(CompactDeletionFile old) |
CompactDeletionFile |
CompactDeletionFile.LazyCompactDeletionFile.mergeOldFile(CompactDeletionFile old) |
Modifier and Type | Method and Description |
---|---|
CompactDeletionFile |
CompactDeletionFile.mergeOldFile(CompactDeletionFile old) |
CompactDeletionFile |
CompactDeletionFile.GeneratedDeletionFile.mergeOldFile(CompactDeletionFile old) |
CompactDeletionFile |
CompactDeletionFile.LazyCompactDeletionFile.mergeOldFile(CompactDeletionFile old) |
void |
CompactResult.setDeletionFile(CompactDeletionFile deletionFile) |
Constructor and Description |
---|
MergeTreeCompactTask(Comparator<InternalRow> keyComparator,
long minFileSize,
CompactRewriter rewriter,
CompactUnit unit,
boolean dropDelete,
int maxLevel,
CompactionMetrics.Reporter metricsReporter,
java.util.function.Supplier<CompactDeletionFile> compactDfSupplier) |
Modifier and Type | Method and Description |
---|---|
CompactDeletionFile |
CommitIncrement.compactDeletionFile() |
Constructor and Description |
---|
CommitIncrement(DataIncrement dataIncrement,
CompactIncrement compactIncrement,
CompactDeletionFile compactDeletionFile) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.