public class BinaryRowChannelInputViewIterator extends Object implements MutableObjectIterator<BinaryRow>
BinaryRowSerializer.deserializeFromPages(org.apache.flink.runtime.memory.AbstractPagedInputView)
.Constructor and Description |
---|
BinaryRowChannelInputViewIterator(ChannelReaderInputView inView,
BinaryRowSerializer serializer) |
BinaryRowChannelInputViewIterator(ChannelReaderInputView inView,
List<MemorySegment> freeMemTarget,
BinaryRowSerializer serializer) |
Modifier and Type | Method and Description |
---|---|
BinaryRow |
next()
Gets the next element from the collection.
|
BinaryRow |
next(BinaryRow reuse)
Gets the next element from the collection.
|
public BinaryRowChannelInputViewIterator(ChannelReaderInputView inView, BinaryRowSerializer serializer)
public BinaryRowChannelInputViewIterator(ChannelReaderInputView inView, List<MemorySegment> freeMemTarget, BinaryRowSerializer serializer)
public BinaryRow next(BinaryRow reuse) throws IOException
MutableObjectIterator
next
in interface MutableObjectIterator<BinaryRow>
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 BinaryRow next() throws IOException
MutableObjectIterator
next
in interface MutableObjectIterator<BinaryRow>
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–2020 The Apache Software Foundation. All rights reserved.