Uses of Class
org.apache.flink.table.runtime.io.ChannelWithMeta

Packages that use ChannelWithMeta

Package	Description
org.apache.flink.table.runtime.operators.sort
org.apache.flink.table.runtime.util

Uses of ChannelWithMeta in org.apache.flink.table.runtime.operators.sort

Methods in org.apache.flink.table.runtime.operators.sort that return types with arguments of type ChannelWithMeta

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.

Method parameters in org.apache.flink.table.runtime.operators.sort with type arguments of type ChannelWithMeta

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.

Uses of ChannelWithMeta in org.apache.flink.table.runtime.util

Methods in org.apache.flink.table.runtime.util with parameters of type ChannelWithMeta

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)