Struct Table 

pub struct Table { /* private fields */ }

A table at one committed version. Cheap to clone; call Table::refresh to see newer commits.

Operations that commit (Table::append, Table::maintain) return the new version and leave self unchanged.

Implementations

impl Table

pub async fn append( &self, batches: &[RecordBatch], opts: AppendOptions, ) -> Result<(Table, AppendResult)>

Appends Arrow data as one commit. Rows are aligned to the table schema, sorted by (series_key…, time), and written to one file per time partition. Returns the new table version.

impl Table

pub async fn maintain( &self, opts: MaintainOptions, ) -> Result<(Table, MaintainReport)>

Runs maintenance: retention, then compaction, then snapshot expiry and file cleanup. Returns the new table version.

impl Table

pub fn lake(&self) -> &Lake

The lake this table belongs to.

pub fn name(&self) -> &TableName

The table’s name.

pub fn location(&self) -> &str

The table’s root URI (<warehouse>/<namespace>/<table>).

pub fn version(&self) -> u64

The metadata version (v<N>.metadata.json) this handle reads.

pub fn metadata(&self) -> &TableMetadata

The Iceberg metadata of this version.

pub fn contract(&self) -> &Contract

The Timelake contract (time column, series key, layout and maintenance policy).

pub fn schema(&self) -> SchemaRef

Arrow schema of the table (fields carry Iceberg field ids as PARQUET:field_id metadata).

pub async fn refresh(&self) -> Result<Table>

Loads the latest committed version.

pub fn current_snapshot(&self) -> Option<&SnapshotRef>

The current snapshot, if anything was ever committed.

pub fn last_value_index(&self) -> Option<String>

Location of the last-value index for the current snapshot, if the table has one.

pub async fn manifests(&self) -> Result<Arc<Vec<ManifestFile>>>

Manifests of the current snapshot.

pub async fn files(&self) -> Result<Vec<LiveEntry>>

All live data files of the current snapshot.

impl Table

pub async fn upgrade( &self, opts: &UpgradeOptions, ) -> Result<(Table, UpgradeReport)>

Brings the table to the current format (FORMAT_VERSION) and layout, without losing data: every step is a commit, and no snapshot expires for opts.keep_snapshots, so Table::rollback to report.snapshot_before undoes it. Returns the new version.

pub async fn rollback(&self, snapshot_id: i64) -> Result<Table>

Makes snapshot_id, an earlier snapshot of this table, current again: a new version whose data is that snapshot’s. Later snapshots stay in the history until they expire, so a rollback can be rolled back too. Returns the new version.

Trait Implementations

impl Clone for Table

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Table

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

Formats the value using the given formatter.