Class LongHashPartitionChannelReaderInputViewIterator
- java.lang.Object
-
- org.apache.flink.table.runtime.io.BinaryRowChannelInputViewIterator
-
- org.apache.flink.table.runtime.io.LongHashPartitionChannelReaderInputViewIterator
-
- All Implemented Interfaces:
MutableObjectIterator<BinaryRowData>
public class LongHashPartitionChannelReaderInputViewIterator extends BinaryRowChannelInputViewIterator
A simple iterator over the input read though an I/O channel. UseLongHashPartition.deserializeFromPages(org.apache.flink.table.data.binary.BinaryRowData, org.apache.flink.runtime.io.disk.iomanager.ChannelReaderInputView, org.apache.flink.table.runtime.typeutils.BinaryRowDataSerializer)
-
-
Field Summary
-
Fields inherited from class org.apache.flink.table.runtime.io.BinaryRowChannelInputViewIterator
freeMemTarget, inView, serializer
-
-
Constructor Summary
Constructors Constructor Description LongHashPartitionChannelReaderInputViewIterator(ChannelReaderInputView inView, BinaryRowDataSerializer serializer)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description BinaryRowData
next(BinaryRowData reuse)
Gets the next element from the collection.-
Methods inherited from class org.apache.flink.table.runtime.io.BinaryRowChannelInputViewIterator
next
-
-
-
-
Constructor Detail
-
LongHashPartitionChannelReaderInputViewIterator
public LongHashPartitionChannelReaderInputViewIterator(ChannelReaderInputView inView, BinaryRowDataSerializer serializer)
-
-
Method Detail
-
next
public BinaryRowData next(BinaryRowData reuse) throws IOException
Description copied from interface:MutableObjectIterator
Gets the next element from the collection. The contents of that next element is put into the given reuse object, if the type is mutable.- Specified by:
next
in interfaceMutableObjectIterator<BinaryRowData>
- Overrides:
next
in classBinaryRowChannelInputViewIterator
- Parameters:
reuse
- The target object into which to place next element if E is mutable.- Returns:
- The filled object or
null
if the iterator is exhausted. - Throws:
IOException
- Thrown, if a problem occurred in the underlying I/O layer or in the serialization / deserialization logic
-
-