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

Packages that use FileStoreSourceSplit

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

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

Fields in org.apache.paimon.flink.source with type parameters of type FileStoreSourceSplit

Modifier and Type	Field and Description
protected org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit>	ContinuousFileSplitEnumerator.context

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

Modifier and Type	Method and Description
FileStoreSourceSplit	FileStoreSourceSplitSerializer.deserialize(int version, byte[] serialized)
FileStoreSourceSplit	FileStoreSourceSplitState.toSourceSplit()
protected FileStoreSourceSplit	FileStoreSourceReader.toSplitType(String splitId, FileStoreSourceSplitState splitState)
FileStoreSourceSplit	FileStoreSourceSplit.updateWithRecordsToSkip(long recordsToSkip)

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

Modifier and Type	Method and Description
protected org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint>	ContinuousFileStoreSource.buildEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context, Collection<FileStoreSourceSplit> splits, Long nextSnapshotId, StreamTableScan scan)
org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint>	FlinkSource.createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context)
org.apache.flink.api.connector.source.SourceReader<org.apache.flink.table.data.RowData,FileStoreSourceSplit>	FlinkSource.createReader(org.apache.flink.api.connector.source.SourceReaderContext context)
List<FileStoreSourceSplit>	FileStoreSourceSplitGenerator.createSplits(List<Split> splits)
List<FileStoreSourceSplit>	FileStoreSourceSplitGenerator.createSplits(TableScan.Plan plan)
org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint>	StaticFileStoreSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context, PendingSplitsCheckpoint checkpoint)
org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint>	ContinuousFileStoreSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context, PendingSplitsCheckpoint checkpoint)
Collection<FileStoreSourceSplit>	PendingSplitsCheckpoint.splits()

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

Modifier and Type	Method and Description
protected int	ContinuousFileSplitEnumerator.assignSuggestedTask(FileStoreSourceSplit split)
protected FileStoreSourceSplitState	FileStoreSourceReader.initializedState(FileStoreSourceSplit split)
byte[]	FileStoreSourceSplitSerializer.serialize(FileStoreSourceSplit split)
void	ConsumerProgressCalculator.updateAssignInformation(int subtaskId, FileStoreSourceSplit split)

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

Modifier and Type	Method and Description
protected void	ContinuousFileSplitEnumerator.addSplits(Collection<FileStoreSourceSplit> splits)
void	StaticFileStoreSplitEnumerator.addSplitsBack(List<FileStoreSourceSplit> backSplits, int subtaskId)
void	ContinuousFileSplitEnumerator.addSplitsBack(List<FileStoreSourceSplit> splits, int subtaskId)
protected org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint>	ContinuousFileStoreSource.buildEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context, Collection<FileStoreSourceSplit> splits, Long nextSnapshotId, StreamTableScan scan)
protected org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint>	ContinuousFileStoreSource.buildEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context, Collection<FileStoreSourceSplit> splits, Long nextSnapshotId, StreamTableScan scan)
org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint>	FlinkSource.createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context)
static SplitAssigner	StaticFileStoreSource.createSplitAssigner(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context, int splitBatchSize, FlinkConnectorOptions.SplitAssignMode splitAssignMode, Collection<FileStoreSourceSplit> splits)
static SplitAssigner	StaticFileStoreSource.createSplitAssigner(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context, int splitBatchSize, FlinkConnectorOptions.SplitAssignMode splitAssignMode, Collection<FileStoreSourceSplit> splits)
void	FileStoreSourceSplitReader.handleSplitsChanges(org.apache.flink.connector.base.source.reader.splitreader.SplitsChange<FileStoreSourceSplit> splitsChange)
void	FileStoreSourceSplitReader.pauseOrResumeSplits(Collection<FileStoreSourceSplit> splitsToPause, Collection<FileStoreSourceSplit> splitsToResume) Do not annotate with @override here to maintain compatibility with Flink 1.7-.
void	FileStoreSourceSplitReader.pauseOrResumeSplits(Collection<FileStoreSourceSplit> splitsToPause, Collection<FileStoreSourceSplit> splitsToResume) Do not annotate with @override here to maintain compatibility with Flink 1.7-.
org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint>	StaticFileStoreSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context, PendingSplitsCheckpoint checkpoint)
org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint>	ContinuousFileStoreSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context, PendingSplitsCheckpoint checkpoint)

Constructors in org.apache.paimon.flink.source with parameters of type FileStoreSourceSplit

Constructor and Description
FileStoreSourceSplitState(FileStoreSourceSplit split)

Constructor parameters in org.apache.paimon.flink.source with type arguments of type FileStoreSourceSplit

Constructor and Description
ContinuousFileSplitEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context, Collection<FileStoreSourceSplit> remainSplits, Long nextSnapshotId, long discoveryInterval, StreamTableScan scan, BucketMode bucketMode, int splitMaxPerTask, boolean shuffleBucketWithPartition)
ContinuousFileSplitEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context, Collection<FileStoreSourceSplit> remainSplits, Long nextSnapshotId, long discoveryInterval, StreamTableScan scan, BucketMode bucketMode, int splitMaxPerTask, boolean shuffleBucketWithPartition)
PendingSplitsCheckpoint(Collection<FileStoreSourceSplit> splits, Long currentSnapshotId)
StaticFileStoreSplitEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context, Snapshot snapshot, SplitAssigner splitAssigner)
StaticFileStoreSplitEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context, Snapshot snapshot, SplitAssigner splitAssigner, DynamicPartitionFilteringInfo dynamicPartitionFilteringInfo)

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

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

