ChangelogMergeTreeRewriter(int maxLevel,
CoreOptions.MergeEngine mergeEngine,
FileReaderFactory<KeyValue> readerFactory,
KeyValueFileWriterFactory writerFactory,
Comparator<InternalRow> keyComparator,
FieldsComparator userDefinedSeqComparator,
MergeFunctionFactory<KeyValue> mfFactory,
MergeSorter mergeSorter,
boolean produceChangelog,
boolean forceDropDelete) |
FullChangelogMergeTreeCompactRewriter(int maxLevel,
CoreOptions.MergeEngine mergeEngine,
FileReaderFactory<KeyValue> readerFactory,
KeyValueFileWriterFactory writerFactory,
Comparator<InternalRow> keyComparator,
FieldsComparator userDefinedSeqComparator,
MergeFunctionFactory<KeyValue> mfFactory,
MergeSorter mergeSorter,
RecordEqualiser valueEqualiser) |
LookupMergeTreeCompactRewriter(int maxLevel,
CoreOptions.MergeEngine mergeEngine,
LookupLevels<T> lookupLevels,
FileReaderFactory<KeyValue> readerFactory,
KeyValueFileWriterFactory writerFactory,
Comparator<InternalRow> keyComparator,
FieldsComparator userDefinedSeqComparator,
MergeFunctionFactory<KeyValue> mfFactory,
MergeSorter mergeSorter,
LookupMergeTreeCompactRewriter.MergeFunctionWrapperFactory<T> wrapperFactory,
boolean produceChangelog,
DeletionVectorsMaintainer dvMaintainer,
CoreOptions options) |