org.apache.paimon.mergetree.compact

Class SortMergeReaderWithLoserTree<T>

java.lang.Object

org.apache.paimon.mergetree.compact.SortMergeReaderWithLoserTree<T>

All Implemented Interfaces:

Closeable, AutoCloseable, SortMergeReader<T>, RecordReader<T>

public class SortMergeReaderWithLoserTree<T>
extends Object
implements SortMergeReader<T>

SortMergeReader implemented with loser-tree.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.paimon.reader.RecordReader

RecordReader.RecordIterator<T>

Constructor Summary

Constructors

Constructor and Description
SortMergeReaderWithLoserTree(List<RecordReader<KeyValue>> readers, Comparator<InternalRow> userKeyComparator, FieldsComparator userDefinedSeqComparator, MergeFunctionWrapper<T> mergeFunctionWrapper)

Method Summary

Modifier and Type	Method and Description
void	close() Closes the reader and should release all resources.
RecordReader.RecordIterator<T>	readBatch() Compared with heapsort, LoserTree will only produce one batch.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.paimon.mergetree.compact.SortMergeReader

createSortMergeReader

Methods inherited from interface org.apache.paimon.reader.RecordReader

filter, forEachRemaining, forEachRemainingWithPosition, toCloseableIterator, transform

Constructor Detail

SortMergeReaderWithLoserTree

public SortMergeReaderWithLoserTree(List<RecordReader<KeyValue>> readers,
                                    Comparator<InternalRow> userKeyComparator,
                                    @Nullable
                                    FieldsComparator userDefinedSeqComparator,
                                    MergeFunctionWrapper<T> mergeFunctionWrapper)

Method Detail

readBatch

@Nullable
public RecordReader.RecordIterator<T> readBatch()
                                                   throws IOException

Compared with heapsort, LoserTree will only produce one batch.

Specified by:

readBatch in interface RecordReader<T>

Throws:

IOException

close

public void close()
           throws IOException

Description copied from interface: RecordReader

Closes the reader and should release all resources.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface RecordReader<T>

Throws:

IOException