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 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.

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.