public class SnapshotReaderImpl extends Object implements SnapshotReader
SnapshotReader
.SnapshotReader.Plan
Constructor and Description |
---|
SnapshotReaderImpl(FileStoreScan scan,
TableSchema tableSchema,
CoreOptions options,
SnapshotManager snapshotManager,
SplitGenerator splitGenerator,
java.util.function.BiConsumer<FileStoreScan,Predicate> nonPartitionFilterConsumer,
DefaultValueAssigner defaultValueAssigner,
FileStorePathFactory pathFactory,
String tableName,
IndexFileHandler indexFileHandler) |
public SnapshotReaderImpl(FileStoreScan scan, TableSchema tableSchema, CoreOptions options, SnapshotManager snapshotManager, SplitGenerator splitGenerator, java.util.function.BiConsumer<FileStoreScan,Predicate> nonPartitionFilterConsumer, DefaultValueAssigner defaultValueAssigner, FileStorePathFactory pathFactory, String tableName, IndexFileHandler indexFileHandler)
public Integer parallelism()
parallelism
in interface SnapshotReader
public SnapshotManager snapshotManager()
snapshotManager
in interface SnapshotReader
public ManifestsReader manifestsReader()
manifestsReader
in interface SnapshotReader
public List<ManifestEntry> readManifest(ManifestFileMeta manifest)
readManifest
in interface SnapshotReader
public ConsumerManager consumerManager()
consumerManager
in interface SnapshotReader
public SplitGenerator splitGenerator()
splitGenerator
in interface SnapshotReader
public FileStorePathFactory pathFactory()
pathFactory
in interface SnapshotReader
public SnapshotReader withSnapshot(long snapshotId)
withSnapshot
in interface SnapshotReader
public SnapshotReader withSnapshot(Snapshot snapshot)
withSnapshot
in interface SnapshotReader
public SnapshotReader withPartitionFilter(Map<String,String> partitionSpec)
withPartitionFilter
in interface SnapshotReader
public SnapshotReader withPartitionFilter(Predicate predicate)
withPartitionFilter
in interface SnapshotReader
public SnapshotReader withPartitionFilter(List<BinaryRow> partitions)
withPartitionFilter
in interface SnapshotReader
public SnapshotReader withFilter(Predicate predicate)
withFilter
in interface SnapshotReader
public SnapshotReader withMode(ScanMode scanMode)
withMode
in interface SnapshotReader
public SnapshotReader withLevelFilter(Filter<Integer> levelFilter)
withLevelFilter
in interface SnapshotReader
public SnapshotReader withManifestEntryFilter(Filter<ManifestEntry> filter)
withManifestEntryFilter
in interface SnapshotReader
public SnapshotReader withBucket(int bucket)
withBucket
in interface SnapshotReader
public SnapshotReader withBucketFilter(Filter<Integer> bucketFilter)
withBucketFilter
in interface SnapshotReader
public SnapshotReader withMetricRegistry(MetricRegistry registry)
withMetricRegistry
in interface SnapshotReader
public SnapshotReader withDataFileNameFilter(Filter<String> fileNameFilter)
withDataFileNameFilter
in interface SnapshotReader
public SnapshotReader withShard(int indexOfThisSubtask, int numberOfParallelSubtasks)
withShard
in interface SnapshotReader
public SnapshotReader.Plan read()
FileKind.ADD
files.read
in interface SnapshotReader
public List<BinaryRow> partitions()
SnapshotReader
partitions
in interface SnapshotReader
public List<PartitionEntry> partitionEntries()
partitionEntries
in interface SnapshotReader
public List<BucketEntry> bucketEntries()
bucketEntries
in interface SnapshotReader
public Iterator<ManifestEntry> readFileIterator()
readFileIterator
in interface SnapshotReader
public SnapshotReader.Plan readChanges()
SnapshotReader
readChanges
in interface SnapshotReader
public SnapshotReader.Plan readIncrementalDiff(Snapshot before)
readIncrementalDiff
in interface SnapshotReader
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.