Uses of Interface
org.apache.paimon.operation.FileStoreScan

Packages that use FileStoreScan

Package	Description
org.apache.paimon
org.apache.paimon.operation
org.apache.paimon.partition
org.apache.paimon.privilege
org.apache.paimon.table.source.snapshot

Uses of FileStoreScan in org.apache.paimon

Methods in org.apache.paimon that return FileStoreScan

Modifier and Type	Method and Description
FileStoreScan	FileStore.newScan()

Uses of FileStoreScan in org.apache.paimon.operation

Classes in org.apache.paimon.operation that implement FileStoreScan

Modifier and Type	Class and Description
class	AbstractFileStoreScan Default implementation of FileStoreScan.
class	AppendOnlyFileStoreScan FileStoreScan for AppendOnlyFileStore.
class	KeyValueFileStoreScan FileStoreScan for KeyValueFileStore.

Methods in org.apache.paimon.operation that return FileStoreScan

Modifier and Type	Method and Description
FileStoreScan	FileStoreScan.dropStats()
FileStoreScan	AbstractFileStoreScan.dropStats()
FileStoreScan	FileStoreScan.enableValueFilter()
FileStoreScan	AbstractFileStoreScan.enableValueFilter()
FileStoreScan	KeyValueFileStoreScan.enableValueFilter()
FileStoreScan	FileStoreScan.withBucket(int bucket)
FileStoreScan	AbstractFileStoreScan.withBucket(int bucket)
FileStoreScan	FileStoreScan.withBucketFilter(Filter<Integer> bucketFilter)
FileStoreScan	AbstractFileStoreScan.withBucketFilter(Filter<Integer> bucketFilter)
FileStoreScan	FileStoreScan.withDataFileNameFilter(Filter<String> fileNameFilter)
FileStoreScan	AbstractFileStoreScan.withDataFileNameFilter(Filter<String> fileNameFilter)
FileStoreScan	FileStoreScan.withKind(ScanMode scanMode)
FileStoreScan	AbstractFileStoreScan.withKind(ScanMode scanMode)
FileStoreScan	FileStoreScan.withLevelFilter(Filter<Integer> levelFilter)
FileStoreScan	AbstractFileStoreScan.withLevelFilter(Filter<Integer> levelFilter)
FileStoreScan	FileStoreScan.withManifestCacheFilter(ManifestCacheFilter manifestFilter)
FileStoreScan	AbstractFileStoreScan.withManifestCacheFilter(ManifestCacheFilter manifestFilter)
FileStoreScan	FileStoreScan.withManifestEntryFilter(Filter<ManifestEntry> filter)
FileStoreScan	AbstractFileStoreScan.withManifestEntryFilter(Filter<ManifestEntry> filter)
FileStoreScan	FileStoreScan.withMetrics(ScanMetrics metrics)
FileStoreScan	AbstractFileStoreScan.withMetrics(ScanMetrics metrics)
FileStoreScan	FileStoreScan.withPartitionBucket(BinaryRow partition, int bucket)
FileStoreScan	AbstractFileStoreScan.withPartitionBucket(BinaryRow partition, int bucket)
FileStoreScan	FileStoreScan.withPartitionFilter(List<BinaryRow> partitions)
FileStoreScan	AbstractFileStoreScan.withPartitionFilter(List<BinaryRow> partitions)
FileStoreScan	FileStoreScan.withPartitionFilter(PartitionPredicate predicate)
FileStoreScan	AbstractFileStoreScan.withPartitionFilter(PartitionPredicate predicate)
FileStoreScan	FileStoreScan.withPartitionFilter(Predicate predicate)
FileStoreScan	AbstractFileStoreScan.withPartitionFilter(Predicate predicate)
FileStoreScan	FileStoreScan.withSnapshot(long snapshotId)
FileStoreScan	AbstractFileStoreScan.withSnapshot(long snapshotId)
FileStoreScan	FileStoreScan.withSnapshot(Snapshot snapshot)
FileStoreScan	AbstractFileStoreScan.withSnapshot(Snapshot snapshot)
FileStoreScan	FileStoreScan.withTotalAwareBucketFilter(BiFilter<Integer,Integer> bucketFilter)
FileStoreScan	AbstractFileStoreScan.withTotalAwareBucketFilter(BiFilter<Integer,Integer> totalAwareBucketFilter)

Constructors in org.apache.paimon.operation with parameters of type FileStoreScan

