Package | Description |
---|---|
org.apache.paimon.compact | |
org.apache.paimon.mergetree.compact |
Modifier and Type | Method and Description |
---|---|
static CompactUnit |
CompactUnit.fromFiles(int outputLevel,
List<DataFileMeta> files) |
static CompactUnit |
CompactUnit.fromLevelRuns(int outputLevel,
List<LevelSortedRun> runs) |
Modifier and Type | Method and Description |
---|---|
CompactUnit |
UniversalCompaction.pickForSizeRatio(int maxLevel,
List<LevelSortedRun> runs,
int candidateCount,
boolean forcePick) |
Modifier and Type | Method and Description |
---|---|
Optional<CompactUnit> |
CompactStrategy.pick(int numLevels,
List<LevelSortedRun> runs)
Pick compaction unit from runs.
|
Optional<CompactUnit> |
UniversalCompaction.pick(int numLevels,
List<LevelSortedRun> runs) |
Optional<CompactUnit> |
ForceUpLevel0Compaction.pick(int numLevels,
List<LevelSortedRun> runs) |
static Optional<CompactUnit> |
CompactStrategy.pickFullCompaction(int numLevels,
List<LevelSortedRun> runs)
Pick a compaction unit consisting of all existing files.
|
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) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.