Modifier and Type | Method and Description |
---|---|
List<TagCallback> |
FileStore.createTagCallbacks() |
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) |
Modifier and Type | Class and Description |
---|---|
class |
AddPartitionTagCallback
A
TagCallback to add newly created partitions to metastore. |
Modifier and Type | Method and Description |
---|---|
List<TagCallback> |
PrivilegedFileStore.createTagCallbacks() |
Modifier and Type | Method and Description |
---|---|
static List<TagCallback> |
CallbackUtils.loadTagCallbacks(CoreOptions coreOptions) |
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) |
Modifier and Type | Method and Description |
---|---|
void |
TagManager.createTag(Snapshot snapshot,
String tagName,
java.time.Duration timeRetained,
List<TagCallback> callbacks)
Create a tag from given snapshot and save it in the storage.
|
void |
TagManager.deleteTag(String tagName,
TagDeletion tagDeletion,
SnapshotManager snapshotManager,
List<TagCallback> callbacks) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.