public class NoopCompactManager extends Object implements CompactManager
CompactManager
which never compacts.Constructor and Description |
---|
NoopCompactManager() |
Modifier and Type | Method and Description |
---|---|
void |
addNewFile(DataFileMeta file)
Add a new file.
|
List<DataFileMeta> |
allFiles() |
void |
cancelCompaction()
Cancel currently running compaction task.
|
void |
close() |
Optional<CompactResult> |
getCompactionResult(boolean blocking)
Get compaction result.
|
boolean |
isCompacting()
Check if a compaction is in progress, or if a compaction result remains to be fetched.
|
boolean |
shouldWaitForLatestCompaction()
Should wait compaction finish.
|
boolean |
shouldWaitForPreparingCheckpoint() |
void |
triggerCompaction(boolean fullCompaction)
Trigger a new compaction task.
|
public boolean shouldWaitForLatestCompaction()
CompactManager
shouldWaitForLatestCompaction
in interface CompactManager
public boolean shouldWaitForPreparingCheckpoint()
shouldWaitForPreparingCheckpoint
in interface CompactManager
public void addNewFile(DataFileMeta file)
CompactManager
addNewFile
in interface CompactManager
public List<DataFileMeta> allFiles()
allFiles
in interface CompactManager
public void triggerCompaction(boolean fullCompaction)
CompactManager
triggerCompaction
in interface CompactManager
fullCompaction
- if caller needs a guaranteed full compactionpublic Optional<CompactResult> getCompactionResult(boolean blocking) throws ExecutionException, InterruptedException
CompactManager
blocking
is true.getCompactionResult
in interface CompactManager
ExecutionException
InterruptedException
public void cancelCompaction()
CompactManager
cancelCompaction
in interface CompactManager
public boolean isCompacting()
CompactManager
isCompacting
in interface CompactManager
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.