org.apache.paimon.compact

Class CompactFutureManager

java.lang.Object

org.apache.paimon.compact.CompactFutureManager

All Implemented Interfaces:

Closeable, AutoCloseable, CompactManager

Direct Known Subclasses:

BucketedAppendCompactManager, MergeTreeCompactManager

public abstract class CompactFutureManager
extends Object
implements CompactManager

Base implementation of CompactManager which runs compaction in a separate thread.

Field Summary

Fields

Modifier and Type	Field and Description
protected Future<CompactResult>	taskFuture

Constructor Summary

Constructors

Constructor and Description
CompactFutureManager()

Method Summary

Modifier and Type	Method and Description
void	cancelCompaction() Cancel currently running compaction task.
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.
protected Optional<CompactResult>	innerGetCompactionResult(boolean blocking)
protected CompactResult	obtainCompactResult()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.paimon.compact.CompactManager

addNewFile, allFiles, getCompactionResult, shouldWaitForLatestCompaction, shouldWaitForPreparingCheckpoint, triggerCompaction

Methods inherited from interface java.io.Closeable

close

Field Detail

taskFuture

protected Future<CompactResult> taskFuture

Constructor Detail

CompactFutureManager

public CompactFutureManager()

Method Detail

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

innerGetCompactionResult

protected final Optional<CompactResult> innerGetCompactionResult(boolean blocking)
                                                          throws ExecutionException,
                                                                 InterruptedException

Throws:

ExecutionException

InterruptedException

obtainCompactResult

@VisibleForTesting
protected CompactResult obtainCompactResult()
                                                        throws InterruptedException,
                                                               ExecutionException

Throws:

InterruptedException

ExecutionException