org.apache.paimon.flink.source.align

Class AlignedContinuousFileStoreSource

java.lang.Object

org.apache.paimon.flink.source.FlinkSource

org.apache.paimon.flink.source.ContinuousFileStoreSource

org.apache.paimon.flink.source.align.AlignedContinuousFileStoreSource

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 AlignedContinuousFileStoreSource
extends ContinuousFileStoreSource

Used to create AlignedSourceReader and AlignedContinuousFileSplitEnumerator.

See Also:

Serialized Form

Field Summary

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

bucketMode, options

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

limit, readBuilder

Constructor Summary

Constructors

Constructor and Description
AlignedContinuousFileStoreSource(ReadBuilder readBuilder, Map<String,String> options, Long limit, BucketMode bucketMode)

Method Summary

Modifier and Type	Method and Description
protected org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint>	buildEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context, Collection<FileStoreSourceSplit> splits, Long nextSnapshotId, StreamTableScan scan)
org.apache.flink.api.connector.source.SourceReader<org.apache.flink.table.data.RowData,FileStoreSourceSplit>	createReader(org.apache.flink.api.connector.source.SourceReaderContext context)

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

getBoundedness, restoreEnumerator

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

createEnumerator, getEnumeratorCheckpointSerializer, getSplitSerializer

Methods inherited from class java.lang.Object

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

Constructor Detail

AlignedContinuousFileStoreSource

public AlignedContinuousFileStoreSource(ReadBuilder readBuilder,
                                        Map<String,String> options,
                                        @Nullable
                                        Long limit,
                                        BucketMode bucketMode)

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>

Overrides:

createReader in class FlinkSource

buildEnumerator

protected org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint> buildEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context,
                                                                                                                              Collection<FileStoreSourceSplit> splits,
                                                                                                                              @Nullable
                                                                                                                              Long nextSnapshotId,
                                                                                                                              StreamTableScan scan)

Overrides:

buildEnumerator in class ContinuousFileStoreSource