Package org.apache.flink.connector.file.src.util

Class MutableRecordAndPosition<E>

java.lang.Object

org.apache.flink.connector.file.src.util.RecordAndPosition<E>

org.apache.flink.connector.file.src.util.MutableRecordAndPosition<E>

@PublicEvolving
public class MutableRecordAndPosition<E>
extends RecordAndPosition<E>

A mutable version of the RecordAndPosition.

This mutable object is useful in cases where only once instance of a RecordAndPosition is needed at a time, like for the result values of the BulkFormat.RecordIterator.

Field Summary

Fields inherited from class org.apache.flink.connector.file.src.util.RecordAndPosition

NO_OFFSET

Constructor Summary

Constructors

Constructor	Description
MutableRecordAndPosition()

Method Summary

Modifier and Type	Method	Description
void	set(E record, long offset, long recordSkipCount)	Updates the record and position in this object.
void	setNext(E record)	Sets the next record of a sequence.
void	setPosition(long offset, long recordSkipCount)	Sets the position without setting a record.

Methods inherited from class org.apache.flink.connector.file.src.util.RecordAndPosition

getOffset, getRecord, getRecordSkipCount, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

MutableRecordAndPosition

public MutableRecordAndPosition()

Method Detail

set

public void set(E record,
                long offset,
                long recordSkipCount)

Updates the record and position in this object.

setPosition

public void setPosition(long offset,
                        long recordSkipCount)

Sets the position without setting a record.

setNext

public void setNext(E record)

Sets the next record of a sequence. This increments the recordSkipCount by one.