public class AppendOnlyCompactManager extends CompactFutureManager
AppendOnlyFileStore
.Modifier and Type | Class and Description |
---|---|
static class |
AppendOnlyCompactManager.AutoCompactTask
A
CompactTask impl for append-only table auto-compaction. |
static interface |
AppendOnlyCompactManager.CompactRewriter
Compact rewriter for append-only table.
|
static class |
AppendOnlyCompactManager.IterativeCompactTask
A
CompactTask impl for full compaction of append-only table. |
taskFuture
Constructor and Description |
---|
AppendOnlyCompactManager(ExecutorService executor,
LinkedList<DataFileMeta> toCompact,
int minFileNum,
int maxFileNum,
long targetFileSize,
AppendOnlyCompactManager.CompactRewriter rewriter,
DataFilePathFactory pathFactory) |
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
toCompact . |
boolean |
shouldWaitCompaction()
Should wait compaction finish.
|
void |
triggerCompaction(boolean fullCompaction)
Trigger a new compaction task.
|
cancelCompaction, innerGetCompactionResult
public AppendOnlyCompactManager(ExecutorService executor, LinkedList<DataFileMeta> toCompact, int minFileNum, int maxFileNum, long targetFileSize, AppendOnlyCompactManager.CompactRewriter rewriter, DataFilePathFactory pathFactory)
public void triggerCompaction(boolean fullCompaction)
CompactManager
fullCompaction
- if caller needs a guaranteed full compactionpublic boolean shouldWaitCompaction()
CompactManager
public void addNewFile(DataFileMeta file)
CompactManager
public Optional<CompactResult> getCompactionResult(boolean blocking) throws ExecutionException, InterruptedException
toCompact
.Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.