org.apache.paimon.mergetree.compact

Class MergeTreeCompactTask

java.lang.Object

org.apache.paimon.compact.CompactTask

org.apache.paimon.mergetree.compact.MergeTreeCompactTask

All Implemented Interfaces:

Callable<CompactResult>

public class MergeTreeCompactTask
extends CompactTask

Compact task for merge tree compaction.

Constructor Summary

Constructors

Constructor and Description
MergeTreeCompactTask(Comparator<InternalRow> keyComparator, long minFileSize, CompactRewriter rewriter, CompactUnit unit, boolean dropDelete, int maxLevel, CompactionMetrics.Reporter metricsReporter, java.util.function.Supplier<CompactDeletionFile> compactDfSupplier)

Method Summary

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

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

call

Methods inherited from class java.lang.Object

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

Constructor Detail

MergeTreeCompactTask

public MergeTreeCompactTask(Comparator<InternalRow> keyComparator,
                            long minFileSize,
                            CompactRewriter rewriter,
                            CompactUnit unit,
                            boolean dropDelete,
                            int maxLevel,
                            @Nullable
                            CompactionMetrics.Reporter metricsReporter,
                            java.util.function.Supplier<CompactDeletionFile> compactDfSupplier)

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

logMetric

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

Overrides:

logMetric in class CompactTask