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

Packages that use SimpleSourceSplit

Package	Description
org.apache.paimon.flink.service
org.apache.paimon.flink.source
org.apache.paimon.flink.source.operator

Uses of SimpleSourceSplit in org.apache.paimon.flink.service

Methods in org.apache.paimon.flink.service that return types with arguments of type SimpleSourceSplit

Modifier and Type	Method and Description
org.apache.flink.api.connector.source.SourceReader<InternalRow,SimpleSourceSplit>	QueryFileMonitor.createReader(org.apache.flink.api.connector.source.SourceReaderContext sourceReaderContext)

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

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

Modifier and Type	Method and Description
SimpleSourceSplit	SimpleSourceSplitSerializer.deserialize(int version, byte[] serialized)

Methods in org.apache.paimon.flink.source that return types with arguments of type SimpleSourceSplit

Modifier and Type	Method and Description
org.apache.flink.api.connector.source.SplitEnumerator<SimpleSourceSplit,NoOpEnumState>	AbstractNonCoordinatedSource.createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<SimpleSourceSplit> enumContext)
org.apache.flink.api.connector.source.SourceReader<UnawareAppendCompactionTask,SimpleSourceSplit>	BucketUnawareCompactSource.createReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext)
org.apache.flink.core.io.SimpleVersionedSerializer<SimpleSourceSplit>	AbstractNonCoordinatedSource.getSplitSerializer()
org.apache.flink.api.connector.source.SplitEnumerator<SimpleSourceSplit,NoOpEnumState>	AbstractNonCoordinatedSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<SimpleSourceSplit> enumContext, NoOpEnumState checkpoint)
List<SimpleSourceSplit>	SplitListState.snapshotState()
List<SimpleSourceSplit>	AbstractNonCoordinatedSourceReader.snapshotState(long l)

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

Modifier and Type	Method and Description
byte[]	SimpleSourceSplitSerializer.serialize(SimpleSourceSplit split)

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

Modifier and Type	Method and Description
void	AbstractNonCoordinatedSourceReader.addSplits(List<SimpleSourceSplit> list)
org.apache.flink.api.connector.source.SplitEnumerator<SimpleSourceSplit,NoOpEnumState>	AbstractNonCoordinatedSource.createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<SimpleSourceSplit> enumContext)
org.apache.flink.api.connector.source.SplitEnumerator<SimpleSourceSplit,NoOpEnumState>	AbstractNonCoordinatedSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<SimpleSourceSplit> enumContext, NoOpEnumState checkpoint)
void	SplitListState.restoreState(List<SimpleSourceSplit> splits)

Uses of SimpleSourceSplit in org.apache.paimon.flink.source.operator

Methods in org.apache.paimon.flink.source.operator that return types with arguments of type SimpleSourceSplit

Modifier and Type	Method and Description
org.apache.flink.api.connector.source.SourceReader<org.apache.flink.api.java.tuple.Tuple2<Split,String>,SimpleSourceSplit>	CombinedAwareStreamingSource.createReader(org.apache.flink.api.connector.source.SourceReaderContext sourceReaderContext)
org.apache.flink.api.connector.source.SourceReader<Split,SimpleSourceSplit>	MonitorSource.createReader(org.apache.flink.api.connector.source.SourceReaderContext sourceReaderContext)
org.apache.flink.api.connector.source.SourceReader<MultiTableUnawareAppendCompactionTask,SimpleSourceSplit>	CombinedUnawareStreamingSource.createReader(org.apache.flink.api.connector.source.SourceReaderContext sourceReaderContext)
org.apache.flink.api.connector.source.SourceReader<MultiTableUnawareAppendCompactionTask,SimpleSourceSplit>	CombinedUnawareBatchSource.createReader(org.apache.flink.api.connector.source.SourceReaderContext sourceReaderContext)
org.apache.flink.api.connector.source.SourceReader<org.apache.flink.api.java.tuple.Tuple2<Split,String>,SimpleSourceSplit>	CombinedAwareBatchSource.createReader(org.apache.flink.api.connector.source.SourceReaderContext sourceReaderContext)