Struct iceberg_rust::table::Table

pub struct Table { /* private fields */ }

Iceberg table

Implementations

impl Table

Public interface of the table.

pub fn builder() -> CreateTableBuilder

Build a new table

pub async fn new( identifier: Identifier, catalog: Arc<dyn Catalog>, metadata: TableMetadata, ) -> Result<Self, Error>

Create a new metastore Table

pub fn identifier(&self) -> &Identifier

Get the table identifier in the catalog. Returns None of it is a filesystem table.

pub fn catalog(&self) -> Arc<dyn Catalog>

Get the catalog associated to the table. Returns None if the table is a filesystem table

pub fn object_store(&self) -> Arc<dyn ObjectStore>

Get the object_store associated to the table

pub fn current_schema(&self, branch: Option<&str>) -> Result<&Schema, Error>

Get the schema of the table for a given branch. Defaults to main.

pub fn metadata(&self) -> &TableMetadata

Get the metadata of the table

pub fn into_metadata(self) -> TableMetadata

Get the metadata of the table

pub async fn manifests( &self, start: Option<i64>, end: Option<i64>, ) -> Result<Vec<ManifestListEntry>, Error>

Get list of current manifest files within an optional snapshot range. The start snapshot is excluded from the range.

pub async fn datafiles( &self, manifests: &[ManifestListEntry], filter: Option<Vec<bool>>, ) -> Result<Vec<ManifestEntry>, Error>

Get list of datafiles corresponding to the given manifest files

pub async fn datafiles_contains_delete( &self, start: Option<i64>, end: Option<i64>, ) -> Result<bool, Error>

Check if datafiles contain deletes

pub fn new_transaction(&mut self, branch: Option<&str>) -> TableTransaction<'_>

Create a new transaction for this table

Trait Implementations

impl Debug for Table

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

Formats the value using the given formatter.