public class MergeTreeCompactManager extends CompactFutureManager
KeyValueFileStore
.taskFuture
Constructor and Description |
---|
MergeTreeCompactManager(ExecutorService executor,
Levels levels,
CompactStrategy strategy,
Comparator<org.apache.flink.table.data.RowData> keyComparator,
long minFileSize,
int numSortedRunStopTrigger,
CompactRewriter rewriter) |
Modifier and Type | Method and Description |
---|---|
void |
addNewFile(DataFileMeta file)
Add a new file.
|
Optional<CompactResult> |
getCompactionResult(boolean blocking)
Finish current task, and update result files to
Levels . |
Levels |
levels() |
boolean |
shouldWaitCompaction()
Should wait compaction finish.
|
void |
triggerCompaction(boolean fullCompaction)
Trigger a new compaction task.
|
cancelCompaction, innerGetCompactionResult
public MergeTreeCompactManager(ExecutorService executor, Levels levels, CompactStrategy strategy, Comparator<org.apache.flink.table.data.RowData> keyComparator, long minFileSize, int numSortedRunStopTrigger, CompactRewriter rewriter)
public boolean shouldWaitCompaction()
CompactManager
public void addNewFile(DataFileMeta file)
CompactManager
public void triggerCompaction(boolean fullCompaction)
CompactManager
fullCompaction
- if caller needs a guaranteed full compaction@VisibleForTesting public Levels levels()
public Optional<CompactResult> getCompactionResult(boolean blocking) throws ExecutionException, InterruptedException
Levels
.Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.