public class MergeTreeCompactRewriter extends AbstractCompactRewriter
CompactRewriter
for merge trees.Modifier and Type | Field and Description |
---|---|
protected Comparator<org.apache.flink.table.data.RowData> |
keyComparator |
protected MergeFunctionFactory<KeyValue> |
mfFactory |
protected KeyValueFileReaderFactory |
readerFactory |
protected KeyValueFileWriterFactory |
writerFactory |
Constructor and Description |
---|
MergeTreeCompactRewriter(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) |
protected CompactResult |
rewriteCompaction(int outputLevel,
boolean dropDelete,
List<List<SortedRun>> sections) |
extractFilesFromSections, upgrade
protected final KeyValueFileReaderFactory readerFactory
protected final KeyValueFileWriterFactory writerFactory
protected final Comparator<org.apache.flink.table.data.RowData> keyComparator
protected final MergeFunctionFactory<KeyValue> mfFactory
public MergeTreeCompactRewriter(KeyValueFileReaderFactory readerFactory, KeyValueFileWriterFactory writerFactory, Comparator<org.apache.flink.table.data.RowData> keyComparator, MergeFunctionFactory<KeyValue> mfFactory)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.