public class FullChangelogMergeTreeCompactRewriter extends MergeTreeCompactRewriter
MergeTreeCompactRewriter
which produces changelog files for each full compaction.keyComparator, mfFactory, readerFactory, writerFactory
Constructor and Description |
---|
FullChangelogMergeTreeCompactRewriter(int maxLevel,
KeyValueFileReaderFactory readerFactory,
KeyValueFileWriterFactory writerFactory,
Comparator<org.apache.flink.table.data.RowData> keyComparator,
MergeFunctionFactory<KeyValue> mfFactory) |
Modifier and Type | Method and Description |
---|---|
CompactResult |
rewrite(int outputLevel,
boolean dropDelete,
List<List<SortedRun>> sections) |
CompactResult |
upgrade(int outputLevel,
DataFileMeta file) |
rewriteCompaction
extractFilesFromSections
public FullChangelogMergeTreeCompactRewriter(int maxLevel, KeyValueFileReaderFactory readerFactory, KeyValueFileWriterFactory writerFactory, Comparator<org.apache.flink.table.data.RowData> keyComparator, MergeFunctionFactory<KeyValue> mfFactory)
public CompactResult rewrite(int outputLevel, boolean dropDelete, List<List<SortedRun>> sections) throws Exception
rewrite
in interface CompactRewriter
rewrite
in class MergeTreeCompactRewriter
Exception
public CompactResult upgrade(int outputLevel, DataFileMeta file) throws Exception
upgrade
in interface CompactRewriter
upgrade
in class AbstractCompactRewriter
Exception
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.