| 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> |
UniversalCompaction.pick(int numLevels,
List<LevelSortedRun> runs) |
Optional<CompactUnit> |
ForceUpLevel0Compaction.pick(int numLevels,
List<LevelSortedRun> runs) |
Optional<CompactUnit> |
CompactStrategy.pick(int numLevels,
List<LevelSortedRun> runs)
Pick compaction unit from 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.