org.apache.paimon.append

Class BucketedAppendCompactManager.FullCompactTask

java.lang.Object

org.apache.paimon.compact.CompactTask

org.apache.paimon.append.BucketedAppendCompactManager.FullCompactTask

All Implemented Interfaces:

Callable<CompactResult>

Enclosing class:

BucketedAppendCompactManager

public static class BucketedAppendCompactManager.FullCompactTask
extends CompactTask

A CompactTask impl for full compaction of append-only table.

Constructor Summary

Constructors

Constructor and Description
FullCompactTask(DeletionVectorsMaintainer dvMaintainer, Collection<DataFileMeta> inputs, long targetFileSize, 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

FullCompactTask

public FullCompactTask(DeletionVectorsMaintainer dvMaintainer,
                       Collection<DataFileMeta> inputs,
                       long targetFileSize,
                       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