org.apache.paimon.table.source

Class ValueContentRowDataRecordIterator

java.lang.Object

org.apache.paimon.table.source.ResetRowKindRecordIterator

org.apache.paimon.table.source.ValueContentRowDataRecordIterator

All Implemented Interfaces:

RecordReader.RecordIterator<InternalRow>

public class ValueContentRowDataRecordIterator
extends ResetRowKindRecordIterator

A RecordReader.RecordIterator mapping a KeyValue to its value.

Constructor Summary

Constructors

Constructor and Description
ValueContentRowDataRecordIterator(RecordReader.RecordIterator<KeyValue> kvIterator)

Method Summary

Modifier and Type	Method and Description
InternalRow	next() Gets the next record from the iterator.

Methods inherited from class org.apache.paimon.table.source.ResetRowKindRecordIterator

nextKeyValue, releaseBatch

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.paimon.reader.RecordReader.RecordIterator

filter, transform

Constructor Detail

ValueContentRowDataRecordIterator

public ValueContentRowDataRecordIterator(RecordReader.RecordIterator<KeyValue> kvIterator)

Method Detail

next

public InternalRow next()
                 throws IOException

Description copied from interface: RecordReader.RecordIterator

Gets the next record from the iterator. Returns null if this iterator has no more elements.

Throws:

IOException