org.apache.paimon.compact

Interface CompactManager

All Superinterfaces:

AutoCloseable, Closeable

All Known Implementing Classes:

BucketedAppendCompactManager, CompactFutureManager, MergeTreeCompactManager, NoopCompactManager

public interface CompactManager
extends Closeable

Manager to submit compaction task.

Method Summary

Modifier and Type	Method and Description
void	addNewFile(DataFileMeta file) Add a new file.
Collection<DataFileMeta>	allFiles()
void	cancelCompaction() Cancel currently running compaction task.
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.

Methods inherited from interface java.io.Closeable

close

Method Detail

shouldWaitForLatestCompaction

boolean shouldWaitForLatestCompaction()

Should wait compaction finish.

shouldWaitForPreparingCheckpoint

boolean shouldWaitForPreparingCheckpoint()

addNewFile

void addNewFile(DataFileMeta file)

Add a new file.

allFiles

Collection<DataFileMeta> allFiles()

triggerCompaction

void triggerCompaction(boolean fullCompaction)

Trigger a new compaction task.

Parameters:

fullCompaction - if caller needs a guaranteed full compaction

getCompactionResult

Optional<CompactResult> getCompactionResult(boolean blocking)
                                     throws ExecutionException,
                                            InterruptedException

Get compaction result. Wait finish if blocking is true.

Throws:

ExecutionException

InterruptedException

cancelCompaction

void cancelCompaction()

Cancel currently running compaction task.

isCompacting

boolean isCompacting()

Check if a compaction is in progress, or if a compaction result remains to be fetched.