org.apache.paimon.table.source

Class ResetRowKindRecordIterator

java.lang.Object

org.apache.paimon.table.source.ResetRowKindRecordIterator

All Implemented Interfaces:

RecordReader.RecordIterator<InternalRow>

Direct Known Subclasses:

ValueContentRowDataRecordIterator

public abstract class ResetRowKindRecordIterator
extends Object
implements RecordReader.RecordIterator<InternalRow>

A RecordReader.RecordIterator which resets RowKind.INSERT to previous key value.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
KeyValue	nextKeyValue()
void	releaseBatch() Releases the batch that this iterator iterated over.

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, next, transform

Constructor Detail

ResetRowKindRecordIterator

public ResetRowKindRecordIterator(RecordReader.RecordIterator<KeyValue> kvIterator)

Method Detail

nextKeyValue

public final KeyValue nextKeyValue()
                            throws IOException

Throws:

IOException

releaseBatch

public final void releaseBatch()

Description copied from interface: RecordReader.RecordIterator

Releases the batch that this iterator iterated over. This is not supposed to close the reader and its resources, but is simply a signal that this iterator is not used anymore. This method can be used as a hook to recycle/reuse heavyweight object structures.

Specified by:

releaseBatch in interface RecordReader.RecordIterator<InternalRow>