org.apache.paimon.mergetree

Class MergeSorter

java.lang.Object

org.apache.paimon.mergetree.MergeSorter

public class MergeSorter
extends Object

The merge sorter to sort and merge readers with key overlap.

Constructor Summary

Constructors

Constructor and Description
MergeSorter(CoreOptions options, RowType keyType, RowType valueType, IOManager ioManager)

Method Summary

Modifier and Type	Method and Description
MemorySegmentPool	memoryPool()
<T> RecordReader<T>	mergeSort(List<SizedReaderSupplier<KeyValue>> lazyReaders, Comparator<InternalRow> keyComparator, FieldsComparator userDefinedSeqComparator, MergeFunctionWrapper<T> mergeFunction)
<T> RecordReader<T>	mergeSortNoSpill(List<? extends ReaderSupplier<KeyValue>> lazyReaders, Comparator<InternalRow> keyComparator, FieldsComparator userDefinedSeqComparator, MergeFunctionWrapper<T> mergeFunction)
void	setIOManager(IOManager ioManager)
void	setProjectedValueType(RowType projectedType)
RowType	valueType()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MergeSorter

public MergeSorter(CoreOptions options,
                   RowType keyType,
                   RowType valueType,
                   @Nullable
                   IOManager ioManager)

Method Detail

memoryPool

public MemorySegmentPool memoryPool()

valueType

public RowType valueType()

setIOManager

public void setIOManager(IOManager ioManager)

setProjectedValueType

public void setProjectedValueType(RowType projectedType)

mergeSort

public <T> RecordReader<T> mergeSort(List<SizedReaderSupplier<KeyValue>> lazyReaders,
                                     Comparator<InternalRow> keyComparator,
                                     @Nullable
                                     FieldsComparator userDefinedSeqComparator,
                                     MergeFunctionWrapper<T> mergeFunction)
                              throws IOException

Throws:

IOException

mergeSortNoSpill

public <T> RecordReader<T> mergeSortNoSpill(List<? extends ReaderSupplier<KeyValue>> lazyReaders,
                                            Comparator<InternalRow> keyComparator,
                                            @Nullable
                                            FieldsComparator userDefinedSeqComparator,
                                            MergeFunctionWrapper<T> mergeFunction)
                                     throws IOException

Throws:

IOException