org.apache.paimon.mergetree.compact

Class AbstractCompactRewriter

java.lang.Object

org.apache.paimon.mergetree.compact.AbstractCompactRewriter

All Implemented Interfaces:

Closeable, AutoCloseable, CompactRewriter

Direct Known Subclasses:

MergeTreeCompactRewriter

public abstract class AbstractCompactRewriter
extends Object
implements CompactRewriter

Common implementation of CompactRewriter.

Constructor Summary

Constructors

Constructor and Description
AbstractCompactRewriter()

Method Summary

Modifier and Type	Method and Description
void	close()
protected static List<DataFileMeta>	extractFilesFromSections(List<List<SortedRun>> sections)
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 class java.lang.Object

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

Methods inherited from interface org.apache.paimon.mergetree.compact.CompactRewriter

rewrite

Constructor Detail

AbstractCompactRewriter

public AbstractCompactRewriter()

Method Detail

upgrade

public CompactResult upgrade(int outputLevel,
                             DataFileMeta file)
                      throws Exception

Description copied from interface: CompactRewriter

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

Specified by:

upgrade in interface CompactRewriter

Parameters:

outputLevel - new level

file - file to be updated

Returns:

compaction result

Throws:

Exception - exception

extractFilesFromSections

protected static List<DataFileMeta> extractFilesFromSections(List<List<SortedRun>> sections)

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException