Struct iceberg_rust::table::Table

pub struct Table { /* private fields */ }

Iceberg table

Implementations

impl Table

pub async fn files(
    &self,
    filter: Option<Vec<bool>>
) -> Result<Vec<ManifestEntry>>

Get the data_files associated to a table. The files are returned based on the list of manifest files associated to that table. The included manifest files can be filtered based on an filter vector. The filter vector has the length equal to the number of manifest files and contains a true entry everywhere the manifest file is to be included in the output.

impl Table

Public interface of the table.

pub async fn new_metastore_table(
    identifier: Identifier,
    catalog: Arc<dyn Catalog>,
    metadata: TableMetadata,
    metadata_location: &str
) -> Result<Self>

Create a new metastore Table

pub async fn load_file_system_table(
    location: &str,
    object_store: &Arc<dyn ObjectStore>
) -> Result<Self>

Load a filesystem table from an objectstore

pub fn identifier(&self) -> Option<&Identifier>

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

pub fn catalog(&self) -> Option<&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 schema(&self) -> &StructType

Get the metadata of the table

pub fn metadata(&self) -> &TableMetadata

Get the metadata of the table

pub fn metadata_location(&self) -> &str

Get the location of the current metadata file

pub fn manifests(&self) -> &[ManifestFile]

Get the location of the current metadata file

pub fn new_transaction(&mut self) -> TableTransaction<'_>

Create a new transaction for this table