org.apache.paimon.append

Class BucketedAppendCompactManager.AutoCompactTask

java.lang.Object

org.apache.paimon.compact.CompactTask

org.apache.paimon.append.BucketedAppendCompactManager.AutoCompactTask

All Implemented Interfaces:

Callable<CompactResult>

Enclosing class:

BucketedAppendCompactManager

public static class BucketedAppendCompactManager.AutoCompactTask
extends CompactTask

A CompactTask impl for append-only table auto-compaction.

This task accepts an already-picked candidate to perform one-time rewrite. And for the rest of input files, it is the duty of AppendOnlyWriter to invoke the next time compaction.

Constructor Summary

Constructors

Constructor and Description
AutoCompactTask(DeletionVectorsMaintainer dvMaintainer, List<DataFileMeta> toCompact, BucketedAppendCompactManager.CompactRewriter rewriter, CompactionMetrics.Reporter metricsReporter)

Method Summary

Modifier and Type	Method and Description
protected CompactResult	doCompact() Perform compaction.

Methods inherited from class org.apache.paimon.compact.CompactTask

call, logMetric

Methods inherited from class java.lang.Object

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

Constructor Detail

AutoCompactTask

public AutoCompactTask(DeletionVectorsMaintainer dvMaintainer,
                       List<DataFileMeta> toCompact,
                       BucketedAppendCompactManager.CompactRewriter rewriter,
                       @Nullable
                       CompactionMetrics.Reporter metricsReporter)

Method Detail

doCompact

protected CompactResult doCompact()
                           throws Exception

Description copied from class: CompactTask

Perform compaction.

Specified by:

doCompact in class CompactTask

Returns:

CompactResult of compact before and compact after files.

Throws:

Exception