org.apache.paimon.mergetree.compact

Interface CompactRewriter

All Superinterfaces:

AutoCloseable, Closeable

All Known Implementing Classes:

AbstractCompactRewriter, ChangelogMergeTreeRewriter, FullChangelogMergeTreeCompactRewriter, LookupMergeTreeCompactRewriter, MergeTreeCompactRewriter

public interface CompactRewriter
extends Closeable

Rewrite sections to new level.

Method Summary

Modifier and Type	Method and Description
CompactResult	rewrite(int outputLevel, boolean dropDelete, List<List<SortedRun>> sections) Rewrite sections to new level.
CompactResult	upgrade(int outputLevel, DataFileMeta file) Upgrade file to new level, usually file data is not rewritten, only the metadata is updated.

Methods inherited from interface java.io.Closeable

close

Method Detail

rewrite

CompactResult rewrite(int outputLevel,
                      boolean dropDelete,
                      List<List<SortedRun>> sections)
               throws Exception

Rewrite sections to new level.

Parameters:

outputLevel - new level

dropDelete - whether to drop the deletion, see MergeTreeCompactManager.triggerCompaction(boolean)

sections - list of sections (section is a list of SortedRuns, and key intervals between sections do not overlap)

Returns:

compaction result

Throws:

Exception - exception

upgrade

CompactResult upgrade(int outputLevel,
                      DataFileMeta file)
               throws Exception

Upgrade file to new level, usually file data is not rewritten, only the metadata is updated. But in some certain scenarios, we must rewrite file too, e.g. ChangelogMergeTreeRewriter

Parameters:

outputLevel - new level

file - file to be updated

Returns:

compaction result

Throws:

Exception - exception