Modifier and Type	Method and Description
protected org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint>	AlignedContinuousFileStoreSource.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>	AlignedContinuousFileStoreSource.createReader(org.apache.flink.api.connector.source.SourceReaderContext context)

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

Modifier and Type	Method and Description
protected void	AlignedContinuousFileSplitEnumerator.addSplits(Collection<FileStoreSourceSplit> splits)
void	AlignedContinuousFileSplitEnumerator.addSplitsBack(List<FileStoreSourceSplit> splits, int subtaskId)
protected org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint>	AlignedContinuousFileStoreSource.buildEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context, Collection<FileStoreSourceSplit> splits, Long nextSnapshotId, StreamTableScan scan)
protected org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint>	AlignedContinuousFileStoreSource.buildEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context, Collection<FileStoreSourceSplit> splits, Long nextSnapshotId, StreamTableScan scan)

Constructor parameters in org.apache.paimon.flink.source.align with type arguments of type FileStoreSourceSplit

Constructor and Description
AlignedContinuousFileSplitEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context, Collection<FileStoreSourceSplit> remainSplits, Long nextSnapshotId, long discoveryInterval, StreamTableScan scan, BucketMode bucketMode, long alignTimeout, int splitPerTaskMax, boolean shuffleBucketWithPartition)
AlignedContinuousFileSplitEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context, Collection<FileStoreSourceSplit> remainSplits, Long nextSnapshotId, long discoveryInterval, StreamTableScan scan, BucketMode bucketMode, long alignTimeout, int splitPerTaskMax, boolean shuffleBucketWithPartition)

Uses of FileStoreSourceSplit in org.apache.paimon.flink.source.assigners

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

Modifier and Type	Method and Description
List<FileStoreSourceSplit>	AlignedSplitAssigner.getNext(int subtask, String hostname)
List<FileStoreSourceSplit>	DynamicPartitionPruningAssigner.getNext(int subtask, String hostname)
List<FileStoreSourceSplit>	FIFOSplitAssigner.getNext(int subtask, String hostname)
List<FileStoreSourceSplit>	SplitAssigner.getNext(int subtask, String hostname) Gets the next split.
List<FileStoreSourceSplit>	PreAssignSplitAssigner.getNext(int subtask, String hostname)
Collection<FileStoreSourceSplit>	AlignedSplitAssigner.remainingSplits()
Collection<FileStoreSourceSplit>	DynamicPartitionPruningAssigner.remainingSplits()
Collection<FileStoreSourceSplit>	FIFOSplitAssigner.remainingSplits()
Collection<FileStoreSourceSplit>	SplitAssigner.remainingSplits() Gets the remaining splits that this assigner has pending.
Collection<FileStoreSourceSplit>	PreAssignSplitAssigner.remainingSplits()

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

Modifier and Type	Method and Description
void	AlignedSplitAssigner.addSplit(int subtask, FileStoreSourceSplit splits)
void	DynamicPartitionPruningAssigner.addSplit(int suggestedTask, FileStoreSourceSplit splits)
void	FIFOSplitAssigner.addSplit(int suggestedTask, FileStoreSourceSplit split)
void	SplitAssigner.addSplit(int suggestedTask, FileStoreSourceSplit splits) Add one split of a specified subtask to the assigner.
void	PreAssignSplitAssigner.addSplit(int suggestedTask, FileStoreSourceSplit split)

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

Modifier and Type	Method and Description
void	AlignedSplitAssigner.addSplitsBack(int suggestedTask, List<FileStoreSourceSplit> splits)
void	DynamicPartitionPruningAssigner.addSplitsBack(int subtask, List<FileStoreSourceSplit> splits)
void	FIFOSplitAssigner.addSplitsBack(int subtask, List<FileStoreSourceSplit> splits)
void	SplitAssigner.addSplitsBack(int subtask, List<FileStoreSourceSplit> splits) Adds a set of splits to this assigner.
void	PreAssignSplitAssigner.addSplitsBack(int subtask, List<FileStoreSourceSplit> splits)

Constructor parameters in org.apache.paimon.flink.source.assigners with type arguments of type FileStoreSourceSplit

Constructor and Description
FIFOSplitAssigner(Collection<FileStoreSourceSplit> splits)
PreAssignSplitAssigner(int splitBatchSize, int parallelism, Collection<FileStoreSourceSplit> splits)
PreAssignSplitAssigner(int splitBatchSize, int parallelism, Collection<FileStoreSourceSplit> splits, Projection partitionRowProjection, org.apache.flink.table.connector.source.DynamicFilteringData dynamicFilteringData)
PreAssignSplitAssigner(int splitBatchSize, org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context, Collection<FileStoreSourceSplit> splits)
PreAssignSplitAssigner(int splitBatchSize, org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context, Collection<FileStoreSourceSplit> splits)

Uses of FileStoreSourceSplit in org.apache.paimon.flink.utils

Methods in org.apache.paimon.flink.utils with parameters of type FileStoreSourceSplit

Modifier and Type	Method and Description
static Optional<Long>	TableScanUtils.getSnapshotId(FileStoreSourceSplit split) Get snapshot id from FileStoreSourceSplit.