Package | Description |
---|---|
org.apache.paimon.io | |
org.apache.paimon.mergetree.compact |
Modifier and Type | Method and Description |
---|---|
static RecordLevelExpire |
RecordLevelExpire.create(CoreOptions options,
TableSchema schema,
SchemaManager schemaManager) |
Modifier and Type | Method and Description |
---|---|
static Optional<CompactUnit> |
CompactStrategy.pickFullCompaction(int numLevels,
List<LevelSortedRun> runs,
RecordLevelExpire recordLevelExpire)
Pick a compaction unit consisting of all existing files.
|
Constructor and Description |
---|
MergeTreeCompactManager(ExecutorService executor,
Levels levels,
CompactStrategy strategy,
Comparator<InternalRow> keyComparator,
long compactionFileSize,
int numSortedRunStopTrigger,
CompactRewriter rewriter,
CompactionMetrics.Reporter metricsReporter,
DeletionVectorsMaintainer dvMaintainer,
boolean lazyGenDeletionFile,
boolean needLookup,
RecordLevelExpire recordLevelExpire) |
MergeTreeCompactTask(Comparator<InternalRow> keyComparator,
long minFileSize,
CompactRewriter rewriter,
CompactUnit unit,
boolean dropDelete,
int maxLevel,
CompactionMetrics.Reporter metricsReporter,
java.util.function.Supplier<CompactDeletionFile> compactDfSupplier,
RecordLevelExpire recordLevelExpire) |
Copyright © 2023–2025 The Apache Software Foundation. All rights reserved.