org.apache.paimon.table.source.snapshot

Interface SnapshotReader

All Known Implementing Classes:

SnapshotReaderImpl

public interface SnapshotReader

Read splits from specified Snapshot with given configuration.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	SnapshotReader.Plan Result plan of this scan.

Method Summary

Modifier and Type	Method and Description
List<BucketEntry>	bucketEntries()
ConsumerManager	consumerManager()
SnapshotReader	dropStats()
SnapshotReader	enableValueFilter()
ManifestsReader	manifestsReader()
Integer	parallelism()
List<PartitionEntry>	partitionEntries()
List<BinaryRow>	partitions() List partitions.
FileStorePathFactory	pathFactory()
SnapshotReader.Plan	read() Get splits plan from snapshot.
SnapshotReader.Plan	readChanges() Get splits plan from file changes.
Iterator<ManifestEntry>	readFileIterator()
SnapshotReader.Plan	readIncrementalDiff(Snapshot before)
List<ManifestEntry>	readManifest(ManifestFileMeta manifest)
SnapshotManager	snapshotManager()
SplitGenerator	splitGenerator()
SnapshotReader	withBucket(int bucket)
SnapshotReader	withBucketFilter(Filter<Integer> bucketFilter)
SnapshotReader	withDataFileNameFilter(Filter<String> fileNameFilter)
SnapshotReader	withFilter(Predicate predicate)
SnapshotReader	withLevelFilter(Filter<Integer> levelFilter)
SnapshotReader	withManifestEntryFilter(Filter<ManifestEntry> filter)
SnapshotReader	withMetricRegistry(MetricRegistry registry)
SnapshotReader	withMode(ScanMode scanMode)
SnapshotReader	withPartitionFilter(List<BinaryRow> partitions)
SnapshotReader	withPartitionFilter(Map<String,String> partitionSpec)
SnapshotReader	withPartitionFilter(Predicate predicate)
SnapshotReader	withShard(int indexOfThisSubtask, int numberOfParallelSubtasks)
SnapshotReader	withSnapshot(long snapshotId)
SnapshotReader	withSnapshot(Snapshot snapshot)

Method Detail

parallelism

@Nullable
Integer parallelism()

snapshotManager

SnapshotManager snapshotManager()

manifestsReader

ManifestsReader manifestsReader()

readManifest

List<ManifestEntry> readManifest(ManifestFileMeta manifest)

consumerManager

ConsumerManager consumerManager()

splitGenerator

SplitGenerator splitGenerator()

pathFactory

FileStorePathFactory pathFactory()

withSnapshot

SnapshotReader withSnapshot(long snapshotId)

withSnapshot

SnapshotReader withSnapshot(Snapshot snapshot)

withFilter

SnapshotReader withFilter(Predicate predicate)

withPartitionFilter

SnapshotReader withPartitionFilter(Map<String,String> partitionSpec)

withPartitionFilter

SnapshotReader withPartitionFilter(Predicate predicate)

withPartitionFilter

SnapshotReader withPartitionFilter(List<BinaryRow> partitions)

withMode

SnapshotReader withMode(ScanMode scanMode)

withLevelFilter

SnapshotReader withLevelFilter(Filter<Integer> levelFilter)

enableValueFilter

SnapshotReader enableValueFilter()

withManifestEntryFilter

SnapshotReader withManifestEntryFilter(Filter<ManifestEntry> filter)

withBucket

SnapshotReader withBucket(int bucket)

withBucketFilter

SnapshotReader withBucketFilter(Filter<Integer> bucketFilter)

withDataFileNameFilter

SnapshotReader withDataFileNameFilter(Filter<String> fileNameFilter)

dropStats

SnapshotReader dropStats()

withShard

SnapshotReader withShard(int indexOfThisSubtask,
                         int numberOfParallelSubtasks)

withMetricRegistry

SnapshotReader withMetricRegistry(MetricRegistry registry)

read

SnapshotReader.Plan read()

Get splits plan from snapshot.

readChanges

SnapshotReader.Plan readChanges()

Get splits plan from file changes.

readIncrementalDiff

SnapshotReader.Plan readIncrementalDiff(Snapshot before)

partitions

List<BinaryRow> partitions()

List partitions.

partitionEntries

List<PartitionEntry> partitionEntries()

bucketEntries

List<BucketEntry> bucketEntries()

readFileIterator

Iterator<ManifestEntry> readFileIterator()