public interface SortMergeReader<T> extends RecordReader<T>
RecordReader
, which is already sorted by key and
sequence number, and perform a sort merge algorithm. KeyValue
s with the same key will
also be combined during sort merging.
NOTE: KeyValue
s from the same RecordReader
must not contain the same key.
RecordReader.RecordIterator<T>
Modifier and Type | Method and Description |
---|---|
static <T> SortMergeReader<T> |
createSortMergeReader(List<RecordReader<KeyValue>> readers,
Comparator<InternalRow> userKeyComparator,
FieldsComparator userDefinedSeqComparator,
MergeFunctionWrapper<T> mergeFunctionWrapper,
CoreOptions.SortEngine sortEngine) |
close, filter, forEachRemaining, forEachRemainingWithPosition, readBatch, toCloseableIterator, transform
static <T> SortMergeReader<T> createSortMergeReader(List<RecordReader<KeyValue>> readers, Comparator<InternalRow> userKeyComparator, @Nullable FieldsComparator userDefinedSeqComparator, MergeFunctionWrapper<T> mergeFunctionWrapper, CoreOptions.SortEngine sortEngine)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.