public class BinaryRowChannelInputViewIterator extends Object implements MutableObjectIterator<BinaryRowData>
BinaryRowDataSerializer.deserializeFromPages(org.apache.flink.runtime.memory.AbstractPagedInputView)
.Constructor and Description |
---|
BinaryRowChannelInputViewIterator(ChannelReaderInputView inView,
BinaryRowDataSerializer serializer) |
BinaryRowChannelInputViewIterator(ChannelReaderInputView inView,
List<MemorySegment> freeMemTarget,
BinaryRowDataSerializer serializer) |
Modifier and Type | Method and Description |
---|---|
BinaryRowData |
next()
Gets the next element from the collection.
|
BinaryRowData |
next(BinaryRowData reuse)
Gets the next element from the collection.
|
public BinaryRowChannelInputViewIterator(ChannelReaderInputView inView, BinaryRowDataSerializer serializer)
public BinaryRowChannelInputViewIterator(ChannelReaderInputView inView, List<MemorySegment> freeMemTarget, BinaryRowDataSerializer serializer)
public BinaryRowData next(BinaryRowData reuse) throws IOException
MutableObjectIterator
next
in interface MutableObjectIterator<BinaryRowData>
reuse
- The target object into which to place next element if E is mutable.null
if the iterator is exhausted.IOException
- Thrown, if a problem occurred in the underlying I/O layer or in the
serialization / deserialization logicpublic BinaryRowData next() throws IOException
MutableObjectIterator
next
in interface MutableObjectIterator<BinaryRowData>
null
if the iterator is exhausted.IOException
- Thrown, if a problem occurred in the underlying I/O layer or in the
serialization / deserialization logicCopyright © 2014–2021 The Apache Software Foundation. All rights reserved.