Uses of Class
org.apache.paimon.utils.SnapshotManager

Packages that use SnapshotManager

Package	Description
org.apache.paimon
org.apache.paimon.flink.sink
org.apache.paimon.index
org.apache.paimon.operation
org.apache.paimon.privilege
org.apache.paimon.stats
org.apache.paimon.table
org.apache.paimon.table.source
org.apache.paimon.table.source.snapshot
org.apache.paimon.table.system
org.apache.paimon.tag
org.apache.paimon.utils

Uses of SnapshotManager in org.apache.paimon

Methods in org.apache.paimon that return SnapshotManager

Modifier and Type	Method and Description
SnapshotManager	FileStore.snapshotManager()

Uses of SnapshotManager in org.apache.paimon.flink.sink

Constructor parameters in org.apache.paimon.flink.sink with type arguments of type SnapshotManager

Constructor and Description
AutoTagForSavepointCommitterOperator(CommitterOperator<CommitT,GlobalCommitT> commitOperator, SerializableSupplier<SnapshotManager> snapshotManagerFactory, SerializableSupplier<TagManager> tagManagerFactory, SerializableSupplier<TagDeletion> tagDeletionFactory, SerializableSupplier<List<TagCallback>> callbacksSupplier, java.time.Duration tagTimeRetained)

Uses of SnapshotManager in org.apache.paimon.index

Constructors in org.apache.paimon.index with parameters of type SnapshotManager

Constructor and Description
HashBucketAssigner(SnapshotManager snapshotManager, String commitUser, IndexFileHandler indexFileHandler, int numChannels, int numAssigners, int assignId, long targetBucketRowNumber)
IndexFileHandler(SnapshotManager snapshotManager, PathFactory pathFactory, IndexManifestFile indexManifestFile, HashIndexFile hashIndex, DeletionVectorsIndexFile deletionVectorsIndex)

Uses of SnapshotManager in org.apache.paimon.operation

Fields in org.apache.paimon.operation declared as SnapshotManager

Modifier and Type	Field and Description
protected SnapshotManager	AbstractFileStoreWrite.snapshotManager

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

Constructor and Description
AbstractFileStoreScan(RowType partitionType, ScanBucketFilter bucketKeyFilter, SnapshotManager snapshotManager, SchemaManager schemaManager, TableSchema schema, ManifestFile.Factory manifestFileFactory, ManifestList.Factory manifestListFactory, int numOfBuckets, boolean checkNumOfBuckets, Integer scanManifestParallelism)
AbstractFileStoreWrite(String commitUser, SnapshotManager snapshotManager, FileStoreScan scan, IndexMaintainer.Factory<T> indexFactory, DeletionVectorsMaintainer.Factory dvMaintainerFactory, String tableName, int writerNumberMax)
AppendOnlyFileStoreScan(RowType partitionType, ScanBucketFilter bucketFilter, SnapshotManager snapshotManager, SchemaManager schemaManager, TableSchema schema, ManifestFile.Factory manifestFileFactory, ManifestList.Factory manifestListFactory, int numOfBuckets, boolean checkNumOfBuckets, Integer scanManifestParallelism, boolean fileIndexReadEnabled)
AppendOnlyFileStoreWrite(FileIO fileIO, RawFileSplitRead read, long schemaId, String commitUser, RowType rowType, FileStorePathFactory pathFactory, SnapshotManager snapshotManager, FileStoreScan scan, CoreOptions options, BucketMode bucketMode, DeletionVectorsMaintainer.Factory dvMaintainerFactory, String tableName)
FileStoreCommitImpl(FileIO fileIO, SchemaManager schemaManager, 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)
KeyValueFileStoreScan(RowType partitionType, ScanBucketFilter bucketFilter, SnapshotManager snapshotManager, SchemaManager schemaManager, TableSchema schema, KeyValueFieldsExtractor keyValueFieldsExtractor, ManifestFile.Factory manifestFileFactory, ManifestList.Factory manifestListFactory, int numOfBuckets, boolean checkNumOfBuckets, Integer scanManifestParallelism, boolean deletionVectorsEnabled, CoreOptions.MergeEngine mergeEngine, CoreOptions.ChangelogProducer changelogProducer)
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(String commitUser, SnapshotManager snapshotManager, FileStoreScan scan, CoreOptions options, IndexMaintainer.Factory<T> indexFactory, DeletionVectorsMaintainer.Factory dvMaintainerFactory, String tableName)

Uses of SnapshotManager in org.apache.paimon.privilege

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

Modifier and Type	Method and Description
SnapshotManager	PrivilegedFileStore.snapshotManager()

Uses of SnapshotManager in org.apache.paimon.stats

Constructors in org.apache.paimon.stats with parameters of type SnapshotManager

Constructor and Description
StatsFileHandler(SnapshotManager snapshotManager, SchemaManager schemaManager, StatsFile statsFile)

Uses of SnapshotManager in org.apache.paimon.table

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

Modifier and Type	Method and Description
SnapshotManager	DataTable.snapshotManager()
SnapshotManager	DelegatedFileStoreTable.snapshotManager()

