Modifier and Type | Method and Description |
---|---|
SnapshotManager |
FileStore.snapshotManager() |
Constructor and Description |
---|
LookupDataTableScan(CoreOptions options,
SnapshotReader snapshotReader,
SnapshotManager snapshotManager,
boolean supportStreamingReadOverwrite,
DefaultValueAssigner defaultValueAssigner,
LookupFileStoreTable.LookupStreamScanMode lookupScanMode) |
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) |
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) |
Modifier and Type | Field and Description |
---|---|
protected SnapshotManager |
AbstractFileStoreWrite.snapshotManager |
Modifier and Type | Method and Description |
---|---|
protected static <T> java.util.function.Function<AbstractFileStoreWrite.WriterContainer<T>,Boolean> |
AbstractFileStoreWrite.createConflictAwareWriterCleanChecker(String commitUser,
SnapshotManager snapshotManager) |
Constructor and Description |
---|
AbstractFileStoreScan(ManifestsReader manifestsReader,
SnapshotManager snapshotManager,
SchemaManager schemaManager,
TableSchema schema,
ManifestFile.Factory manifestFileFactory,
Integer parallelism) |
AbstractFileStoreWrite(SnapshotManager snapshotManager,
FileStoreScan scan,
IndexMaintainer.Factory<T> indexFactory,
DeletionVectorsMaintainer.Factory dvMaintainerFactory,
String tableName,
int totalBuckets,
RowType partitionType,
int writerNumberMax,
boolean legacyPartitionName) |
AppendOnlyFileStoreScan(ManifestsReader manifestsReader,
BucketSelectConverter bucketSelectConverter,
SnapshotManager snapshotManager,
SchemaManager schemaManager,
TableSchema schema,
ManifestFile.Factory manifestFileFactory,
Integer scanManifestParallelism,
boolean fileIndexReadEnabled) |
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) |
KeyValueFileStoreScan(ManifestsReader manifestsReader,
BucketSelectConverter bucketSelectConverter,
SnapshotManager snapshotManager,
SchemaManager schemaManager,
TableSchema schema,
KeyValueFieldsExtractor keyValueFieldsExtractor,
ManifestFile.Factory manifestFileFactory,
Integer scanManifestParallelism,
boolean deletionVectorsEnabled,
CoreOptions.MergeEngine mergeEngine,
CoreOptions.ChangelogProducer changelogProducer,
boolean fileIndexReadEnabled) |
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) |
ManifestsReader(RowType partitionType,
SnapshotManager snapshotManager,
ManifestList.Factory manifestListFactory) |
MemoryFileStoreWrite(SnapshotManager snapshotManager,
FileStoreScan scan,
CoreOptions options,
RowType partitionType,
IndexMaintainer.Factory<T> indexFactory,
DeletionVectorsMaintainer.Factory dvMaintainerFactory,
String tableName) |
Modifier and Type | Method and Description |
---|---|
SnapshotManager |
PrivilegedFileStoreTable.snapshotManager() |
SnapshotManager |
PrivilegedFileStore.snapshotManager() |
Constructor and Description |
---|
StatsFileHandler(SnapshotManager snapshotManager,
SchemaManager schemaManager,
StatsFile statsFile) |
Modifier and Type | Method and Description |
---|---|
SnapshotManager |
DataTable.snapshotManager() |
SnapshotManager |
DelegatedFileStoreTable.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) |
Constructor and Description |
---|
DataTableStreamScan(CoreOptions options,
SnapshotReader snapshotReader,
SnapshotManager snapshotManager,
boolean supportStreamingReadOverwrite,
DefaultValueAssigner defaultValueAssigner) |
Modifier and Type | Field and Description |
---|---|
protected SnapshotManager |
AbstractStartingScanner.snapshotManager |
Modifier and Type | Method and Description |
---|---|
SnapshotManager |
SnapshotReader.snapshotManager() |
SnapshotManager |
SnapshotReaderImpl.snapshotManager() |
Modifier and Type | Method and Description |
---|---|
static Snapshot |
TimeTravelUtil.resolveSnapshotFromOptions(CoreOptions options,
SnapshotManager snapshotManager) |
static Snapshot |
StaticFromTimestampStartingScanner.timeTravelToTimestamp(SnapshotManager snapshotManager,
long timestamp) |
static Snapshot |
StaticFromWatermarkStartingScanner.timeTravelToWatermark(SnapshotManager snapshotManager,
long watermark) |
Modifier and Type | Method and Description |
---|---|
SnapshotManager |
FileMonitorTable.snapshotManager() |
SnapshotManager |
CompactBucketsTable.snapshotManager() |
SnapshotManager |
AuditLogTable.snapshotManager() |
SnapshotManager |
ReadOptimizedTable.snapshotManager() |
Modifier and Type | Method and Description |
---|---|
static TagAutoCreation |
TagAutoCreation.create(CoreOptions options,
SnapshotManager snapshotManager,
TagManager tagManager,
TagDeletion tagDeletion,
List<TagCallback> callbacks) |
static TagAutoManager |
TagAutoManager.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) |
Modifier and Type | Method and Description |
---|---|
SnapshotManager |
SnapshotManager.copyWithBranch(String branchName) |
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) |
Constructor and Description |
---|
BranchManager(FileIO fileIO,
Path path,
SnapshotManager snapshotManager,
TagManager tagManager,
SchemaManager schemaManager) |
NextSnapshotFetcher(SnapshotManager snapshotManager,
boolean changelogDecoupled) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.