Constructor and Description
AbstractFileStoreWrite(SnapshotManager snapshotManager, FileStoreScan scan, IndexMaintainer.Factory<T> indexFactory, DeletionVectorsMaintainer.Factory dvMaintainerFactory, String tableName, int totalBuckets, RowType partitionType, int writerNumberMax, boolean legacyPartitionName)
AppendOnlyFileStoreWrite(FileIO fileIO, RawFileSplitRead read, long schemaId, RowType rowType, RowType partitionType, FileStorePathFactory pathFactory, SnapshotManager snapshotManager, FileStoreScan scan, CoreOptions options, DeletionVectorsMaintainer.Factory dvMaintainerFactory, String tableName)
AppendOnlyFixedBucketFileStoreWrite(FileIO fileIO, RawFileSplitRead read, long schemaId, String commitUser, RowType rowType, RowType partitionType, FileStorePathFactory pathFactory, SnapshotManager snapshotManager, FileStoreScan scan, CoreOptions options, DeletionVectorsMaintainer.Factory dvMaintainerFactory, String tableName)
AppendOnlyUnawareBucketFileStoreWrite(FileIO fileIO, RawFileSplitRead read, long schemaId, RowType rowType, RowType partitionType, FileStorePathFactory pathFactory, SnapshotManager snapshotManager, FileStoreScan scan, CoreOptions options, DeletionVectorsMaintainer.Factory dvMaintainerFactory, String tableName)
FileStoreCommitImpl(FileIO fileIO, SchemaManager schemaManager, String tableName, String commitUser, RowType partitionType, String partitionDefaultName, FileStorePathFactory pathFactory, SnapshotManager snapshotManager, ManifestFile.Factory manifestFileFactory, ManifestList.Factory manifestListFactory, IndexManifestFile.Factory indexManifestFileFactory, FileStoreScan scan, int numBucket, MemorySize manifestTargetSize, MemorySize manifestFullCompactionSize, int manifestMergeMinCount, boolean dynamicPartitionOverwrite, Comparator<InternalRow> keyComparator, String branchName, StatsFileHandler statsFileHandler, BucketMode bucketMode, Integer manifestReadParallelism, List<CommitCallback> commitCallbacks, int commitMaxRetries)
KeyValueFileStoreWrite(FileIO fileIO, SchemaManager schemaManager, TableSchema schema, String commitUser, RowType partitionType, RowType keyType, RowType valueType, java.util.function.Supplier<Comparator<InternalRow>> keyComparatorSupplier, java.util.function.Supplier<FieldsComparator> udsComparatorSupplier, java.util.function.Supplier<RecordEqualiser> logDedupEqualSupplier, MergeFunctionFactory<KeyValue> mfFactory, FileStorePathFactory pathFactory, Map<String,FileStorePathFactory> format2PathFactory, SnapshotManager snapshotManager, FileStoreScan scan, IndexMaintainer.Factory<KeyValue> indexFactory, DeletionVectorsMaintainer.Factory deletionVectorsMaintainerFactory, CoreOptions options, KeyValueFieldsExtractor extractor, String tableName)
MemoryFileStoreWrite(SnapshotManager snapshotManager, FileStoreScan scan, CoreOptions options, RowType partitionType, IndexMaintainer.Factory<T> indexFactory, DeletionVectorsMaintainer.Factory dvMaintainerFactory, String tableName)
PartitionExpire(java.time.Duration expirationTime, java.time.Duration checkInterval, PartitionExpireStrategy strategy, FileStoreScan scan, FileStoreCommit commit, MetastoreClient metastoreClient)
PartitionExpire(java.time.Duration expirationTime, java.time.Duration checkInterval, PartitionExpireStrategy strategy, FileStoreScan scan, FileStoreCommit commit, MetastoreClient metastoreClient, boolean endInputCheckPartitionExpire)

Uses of FileStoreScan in org.apache.paimon.partition

Methods in org.apache.paimon.partition with parameters of type FileStoreScan

Modifier and Type	Method and Description
List<PartitionEntry>	PartitionValuesTimeExpireStrategy.selectExpiredPartitions(FileStoreScan scan, java.time.LocalDateTime expirationTime)
List<PartitionEntry>	PartitionUpdateTimeExpireStrategy.selectExpiredPartitions(FileStoreScan scan, java.time.LocalDateTime expirationTime)
abstract List<PartitionEntry>	PartitionExpireStrategy.selectExpiredPartitions(FileStoreScan scan, java.time.LocalDateTime expirationTime)

Uses of FileStoreScan in org.apache.paimon.privilege

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

Modifier and Type	Method and Description
FileStoreScan	PrivilegedFileStore.newScan()

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

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

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)

Constructor parameters in org.apache.paimon.table.source.snapshot with type arguments of type FileStoreScan

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)