org.apache.paimon.compact

Class NoopCompactManager

java.lang.Object

org.apache.paimon.compact.NoopCompactManager

All Implemented Interfaces:

Closeable, AutoCloseable, CompactManager

public class NoopCompactManager
extends Object
implements CompactManager

A CompactManager which never compacts.

Constructor Summary

Constructors

Constructor and Description
NoopCompactManager()

Method Summary

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()
boolean	compactNotCompleted() Check if a compaction is in progress, or if a compaction result remains to be fetched, or if a compaction should be triggered later.
Optional<CompactResult>	getCompactionResult(boolean blocking) Get compaction result.
boolean	shouldWaitForLatestCompaction() Should wait compaction finish.
boolean	shouldWaitForPreparingCheckpoint()
void	triggerCompaction(boolean fullCompaction) Trigger a new compaction task.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NoopCompactManager

public NoopCompactManager()

Method Detail

shouldWaitForLatestCompaction

public boolean shouldWaitForLatestCompaction()

Description copied from interface: CompactManager

Should wait compaction finish.

Specified by:

shouldWaitForLatestCompaction in interface CompactManager

shouldWaitForPreparingCheckpoint

public boolean shouldWaitForPreparingCheckpoint()

Specified by:

shouldWaitForPreparingCheckpoint in interface CompactManager

addNewFile

public void addNewFile(DataFileMeta file)

Description copied from interface: CompactManager

Add a new file.

Specified by:

addNewFile in interface CompactManager

allFiles

public List<DataFileMeta> allFiles()

Specified by:

allFiles in interface CompactManager

triggerCompaction

public void triggerCompaction(boolean fullCompaction)

Description copied from interface: CompactManager

Trigger a new compaction task.

Specified by:

triggerCompaction in interface CompactManager

Parameters:

fullCompaction - if caller needs a guaranteed full compaction

getCompactionResult

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

Description copied from interface: CompactManager

Get compaction result. Wait finish if blocking is true.

Specified by:

getCompactionResult in interface CompactManager

Throws:

ExecutionException

InterruptedException

cancelCompaction

public void cancelCompaction()

Description copied from interface: CompactManager

Cancel currently running compaction task.

Specified by:

cancelCompaction in interface CompactManager

compactNotCompleted

public boolean compactNotCompleted()

Description copied from interface: CompactManager

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

Specified by:

compactNotCompleted in interface CompactManager

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException