Modifier and Type | Field and Description |
---|---|
protected KeyValueFileWriterFactory |
MergeTreeBenchmark.writerFactory |
Modifier and Type | Method and Description |
---|---|
KeyValueFileWriterFactory |
KeyValueFileWriterFactory.Builder.build(org.apache.flink.table.data.binary.BinaryRowData partition,
int bucket) |
Constructor and Description |
---|
MergeTreeWriter(boolean writeBufferSpillable,
int sortMaxFan,
org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager,
CompactManager compactManager,
long maxSequenceNumber,
Comparator<org.apache.flink.table.data.RowData> keyComparator,
MergeFunction<KeyValue> mergeFunction,
KeyValueFileWriterFactory writerFactory,
boolean commitForceCompact,
CoreOptions.ChangelogProducer changelogProducer) |
Modifier and Type | Field and Description |
---|---|
protected KeyValueFileWriterFactory |
MergeTreeCompactRewriter.writerFactory |
Constructor and Description |
---|
FullChangelogMergeTreeCompactRewriter(int maxLevel,
KeyValueFileReaderFactory readerFactory,
KeyValueFileWriterFactory writerFactory,
Comparator<org.apache.flink.table.data.RowData> keyComparator,
MergeFunctionFactory<KeyValue> mfFactory) |
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.