org.apache.flink.table.runtime.io

Class BinaryRowChannelInputViewIterator

java.lang.Object

org.apache.flink.table.runtime.io.BinaryRowChannelInputViewIterator

All Implemented Interfaces:

MutableObjectIterator<BinaryRowData>

Direct Known Subclasses:

LongHashPartitionChannelReaderInputViewIterator

public class BinaryRowChannelInputViewIterator
extends Object
implements MutableObjectIterator<BinaryRowData>

A simple iterator over the input read though an I/O channel. Use BinaryRowDataSerializer.deserializeFromPages(org.apache.flink.runtime.memory.AbstractPagedInputView).

Field Summary

Fields

Modifier and Type	Field and Description
protected List<MemorySegment>	freeMemTarget
protected ChannelReaderInputView	inView
protected BinaryRowDataSerializer	serializer

Constructor Summary

Constructors

Constructor and Description
BinaryRowChannelInputViewIterator(ChannelReaderInputView inView, BinaryRowDataSerializer serializer)
BinaryRowChannelInputViewIterator(ChannelReaderInputView inView, List<MemorySegment> freeMemTarget, BinaryRowDataSerializer serializer)

Method Summary

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

inView

protected final ChannelReaderInputView inView

serializer

protected final BinaryRowDataSerializer serializer

freeMemTarget

protected final List<MemorySegment> freeMemTarget

Constructor Detail

BinaryRowChannelInputViewIterator

public BinaryRowChannelInputViewIterator(ChannelReaderInputView inView,
                                         BinaryRowDataSerializer serializer)

BinaryRowChannelInputViewIterator

public BinaryRowChannelInputViewIterator(ChannelReaderInputView inView,
                                         List<MemorySegment> freeMemTarget,
                                         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 interface MutableObjectIterator<BinaryRowData>

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

next

public BinaryRowData next()
                   throws IOException

Description copied from interface: MutableObjectIterator

Gets the next element from the collection. The iterator implementation must obtain a new instance.

Specified by:

next in interface MutableObjectIterator<BinaryRowData>

Returns:

The 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