Package org.apache.paimon.flink.source

Class Summary

Class	Description
AppendBypassCoordinateOperator<CommitT>	A OneInputStreamOperator to accept commit messages and send append compact coordinate compact task to downstream operators.
AppendBypassCoordinateOperatorFactory<CommitT>	Factory of AppendBypassCoordinateOperator.
BaseDataTableSource	Table source to create StaticFileStoreSource or ContinuousFileStoreSource under batch mode or streaming mode.
BucketUnawareCompactSource	Source Function for unaware-bucket Compaction.
CombinedTableCompactorSourceBuilder	source builder to build a Flink compactor source for multi-tables.
CompactorSourceBuilder	Source builder to build a Flink StaticFileStoreSource or ContinuousFileStoreSource.
ConsumerProgressCalculator	Calculator for calculating consumer consumption progress.
ContinuousFileSplitEnumerator	A continuously monitoring enumerator.
ContinuousFileSplitEnumerator.PlanWithNextSnapshotId	The result of scan.
ContinuousFileStoreSource	Unbounded FlinkSource for reading records.
DataTableSource	A BaseDataTableSource implements SupportsStatisticReport and SupportsDynamicFiltering.
DynamicPartitionFilteringInfo	Manage dynamic partition filtering fields and table partition row.
FileStoreSourceReader	A SourceReader that read records from FileStoreSourceSplit.
FileStoreSourceSplit	SourceSplit of file store.
FileStoreSourceSplitGenerator	The FileStoreSplitGenerator's task is to plan all files to be read and to split them into a set of FileStoreSourceSplit.
FileStoreSourceSplitReader	The SplitReader implementation for the file store source.
FileStoreSourceSplitSerializer	A SimpleVersionedSerializer for FileStoreSourceSplit.
FileStoreSourceSplitState	State of the reader, essentially a mutable version of the FileStoreSourceSplit.
FlinkRecordsWithSplitIds	A RecordsWithSplitIds which contains only one iterator record.
FlinkSource	A Flink Source for paimon.
FlinkSourceBuilder	DataStream API for building Flink Source.
FlinkTableSource	A Flink ScanTableSource for paimon.
FlinkTableSource.SplitStatistics	Split statistics for inferring row count and parallelism size.
LogHybridSourceFactory	Log HybridSource.SourceFactory from StaticFileStoreSplitEnumerator.
NumberSequenceRowSource	A data source that produces a sequence of numbers (longs) to RowData.
NumberSequenceRowSource.NumberSequenceSplit	A split of the source, representing a number sub-sequence.
OnEventWatermarkStrategy	Paimon WatermarkStrategy to emit watermark on event.
PendingSplitsCheckpoint	A checkpoint of the current state of the containing the currently pending splits that are not yet assigned.
PendingSplitsCheckpointSerializer	A SimpleVersionedSerializer for PendingSplitsCheckpoint.
ReaderConsumeProgressEvent	Event sent from FileStoreSourceReader to ContinuousFileSplitEnumerator to describe the current consumption progress.
RecordLimiter	A limiter to limit record reading.
RewriteFileIndexSource	Bounded FlinkSource for reading records.
RewriteFileIndexSource.CheckpointState	State for splits.
RewriteFileIndexSource.Split	Split to wrap ManifestEntry.
StaticFileStoreSource	Bounded FlinkSource for reading records.
StaticFileStoreSplitEnumerator	A SplitEnumerator implementation for StaticFileStoreSource input.
SystemTableSource	A FlinkTableSource for system table.
WatermarkAlignUtils	Since Flink 1.15, watermark alignment is supported.