Package | Description |
---|---|
org.apache.flink.table.store.file.compact | |
org.apache.flink.table.store.file.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 |
---|---|
Optional<CompactUnit> |
UniversalCompaction.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<org.apache.flink.table.data.RowData> keyComparator,
long minFileSize,
CompactRewriter rewriter,
CompactUnit unit,
boolean dropDelete) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.