Package | Description |
---|---|
org.apache.paimon.disk | |
org.apache.paimon.sort |
Modifier and Type | Method and Description |
---|---|
List<ChannelWithMeta> |
ExternalBuffer.getSpillChannels() |
Modifier and Type | Method and Description |
---|---|
static ChannelReaderInputView |
FileChannelUtil.createInputView(IOManager ioManager,
ChannelWithMeta channel,
List<FileIOChannel> channels,
BlockCompressionFactory compressionCodecFactory,
int compressionBlockSize) |
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.
|
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.