Package | Description |
---|---|
org.apache.flink.table.runtime.operators.sort | |
org.apache.flink.table.runtime.util |
Modifier and Type | Method and Description |
---|---|
List<ChannelWithMeta> |
AbstractBinaryExternalMerger.mergeChannelList(List<ChannelWithMeta> channelIDs)
Merges the given sorted runs to a smaller number of sorted runs.
|
Modifier and Type | Method and Description |
---|---|
BinaryMergeIterator<Entry> |
AbstractBinaryExternalMerger.getMergingIterator(List<ChannelWithMeta> channelIDs,
List<FileIOChannel> openChannels)
Returns an iterator that iterates over the merged result from all given channels.
|
List<ChannelWithMeta> |
AbstractBinaryExternalMerger.mergeChannelList(List<ChannelWithMeta> channelIDs)
Merges the given sorted runs to a smaller number of sorted runs.
|
Modifier and Type | Method and Description |
---|---|
static AbstractChannelReaderInputView |
FileChannelUtil.createInputView(IOManager ioManager,
ChannelWithMeta channel,
List<FileIOChannel> channels,
boolean compressionEnable,
BlockCompressionFactory compressionCodecFactory,
int compressionBlockSize,
int segmentSize) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.