org.apache.flink.table.runtime.operators.sort

Class BinaryExternalMerger

java.lang.Object

org.apache.flink.table.runtime.operators.sort.AbstractBinaryExternalMerger<BinaryRowData>

org.apache.flink.table.runtime.operators.sort.BinaryExternalMerger

All Implemented Interfaces:

Closeable, AutoCloseable

public class BinaryExternalMerger
extends AbstractBinaryExternalMerger<BinaryRowData>

Record merger for sort of BinaryRowData.

Field Summary

Fields inherited from class org.apache.flink.table.runtime.operators.sort.AbstractBinaryExternalMerger

ioManager, pageSize

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class org.apache.flink.table.runtime.operators.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,
                            BinaryRowDataSerializer serializer,
                            RecordComparator comparator,
                            boolean compressionEnabled,
                            BlockCompressionFactory compressionCodecFactory,
                            int compressionBlockSize)

Method Detail

channelReaderInputViewIterator

protected MutableObjectIterator<BinaryRowData> channelReaderInputViewIterator(AbstractChannelReaderInputView inView)

Specified by:

channelReaderInputViewIterator in class AbstractBinaryExternalMerger<BinaryRowData>

Returns:

entry iterator reading from inView.

mergeComparator

protected Comparator<BinaryRowData> mergeComparator()

Specified by:

mergeComparator in class AbstractBinaryExternalMerger<BinaryRowData>

Returns:

merging comparator used in merging.

mergeReusedEntries

protected List<BinaryRowData> mergeReusedEntries(int size)

Specified by:

mergeReusedEntries in class AbstractBinaryExternalMerger<BinaryRowData>

Returns:

reused entry object used in merging.

writeMergingOutput

protected void writeMergingOutput(MutableObjectIterator<BinaryRowData> 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<BinaryRowData>

Throws:

IOException