public class MergeTreeReaders extends Object
RecordReader
s for merge trees.Modifier and Type | Method and Description |
---|---|
static <T> RecordReader<T> |
readerForMergeTree(List<List<SortedRun>> sections,
FileReaderFactory<KeyValue> readerFactory,
Comparator<InternalRow> userKeyComparator,
FieldsComparator userDefinedSeqComparator,
MergeFunctionWrapper<T> mergeFunctionWrapper,
MergeSorter mergeSorter) |
static <T> RecordReader<T> |
readerForSection(List<SortedRun> section,
FileReaderFactory<KeyValue> readerFactory,
Comparator<InternalRow> userKeyComparator,
FieldsComparator userDefinedSeqComparator,
MergeFunctionWrapper<T> mergeFunctionWrapper,
MergeSorter mergeSorter) |
public static <T> RecordReader<T> readerForMergeTree(List<List<SortedRun>> sections, FileReaderFactory<KeyValue> readerFactory, Comparator<InternalRow> userKeyComparator, @Nullable FieldsComparator userDefinedSeqComparator, MergeFunctionWrapper<T> mergeFunctionWrapper, MergeSorter mergeSorter) throws IOException
IOException
public static <T> RecordReader<T> readerForSection(List<SortedRun> section, FileReaderFactory<KeyValue> readerFactory, Comparator<InternalRow> userKeyComparator, @Nullable FieldsComparator userDefinedSeqComparator, MergeFunctionWrapper<T> mergeFunctionWrapper, MergeSorter mergeSorter) throws IOException
IOException
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.