org.apache.paimon.flink.source

Class StaticFileStoreSource

java.lang.Object

org.apache.paimon.flink.source.FlinkSource

org.apache.paimon.flink.source.StaticFileStoreSource

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>

public class StaticFileStoreSource
extends FlinkSource

Bounded FlinkSource for reading records. It does not monitor new snapshots.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.paimon.flink.source.FlinkSource

limit, readBuilder

Constructor Summary

Constructors

Constructor and Description
StaticFileStoreSource(ReadBuilder readBuilder, Long limit, int splitBatchSize, FlinkConnectorOptions.SplitAssignMode splitAssignMode)
StaticFileStoreSource(ReadBuilder readBuilder, Long limit, int splitBatchSize, FlinkConnectorOptions.SplitAssignMode splitAssignMode, DynamicPartitionFilteringInfo dynamicPartitionFilteringInfo)

Method Summary

Modifier and Type	Method and Description
static SplitAssigner	createSplitAssigner(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context, int splitBatchSize, FlinkConnectorOptions.SplitAssignMode splitAssignMode, Collection<FileStoreSourceSplit> splits)
org.apache.flink.api.connector.source.Boundedness	getBoundedness()
org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint>	restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context, PendingSplitsCheckpoint checkpoint)

Methods inherited from class org.apache.paimon.flink.source.FlinkSource

createEnumerator, createReader, getEnumeratorCheckpointSerializer, getSplitSerializer

Methods inherited from class java.lang.Object

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

Constructor Detail

StaticFileStoreSource

public StaticFileStoreSource(ReadBuilder readBuilder,
                             @Nullable
                             Long limit,
                             int splitBatchSize,
                             FlinkConnectorOptions.SplitAssignMode splitAssignMode)

StaticFileStoreSource

public StaticFileStoreSource(ReadBuilder readBuilder,
                             @Nullable
                             Long limit,
                             int splitBatchSize,
                             FlinkConnectorOptions.SplitAssignMode splitAssignMode,
                             @Nullable
                             DynamicPartitionFilteringInfo dynamicPartitionFilteringInfo)

Method Detail

getBoundedness

public org.apache.flink.api.connector.source.Boundedness getBoundedness()

restoreEnumerator

public org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint> restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context,
                                                                                                                             PendingSplitsCheckpoint checkpoint)

createSplitAssigner

public static SplitAssigner createSplitAssigner(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context,
                                                int splitBatchSize,
                                                FlinkConnectorOptions.SplitAssignMode splitAssignMode,
                                                Collection<FileStoreSourceSplit> splits)