org.apache.paimon.flink.source

Class FlinkSource

java.lang.Object

org.apache.paimon.flink.source.FlinkSource

All Implemented Interfaces:

Serializable, org.apache.flink.api.connector.source.Source<org.apache.flink.table.data.RowData,FileStoreSourceSplit,PendingSplitsCheckpoint>, org.apache.flink.api.connector.source.SourceReaderFactory<org.apache.flink.table.data.RowData,FileStoreSourceSplit>

Direct Known Subclasses:

ContinuousFileStoreSource, StaticFileStoreSource

public abstract class FlinkSource
extends Object
implements org.apache.flink.api.connector.source.Source<org.apache.flink.table.data.RowData,FileStoreSourceSplit,PendingSplitsCheckpoint>

A Flink Source for paimon.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected Long	limit
protected ReadBuilder	readBuilder

Constructor Summary

Constructors

Constructor and Description
FlinkSource(ReadBuilder readBuilder, Long limit)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint>	createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context)
org.apache.flink.api.connector.source.SourceReader<org.apache.flink.table.data.RowData,FileStoreSourceSplit>	createReader(org.apache.flink.api.connector.source.SourceReaderContext context)
PendingSplitsCheckpointSerializer	getEnumeratorCheckpointSerializer()
FileStoreSourceSplitSerializer	getSplitSerializer()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.api.connector.source.Source

getBoundedness, restoreEnumerator

Field Detail

readBuilder

protected final ReadBuilder readBuilder

limit

@Nullable
protected final Long limit

Constructor Detail

FlinkSource

public FlinkSource(ReadBuilder readBuilder,
                   @Nullable
                   Long limit)

Method Detail

createReader

public org.apache.flink.api.connector.source.SourceReader<org.apache.flink.table.data.RowData,FileStoreSourceSplit> createReader(org.apache.flink.api.connector.source.SourceReaderContext context)

Specified by:

createReader in interface org.apache.flink.api.connector.source.SourceReaderFactory<org.apache.flink.table.data.RowData,FileStoreSourceSplit>

createEnumerator

public org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint> createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context)
                                                                                                                     throws Exception

Specified by:

createEnumerator in interface org.apache.flink.api.connector.source.Source<org.apache.flink.table.data.RowData,FileStoreSourceSplit,PendingSplitsCheckpoint>

Throws:

Exception

getSplitSerializer

public FileStoreSourceSplitSerializer getSplitSerializer()

Specified by:

getSplitSerializer in interface org.apache.flink.api.connector.source.Source<org.apache.flink.table.data.RowData,FileStoreSourceSplit,PendingSplitsCheckpoint>

getEnumeratorCheckpointSerializer

public PendingSplitsCheckpointSerializer getEnumeratorCheckpointSerializer()

Specified by:

getEnumeratorCheckpointSerializer in interface org.apache.flink.api.connector.source.Source<org.apache.flink.table.data.RowData,FileStoreSourceSplit,PendingSplitsCheckpoint>