Uses of Class
org.apache.paimon.flink.source.FileStoreSourceSplitState

Packages that use FileStoreSourceSplitState

Package	Description
org.apache.paimon.flink.source
org.apache.paimon.flink.source.align

Uses of FileStoreSourceSplitState in org.apache.paimon.flink.source

Methods in org.apache.paimon.flink.source that return FileStoreSourceSplitState

Modifier and Type	Method and Description
protected FileStoreSourceSplitState	FileStoreSourceReader.initializedState(FileStoreSourceSplit split)

Methods in org.apache.paimon.flink.source with parameters of type FileStoreSourceSplitState

Modifier and Type	Method and Description
static void	FlinkRecordsWithSplitIds.emitRecord(org.apache.flink.api.connector.source.SourceReaderContext context, org.apache.flink.connector.file.src.reader.BulkFormat.RecordIterator<org.apache.flink.table.data.RowData> element, org.apache.flink.api.connector.source.SourceOutput<org.apache.flink.table.data.RowData> output, FileStoreSourceSplitState state, FileStoreSourceReaderMetrics metrics)
protected FileStoreSourceSplit	FileStoreSourceReader.toSplitType(String splitId, FileStoreSourceSplitState splitState)

Method parameters in org.apache.paimon.flink.source with type arguments of type FileStoreSourceSplitState

Modifier and Type	Method and Description
protected void	FileStoreSourceReader.onSplitFinished(Map<String,FileStoreSourceSplitState> finishedSplitIds)

Uses of FileStoreSourceSplitState in org.apache.paimon.flink.source.align

Method parameters in org.apache.paimon.flink.source.align with type arguments of type FileStoreSourceSplitState

Modifier and Type	Method and Description
protected void	AlignedSourceReader.onSplitFinished(Map<String,FileStoreSourceSplitState> finishedSplitIds)