org.apache.paimon.flink.source

Class FileStoreSourceSplitState

java.lang.Object

org.apache.paimon.flink.source.FileStoreSourceSplitState

public final class FileStoreSourceSplitState
extends Object

State of the reader, essentially a mutable version of the FileStoreSourceSplit. Has a records-to-skip-count.

Constructor Summary

Constructors

Constructor and Description
FileStoreSourceSplitState(FileStoreSourceSplit split)

Method Summary

Modifier and Type	Method and Description
long	recordsToSkip()
void	setPosition(org.apache.flink.connector.file.src.util.RecordAndPosition<org.apache.flink.table.data.RowData> position)
FileStoreSourceSplit	toSourceSplit()

Methods inherited from class java.lang.Object

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

Constructor Detail

FileStoreSourceSplitState

public FileStoreSourceSplitState(FileStoreSourceSplit split)

Method Detail

setPosition

public void setPosition(org.apache.flink.connector.file.src.util.RecordAndPosition<org.apache.flink.table.data.RowData> position)

recordsToSkip

public long recordsToSkip()

toSourceSplit

public FileStoreSourceSplit toSourceSplit()