Uses of Package
org.apache.paimon.flink.source

Packages that use org.apache.paimon.flink.source

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

Classes in org.apache.paimon.flink.source used by org.apache.paimon.flink.source

Class and Description
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.PlanWithNextSnapshotId The result of scan.
DataTableSource A BaseDataTableSource implements SupportsStatisticReport and SupportsDynamicFiltering.
DynamicPartitionFilteringInfo Manage dynamic partition filtering fields and table partition row.
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.
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.
NumberSequenceRowSource.NumberSequenceSplit A split of the source, representing a number sub-sequence.
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.CheckpointState State for splits.
RewriteFileIndexSource.Split Split to wrap ManifestEntry.
StaticFileStoreSplitEnumerator A SplitEnumerator implementation for StaticFileStoreSource input.
SystemTableSource A FlinkTableSource for system table.

Classes in org.apache.paimon.flink.source used by org.apache.paimon.flink.source.align

Class and Description
ContinuousFileSplitEnumerator A continuously monitoring enumerator.
ContinuousFileSplitEnumerator.PlanWithNextSnapshotId The result of scan.
ContinuousFileStoreSource Unbounded FlinkSource for reading records.
FileStoreSourceReader A SourceReader that read records from FileStoreSourceSplit.
FileStoreSourceSplit SourceSplit of file store.
FileStoreSourceSplitState State of the reader, essentially a mutable version of the FileStoreSourceSplit.
FlinkSource A Flink Source for paimon.
PendingSplitsCheckpoint A checkpoint of the current state of the containing the currently pending splits that are not yet assigned.

Classes in org.apache.paimon.flink.source used by org.apache.paimon.flink.source.assigners

Class and Description
FileStoreSourceSplit SourceSplit of file store.

Classes in org.apache.paimon.flink.source used by org.apache.paimon.flink.utils

Class and Description
FileStoreSourceSplit SourceSplit of file store.