Uses of Interface
org.apache.paimon.table.source.snapshot.SnapshotReader

Packages that use SnapshotReader

Package	Description
org.apache.paimon.flink.lookup
org.apache.paimon.privilege
org.apache.paimon.table
org.apache.paimon.table.source
org.apache.paimon.table.source.snapshot
org.apache.paimon.table.system

Uses of SnapshotReader in org.apache.paimon.flink.lookup

Methods in org.apache.paimon.flink.lookup with parameters of type SnapshotReader

Modifier and Type	Method and Description
SnapshotReader.Plan	CompactionDiffFollowUpScanner.scan(Snapshot snapshot, SnapshotReader snapshotReader)

Constructors in org.apache.paimon.flink.lookup with parameters of type SnapshotReader

Constructor and Description
LookupDataTableScan(CoreOptions options, SnapshotReader snapshotReader, SnapshotManager snapshotManager, boolean supportStreamingReadOverwrite, DefaultValueAssigner defaultValueAssigner, LookupFileStoreTable.LookupStreamScanMode lookupScanMode)

Uses of SnapshotReader in org.apache.paimon.privilege

Methods in org.apache.paimon.privilege that return SnapshotReader

Modifier and Type	Method and Description
SnapshotReader	PrivilegedFileStoreTable.newSnapshotReader()

Uses of SnapshotReader in org.apache.paimon.table

Methods in org.apache.paimon.table that return SnapshotReader

Modifier and Type	Method and Description
SnapshotReader	DataTable.newSnapshotReader()
SnapshotReader	DelegatedFileStoreTable.newSnapshotReader()

Uses of SnapshotReader in org.apache.paimon.table.source

Fields in org.apache.paimon.table.source declared as SnapshotReader

Modifier and Type	Field and Description
protected SnapshotReader	AbstractDataTableScan.snapshotReader

Constructors in org.apache.paimon.table.source with parameters of type SnapshotReader

Constructor and Description
AbstractDataTableScan(CoreOptions options, SnapshotReader snapshotReader)
DataTableBatchScan(boolean pkTable, CoreOptions options, SnapshotReader snapshotReader, DefaultValueAssigner defaultValueAssigner)
DataTableStreamScan(CoreOptions options, SnapshotReader snapshotReader, SnapshotManager snapshotManager, boolean supportStreamingReadOverwrite, DefaultValueAssigner defaultValueAssigner)

Uses of SnapshotReader in org.apache.paimon.table.source.snapshot

Classes in org.apache.paimon.table.source.snapshot that implement SnapshotReader

Modifier and Type	Class and Description
class	SnapshotReaderImpl Implementation of SnapshotReader.

Methods in org.apache.paimon.table.source.snapshot that return SnapshotReader

Modifier and Type	Method and Description
SnapshotReader	CompactedStartingScanner.configure(SnapshotReader snapshotReader)
SnapshotReader	ContinuousFromSnapshotFullStartingScanner.configure(SnapshotReader snapshotReader)
SnapshotReader	FullCompactedStartingScanner.configure(SnapshotReader snapshotReader)
SnapshotReader	StaticFromTimestampStartingScanner.configure(SnapshotReader snapshotReader)
protected abstract SnapshotReader	ReadPlanStartingScanner.configure(SnapshotReader snapshotReader)
SnapshotReader	StaticFromWatermarkStartingScanner.configure(SnapshotReader snapshotReader)
SnapshotReader	StaticFromTagStartingScanner.configure(SnapshotReader snapshotReader)
SnapshotReader	FileCreationTimeStartingScanner.configure(SnapshotReader snapshotReader)
SnapshotReader	StaticFromSnapshotStartingScanner.configure(SnapshotReader snapshotReader)
SnapshotReader	FullStartingScanner.configure(SnapshotReader snapshotReader)
SnapshotReader	SnapshotReader.withBucket(int bucket)
SnapshotReader	SnapshotReaderImpl.withBucket(int bucket)
SnapshotReader	SnapshotReader.withBucketFilter(Filter<Integer> bucketFilter)
SnapshotReader	SnapshotReaderImpl.withBucketFilter(Filter<Integer> bucketFilter)
SnapshotReader	SnapshotReader.withDataFileNameFilter(Filter<String> fileNameFilter)
SnapshotReader	SnapshotReaderImpl.withDataFileNameFilter(Filter<String> fileNameFilter)
SnapshotReader	SnapshotReader.withFilter(Predicate predicate)
SnapshotReader	SnapshotReaderImpl.withFilter(Predicate predicate)
SnapshotReader	SnapshotReader.withLevelFilter(Filter<Integer> levelFilter)
SnapshotReader	SnapshotReaderImpl.withLevelFilter(Filter<Integer> levelFilter)
SnapshotReader	SnapshotReader.withManifestEntryFilter(Filter<ManifestEntry> filter)
SnapshotReader	SnapshotReaderImpl.withManifestEntryFilter(Filter<ManifestEntry> filter)
SnapshotReader	SnapshotReader.withMetricRegistry(MetricRegistry registry)
SnapshotReader	SnapshotReaderImpl.withMetricRegistry(MetricRegistry registry)
SnapshotReader	SnapshotReader.withMode(ScanMode scanMode)
SnapshotReader	SnapshotReaderImpl.withMode(ScanMode scanMode)
SnapshotReader	SnapshotReader.withPartitionFilter(List<BinaryRow> partitions)
SnapshotReader	SnapshotReaderImpl.withPartitionFilter(List<BinaryRow> partitions)
SnapshotReader	SnapshotReader.withPartitionFilter(Map<String,String> partitionSpec)
SnapshotReader	SnapshotReaderImpl.withPartitionFilter(Map<String,String> partitionSpec)
SnapshotReader	SnapshotReader.withPartitionFilter(Predicate predicate)
SnapshotReader	SnapshotReaderImpl.withPartitionFilter(Predicate predicate)
SnapshotReader	SnapshotReader.withShard(int indexOfThisSubtask, int numberOfParallelSubtasks)
SnapshotReader	SnapshotReaderImpl.withShard(int indexOfThisSubtask, int numberOfParallelSubtasks)
SnapshotReader	SnapshotReader.withSnapshot(long snapshotId)
SnapshotReader	SnapshotReaderImpl.withSnapshot(long snapshotId)
SnapshotReader	SnapshotReader.withSnapshot(Snapshot snapshot)
SnapshotReader	SnapshotReaderImpl.withSnapshot(Snapshot snapshot)

