public class BinaryExternalMerger extends AbstractBinaryExternalMerger<BinaryRow>
ioManager, pageSize
Constructor and Description |
---|
BinaryExternalMerger(IOManager ioManager,
int pageSize,
int maxFanIn,
SpillChannelManager channelManager,
BinaryRowSerializer serializer,
RecordComparator comparator,
boolean compressionEnable,
BlockCompressionFactory compressionCodecFactory,
int compressionBlockSize) |
Modifier and Type | Method and Description |
---|---|
protected MutableObjectIterator<BinaryRow> |
channelReaderInputViewIterator(AbstractChannelReaderInputView 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.
|
close, getMergingIterator, mergeChannelList
public BinaryExternalMerger(IOManager ioManager, int pageSize, int maxFanIn, SpillChannelManager channelManager, BinaryRowSerializer serializer, RecordComparator comparator, boolean compressionEnable, BlockCompressionFactory compressionCodecFactory, int compressionBlockSize)
protected MutableObjectIterator<BinaryRow> channelReaderInputViewIterator(AbstractChannelReaderInputView inView)
channelReaderInputViewIterator
in class AbstractBinaryExternalMerger<BinaryRow>
protected Comparator<BinaryRow> mergeComparator()
mergeComparator
in class AbstractBinaryExternalMerger<BinaryRow>
protected List<BinaryRow> mergeReusedEntries(int size)
mergeReusedEntries
in class AbstractBinaryExternalMerger<BinaryRow>
protected void writeMergingOutput(MutableObjectIterator<BinaryRow> mergeIterator, AbstractPagedOutputView output) throws IOException
AbstractBinaryExternalMerger
writeMergingOutput
in class AbstractBinaryExternalMerger<BinaryRow>
IOException
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.