Package | Description |
---|---|
org.apache.paimon.disk | |
org.apache.paimon.sort |
Modifier and Type | Class and Description |
---|---|
class |
ChannelReaderInputViewIterator
A simple iterator over the input read though an I/O channel.
|
Modifier and Type | Method and Description |
---|---|
MutableObjectIterator<BinaryRow> |
ChannelReaderInputView.createBinaryRowIterator(BinaryRowSerializer serializer) |
Modifier and Type | Class and Description |
---|---|
class |
BinaryMergeIterator<Entry>
Binary version of
MergeIterator . |
Modifier and Type | Method and Description |
---|---|
protected MutableObjectIterator<BinaryRow> |
BinaryExternalMerger.channelReaderInputViewIterator(ChannelReaderInputView inView) |
protected abstract MutableObjectIterator<Entry> |
AbstractBinaryExternalMerger.channelReaderInputViewIterator(ChannelReaderInputView inView) |
MutableObjectIterator<BinaryRow> |
BinaryExternalSortBuffer.sortedIterator() |
MutableObjectIterator<BinaryRow> |
BinaryInMemorySortBuffer.sortedIterator() |
MutableObjectIterator<BinaryRow> |
SortBuffer.sortedIterator() |
Modifier and Type | Method and Description |
---|---|
void |
BinaryExternalSortBuffer.write(MutableObjectIterator<BinaryRow> iterator) |
protected void |
BinaryExternalMerger.writeMergingOutput(MutableObjectIterator<BinaryRow> mergeIterator,
AbstractPagedOutputView output) |
protected abstract void |
AbstractBinaryExternalMerger.writeMergingOutput(MutableObjectIterator<Entry> mergeIterator,
AbstractPagedOutputView output)
read the merged stream and write the data back.
|
Constructor and Description |
---|
BinaryMergeIterator(List<MutableObjectIterator<Entry>> iterators,
List<Entry> reusableEntries,
Comparator<Entry> comparator) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.