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.
protected Optional<CompactResult>	innerGetCompactionResult(boolean blocking)
boolean	isCompacting() Check if a compaction is in progress, or if a compaction result remains to be fetched.
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

isCompacting

public boolean isCompacting()

Description copied from interface: CompactManager

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

Specified by:

isCompacting 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