org.apache.paimon.compact

Class CompactTask

java.lang.Object

org.apache.paimon.compact.CompactTask

All Implemented Interfaces:

Callable<CompactResult>

Direct Known Subclasses:

BucketedAppendCompactManager.AutoCompactTask, BucketedAppendCompactManager.FullCompactTask, MergeTreeCompactTask

public abstract class CompactTask
extends Object
implements Callable<CompactResult>

Compact task.

Constructor Summary

Constructors

Constructor and Description
CompactTask(CompactionMetrics.Reporter metricsReporter)

Method Summary

Modifier and Type	Method and Description
CompactResult	call()
protected abstract CompactResult	doCompact() Perform compaction.
protected String	logMetric(long startMillis, List<DataFileMeta> compactBefore, List<DataFileMeta> compactAfter)

Methods inherited from class java.lang.Object

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

Constructor Detail

CompactTask

public CompactTask(@Nullable
                   CompactionMetrics.Reporter metricsReporter)

Method Detail

call

public CompactResult call()
                   throws Exception

Specified by:

call in interface Callable<CompactResult>

Throws:

Exception

logMetric

protected String logMetric(long startMillis,
                           List<DataFileMeta> compactBefore,
                           List<DataFileMeta> compactAfter)

doCompact

protected abstract CompactResult doCompact()
                                    throws Exception

Perform compaction.

Returns:

CompactResult of compact before and compact after files.

Throws:

Exception