Methods in org.apache.paimon.table.source.snapshot with parameters of type SnapshotReader

Modifier and Type	Method and Description
SnapshotReader	CompactedStartingScanner.configure(SnapshotReader snapshotReader)
SnapshotReader	ContinuousFromSnapshotFullStartingScanner.configure(SnapshotReader snapshotReader)
SnapshotReader	FullCompactedStartingScanner.configure(SnapshotReader snapshotReader)
SnapshotReader	StaticFromTimestampStartingScanner.configure(SnapshotReader snapshotReader)
protected abstract SnapshotReader	ReadPlanStartingScanner.configure(SnapshotReader snapshotReader)
SnapshotReader	StaticFromWatermarkStartingScanner.configure(SnapshotReader snapshotReader)
SnapshotReader	StaticFromTagStartingScanner.configure(SnapshotReader snapshotReader)
SnapshotReader	FileCreationTimeStartingScanner.configure(SnapshotReader snapshotReader)
SnapshotReader	StaticFromSnapshotStartingScanner.configure(SnapshotReader snapshotReader)
SnapshotReader	FullStartingScanner.configure(SnapshotReader snapshotReader)
default SnapshotReader.Plan	FollowUpScanner.getOverwriteChangesPlan(Snapshot snapshot, SnapshotReader snapshotReader)
StartingScanner.Result	StartingScanner.scan(SnapshotReader snapshotReader)
StartingScanner.Result	ContinuousFromTimestampStartingScanner.scan(SnapshotReader snapshotReader)
StartingScanner.Result	IncrementalStartingScanner.scan(SnapshotReader reader)
StartingScanner.Result	IncrementalTimeStampStartingScanner.scan(SnapshotReader reader)
StartingScanner.Result	ContinuousCompactorStartingScanner.scan(SnapshotReader snapshotReader)
StartingScanner.Result	ReadPlanStartingScanner.scan(SnapshotReader snapshotReader)
StartingScanner.Result	ContinuousFromSnapshotStartingScanner.scan(SnapshotReader snapshotReader)
StartingScanner.Result	ContinuousLatestStartingScanner.scan(SnapshotReader snapshotReader)
StartingScanner.Result	IncrementalTagStartingScanner.scan(SnapshotReader reader)
SnapshotReader.Plan	FollowUpScanner.scan(Snapshot snapshot, SnapshotReader snapshotReader)
SnapshotReader.Plan	InputChangelogFollowUpScanner.scan(Snapshot snapshot, SnapshotReader snapshotReader)
SnapshotReader.Plan	CompactionChangelogFollowUpScanner.scan(Snapshot snapshot, SnapshotReader snapshotReader)
SnapshotReader.Plan	AllDeltaFollowUpScanner.scan(Snapshot snapshot, SnapshotReader snapshotReader)
SnapshotReader.Plan	DeltaFollowUpScanner.scan(Snapshot snapshot, SnapshotReader snapshotReader)
List<PartitionEntry>	StartingScanner.scanPartitions(SnapshotReader snapshotReader)
List<PartitionEntry>	ReadPlanStartingScanner.scanPartitions(SnapshotReader snapshotReader)
List<PartitionEntry>	AbstractStartingScanner.scanPartitions(SnapshotReader snapshotReader)

Uses of SnapshotReader in org.apache.paimon.table.system

Methods in org.apache.paimon.table.system that return SnapshotReader

Modifier and Type	Method and Description
SnapshotReader	FileMonitorTable.newSnapshotReader()
SnapshotReader	CompactBucketsTable.newSnapshotReader()
SnapshotReader	AuditLogTable.newSnapshotReader()
SnapshotReader	ReadOptimizedTable.newSnapshotReader()