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

Packages that use SnapshotReader

Package	Description
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.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	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
default SnapshotReader.Plan	FollowUpScanner.getOverwriteChangesPlan(Snapshot snapshot, SnapshotReader snapshotReader)
StartingScanner.Result	ContinuousLatestStartingScanner.scan(SnapshotReader snapshotReader)
StartingScanner.Result	IncrementalTagStartingScanner.scan(SnapshotReader reader)
StartingScanner.Result	ContinuousFromSnapshotStartingScanner.scan(SnapshotReader snapshotReader)
StartingScanner.Result	CompactedStartingScanner.scan(SnapshotReader snapshotReader)
StartingScanner.Result	StaticFromSnapshotStartingScanner.scan(SnapshotReader snapshotReader)
StartingScanner.Result	StartingScanner.scan(SnapshotReader snapshotReader)
StartingScanner.Result	ContinuousCompactorStartingScanner.scan(SnapshotReader snapshotReader)
StartingScanner.Result	FullStartingScanner.scan(SnapshotReader snapshotReader)
StartingScanner.Result	FullCompactedStartingScanner.scan(SnapshotReader snapshotReader)
StartingScanner.Result	StaticFromTimestampStartingScanner.scan(SnapshotReader snapshotReader)
StartingScanner.Result	StaticFromWatermarkStartingScanner.scan(SnapshotReader snapshotReader)
StartingScanner.Result	StaticFromTagStartingScanner.scan(SnapshotReader snapshotReader)
StartingScanner.Result	FileCreationTimeStartingScanner.scan(SnapshotReader snapshotReader)
StartingScanner.Result	ContinuousFromSnapshotFullStartingScanner.scan(SnapshotReader snapshotReader)
StartingScanner.Result	IncrementalTimeStampStartingScanner.scan(SnapshotReader reader)
StartingScanner.Result	IncrementalStartingScanner.scan(SnapshotReader reader)
StartingScanner.Result	ContinuousFromTimestampStartingScanner.scan(SnapshotReader snapshotReader)
SnapshotReader.Plan	AllDeltaFollowUpScanner.scan(Snapshot snapshot, SnapshotReader snapshotReader)
SnapshotReader.Plan	DeltaFollowUpScanner.scan(Snapshot snapshot, SnapshotReader snapshotReader)
SnapshotReader.Plan	CompactionChangelogFollowUpScanner.scan(Snapshot snapshot, SnapshotReader snapshotReader)
SnapshotReader.Plan	InputChangelogFollowUpScanner.scan(Snapshot snapshot, SnapshotReader snapshotReader)
SnapshotReader.Plan	FollowUpScanner.scan(Snapshot snapshot, 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()