org.apache.paimon.sort

Class BinaryExternalMerger

java.lang.Object

org.apache.paimon.sort.AbstractBinaryExternalMerger<BinaryRow>

org.apache.paimon.sort.BinaryExternalMerger

All Implemented Interfaces:

Closeable, AutoCloseable

public class BinaryExternalMerger
extends AbstractBinaryExternalMerger<BinaryRow>

Record merger for sort of BinaryRow.

Field Summary

Fields inherited from class org.apache.paimon.sort.AbstractBinaryExternalMerger

ioManager, pageSize

Constructor Summary

Constructors

Constructor and Description
BinaryExternalMerger(IOManager ioManager, int pageSize, int maxFanIn, SpillChannelManager channelManager, BinaryRowSerializer serializer, RecordComparator comparator, BlockCompressionFactory compressionCodecFactory, int compressionBlockSize)

Method Summary

Modifier and Type	Method and Description
protected MutableObjectIterator<BinaryRow>	channelReaderInputViewIterator(ChannelReaderInputView inView)
protected Comparator<BinaryRow>	mergeComparator()
protected List<BinaryRow>	mergeReusedEntries(int size)
protected void	writeMergingOutput(MutableObjectIterator<BinaryRow> mergeIterator, AbstractPagedOutputView output) read the merged stream and write the data back.

Methods inherited from class org.apache.paimon.sort.AbstractBinaryExternalMerger

close, getMergingIterator, mergeChannelList

Methods inherited from class java.lang.Object

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

Constructor Detail

BinaryExternalMerger

public BinaryExternalMerger(IOManager ioManager,
                            int pageSize,
                            int maxFanIn,
                            SpillChannelManager channelManager,
                            BinaryRowSerializer serializer,
                            RecordComparator comparator,
                            BlockCompressionFactory compressionCodecFactory,
                            int compressionBlockSize)

Method Detail

channelReaderInputViewIterator

protected MutableObjectIterator<BinaryRow> channelReaderInputViewIterator(ChannelReaderInputView inView)

Specified by:

channelReaderInputViewIterator in class AbstractBinaryExternalMerger<BinaryRow>

Returns:

entry iterator reading from inView.

mergeComparator

protected Comparator<BinaryRow> mergeComparator()

Specified by:

mergeComparator in class AbstractBinaryExternalMerger<BinaryRow>

Returns:

merging comparator used in merging.

mergeReusedEntries

protected List<BinaryRow> mergeReusedEntries(int size)

Specified by:

mergeReusedEntries in class AbstractBinaryExternalMerger<BinaryRow>

Returns:

reused entry object used in merging.

writeMergingOutput

protected void writeMergingOutput(MutableObjectIterator<BinaryRow> mergeIterator,
                                  AbstractPagedOutputView output)
                           throws IOException

Description copied from class: AbstractBinaryExternalMerger

read the merged stream and write the data back.

Specified by:

writeMergingOutput in class AbstractBinaryExternalMerger<BinaryRow>

Throws:

IOException