Struct TagManager 

pub struct TagManager { /* private fields */ }

Manager for tag files using unified FileIO.

Tags are named snapshots stored as JSON files at {table_path}/tag/tag-{name}. The tag file format is identical to a Snapshot JSON file.

Reference: org.apache.paimon.utils.TagManager

Implementations

impl TagManager

pub fn new(file_io: FileIO, table_path: String) -> Self

pub fn tag_directory(&self) -> String

Path to the tag directory (e.g. table_path/tag).

pub fn with_branch(&self, branch_name: &str) -> Self

Create a TagManager for a branch of this table.

pub fn tag_path(&self, tag_name: &str) -> String

Path to the tag file for the given name (e.g. tag/tag-my_tag).

pub async fn tag_exists(&self, tag_name: &str) -> Result<bool>

Check if a tag exists.

pub async fn get(&self, tag_name: &str) -> Result<Option<Snapshot>>

Get the snapshot for a tag, or None if the tag file does not exist.

Tag files are JSON with the same schema as Snapshot. Reads directly and catches NotFound to avoid a separate exists() IO round-trip.

pub async fn list_all_names(&self) -> Result<Vec<String>>

List all tag names sorted ascending. Returns an empty vector when the tag directory does not exist.

pub async fn create(&self, tag_name: &str, snapshot: &Snapshot) -> Result<()>

Create a tag by writing the snapshot JSON to the tag path.

pub async fn delete(&self, tag_name: &str) -> Result<()>

Delete a tag file.

pub async fn list_all(&self) -> Result<Vec<(String, Snapshot)>>

List all tags as (name, snapshot) pairs sorted by name ascending.

Trait Implementations

impl Clone for TagManager

fn clone(&self) -> TagManager

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for TagManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.