| 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–2025 The Apache Software Foundation. All rights reserved.