Modifier and Type | Field and Description |
---|---|
protected KeyValueFileReaderFactory |
MergeTreeBenchmark.readerFactory |
Modifier and Type | Method and Description |
---|---|
KeyValueFileReaderFactory |
KeyValueFileReaderFactory.Builder.build(org.apache.flink.table.data.binary.BinaryRowData partition,
int bucket) |
KeyValueFileReaderFactory |
KeyValueFileReaderFactory.Builder.build(org.apache.flink.table.data.binary.BinaryRowData partition,
int bucket,
boolean projectKeys,
List<Predicate> filters) |
Modifier and Type | Method and Description |
---|---|
static RecordReader<KeyValue> |
MergeTreeReaders.readerForMergeTree(List<List<SortedRun>> sections,
boolean dropDelete,
KeyValueFileReaderFactory readerFactory,
Comparator<org.apache.flink.table.data.RowData> userKeyComparator,
MergeFunction<KeyValue> mergeFunction) |
static RecordReader<KeyValue> |
MergeTreeReaders.readerForRun(SortedRun run,
KeyValueFileReaderFactory readerFactory) |
static RecordReader<KeyValue> |
MergeTreeReaders.readerForSection(List<SortedRun> section,
KeyValueFileReaderFactory readerFactory,
Comparator<org.apache.flink.table.data.RowData> userKeyComparator,
MergeFunctionWrapper<KeyValue> mergeFunctionWrapper) |
Modifier and Type | Field and Description |
---|---|
protected KeyValueFileReaderFactory |
MergeTreeCompactRewriter.readerFactory |
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.