public class BinaryExternalMerger
extends org.apache.flink.table.runtime.operators.sort.AbstractBinaryExternalMerger<org.apache.flink.table.data.binary.BinaryRowData>
Constructor and Description |
---|
BinaryExternalMerger(org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager,
int pageSize,
int maxFanIn,
org.apache.flink.table.runtime.operators.sort.SpillChannelManager channelManager,
org.apache.flink.table.runtime.typeutils.BinaryRowDataSerializer serializer,
RecordComparator comparator,
boolean compressionEnable,
org.apache.flink.runtime.io.compression.BlockCompressionFactory compressionCodecFactory,
int compressionBlockSize) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.flink.util.MutableObjectIterator<org.apache.flink.table.data.binary.BinaryRowData> |
channelReaderInputViewIterator(org.apache.flink.runtime.io.disk.iomanager.AbstractChannelReaderInputView inView) |
protected Comparator<org.apache.flink.table.data.binary.BinaryRowData> |
mergeComparator() |
protected List<org.apache.flink.table.data.binary.BinaryRowData> |
mergeReusedEntries(int size) |
protected void |
writeMergingOutput(org.apache.flink.util.MutableObjectIterator<org.apache.flink.table.data.binary.BinaryRowData> mergeIterator,
org.apache.flink.runtime.memory.AbstractPagedOutputView output) |
public BinaryExternalMerger(org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager, int pageSize, int maxFanIn, org.apache.flink.table.runtime.operators.sort.SpillChannelManager channelManager, org.apache.flink.table.runtime.typeutils.BinaryRowDataSerializer serializer, RecordComparator comparator, boolean compressionEnable, org.apache.flink.runtime.io.compression.BlockCompressionFactory compressionCodecFactory, int compressionBlockSize)
protected org.apache.flink.util.MutableObjectIterator<org.apache.flink.table.data.binary.BinaryRowData> channelReaderInputViewIterator(org.apache.flink.runtime.io.disk.iomanager.AbstractChannelReaderInputView inView)
channelReaderInputViewIterator
in class org.apache.flink.table.runtime.operators.sort.AbstractBinaryExternalMerger<org.apache.flink.table.data.binary.BinaryRowData>
protected Comparator<org.apache.flink.table.data.binary.BinaryRowData> mergeComparator()
mergeComparator
in class org.apache.flink.table.runtime.operators.sort.AbstractBinaryExternalMerger<org.apache.flink.table.data.binary.BinaryRowData>
protected List<org.apache.flink.table.data.binary.BinaryRowData> mergeReusedEntries(int size)
mergeReusedEntries
in class org.apache.flink.table.runtime.operators.sort.AbstractBinaryExternalMerger<org.apache.flink.table.data.binary.BinaryRowData>
protected void writeMergingOutput(org.apache.flink.util.MutableObjectIterator<org.apache.flink.table.data.binary.BinaryRowData> mergeIterator, org.apache.flink.runtime.memory.AbstractPagedOutputView output) throws IOException
writeMergingOutput
in class org.apache.flink.table.runtime.operators.sort.AbstractBinaryExternalMerger<org.apache.flink.table.data.binary.BinaryRowData>
IOException
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.