Constructors in org.apache.paimon.table with parameters of type SnapshotManager

Constructor and Description
ExpireChangelogImpl(SnapshotManager snapshotManager, TagManager tagManager, ChangelogDeletion changelogDeletion)
ExpireSnapshotsImpl(SnapshotManager snapshotManager, SnapshotDeletion snapshotDeletion, TagManager tagManager)
RollbackHelper(SnapshotManager snapshotManager, TagManager tagManager, FileIO fileIO, SnapshotDeletion snapshotDeletion, ChangelogDeletion changelogDeletion, TagDeletion tagDeletion)

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

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

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

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

Fields in org.apache.paimon.table.source.snapshot declared as SnapshotManager

Modifier and Type	Field and Description
protected SnapshotManager	AbstractStartingScanner.snapshotManager

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

Modifier and Type	Method and Description
SnapshotManager	SnapshotReader.snapshotManager()
SnapshotManager	SnapshotReaderImpl.snapshotManager()

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

Modifier and Type	Method and Description
static Snapshot	StaticFromTimestampStartingScanner.timeTravelToTimestamp(SnapshotManager snapshotManager, long timestamp)
static Snapshot	StaticFromWatermarkStartingScanner.timeTravelToWatermark(SnapshotManager snapshotManager, long watermark)

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

Constructor and Description
CompactedStartingScanner(SnapshotManager snapshotManager)
ContinuousCompactorStartingScanner(SnapshotManager snapshotManager)
ContinuousFromSnapshotFullStartingScanner(SnapshotManager snapshotManager, long snapshotId)
ContinuousFromSnapshotStartingScanner(SnapshotManager snapshotManager, long snapshotId, boolean changelogDecoupled)
ContinuousFromTimestampStartingScanner(SnapshotManager snapshotManager, long startupMillis, boolean changelogDecoupled)
ContinuousLatestStartingScanner(SnapshotManager snapshotManager)
FileCreationTimeStartingScanner(SnapshotManager snapshotManager, long startupMillis)
FullCompactedStartingScanner(SnapshotManager snapshotManager, int deltaCommits)
FullStartingScanner(SnapshotManager snapshotManager)
IncrementalStartingScanner(SnapshotManager snapshotManager, long start, long end, ScanMode scanMode)
IncrementalTagStartingScanner(SnapshotManager snapshotManager, String start, String end)
IncrementalTimeStampStartingScanner(SnapshotManager snapshotManager, long startTimestamp, long endTimestamp, ScanMode scanMode)
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)
StaticFromSnapshotStartingScanner(SnapshotManager snapshotManager, long snapshotId)
StaticFromTagStartingScanner(SnapshotManager snapshotManager, String tagName)
StaticFromTimestampStartingScanner(SnapshotManager snapshotManager, long startupMillis)
StaticFromWatermarkStartingScanner(SnapshotManager snapshotManager, long watermark)

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

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

Modifier and Type	Method and Description
SnapshotManager	FileMonitorTable.snapshotManager()
SnapshotManager	CompactBucketsTable.snapshotManager()
SnapshotManager	AuditLogTable.snapshotManager()
SnapshotManager	ReadOptimizedTable.snapshotManager()

Uses of SnapshotManager in org.apache.paimon.tag

Methods in org.apache.paimon.tag with parameters of type SnapshotManager

Modifier and Type	Method and Description
static TagAutoManager	TagAutoManager.create(CoreOptions options, SnapshotManager snapshotManager, TagManager tagManager, TagDeletion tagDeletion, List<TagCallback> callbacks)
static TagAutoCreation	TagAutoCreation.create(CoreOptions options, SnapshotManager snapshotManager, TagManager tagManager, TagDeletion tagDeletion, List<TagCallback> callbacks)
static TagTimeExpire	TagTimeExpire.create(SnapshotManager snapshotManager, TagManager tagManager, TagDeletion tagDeletion, List<TagCallback> callbacks)

Uses of SnapshotManager in org.apache.paimon.utils

Methods in org.apache.paimon.utils that return SnapshotManager

Modifier and Type	Method and Description
SnapshotManager	SnapshotManager.copyWithBranch(String branchName)

Methods in org.apache.paimon.utils with parameters of type SnapshotManager

Modifier and Type	Method and Description
void	TagManager.deleteAllTagsOfOneSnapshot(List<String> tagNames, TagDeletion tagDeletion, SnapshotManager snapshotManager) Make sure the tagNames are ALL tags of one snapshot.
void	TagManager.deleteTag(String tagName, TagDeletion tagDeletion, SnapshotManager snapshotManager, List<TagCallback> callbacks)

Constructors in org.apache.paimon.utils with parameters of type SnapshotManager

Constructor and Description
BranchManager(FileIO fileIO, Path path, SnapshotManager snapshotManager, TagManager tagManager, SchemaManager schemaManager)
NextSnapshotFetcher(SnapshotManager snapshotManager, boolean changelogDecoupled)