Struct TableSpec 

pub struct TableSpec {
    pub table: String,
    pub mode: SyncMode,
    pub columns: Vec<String>,
    pub filter: Option<RowFilter>,
}

What the listener asks a source each round.

columns + filter are the pushdown half of the ask: they say what the round actually needs, so a source that can prune (the Iceberg one) reads only that. A source that cannot prune ignores them and returns everything — the batches are then a superset, which every downstream transform already tolerates (they project what they name).

Fields

table: String

mode: SyncMode

columns: Vec<String>

The projection: columns the round needs. Empty = every column, which is the pre-pushdown behaviour. Derived from the mapping’s pipeline by TableMapping::projected_columns.

filter: Option<RowFilter>

An optional row predicate to push into the scan planner (partition / data file / row-group pruning). None = no filter.

Implementations

impl TableSpec

pub fn new(table: impl Into<String>, mode: SyncMode) -> Self

The pre-pushdown ask: this table, this mode, every column, no filter.

pub fn with_columns(self, columns: Vec<String>) -> Self

Narrow the read to columns (empty leaves it unprojected).

pub fn with_filter(self, filter: Option<RowFilter>) -> Self

Push filter into the scan planner.

pub fn column_refs(&self) -> Vec<&str>

columns as the &[&str] the skade read API takes.

Trait Implementations

impl Clone for TableSpec

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 TableSpec

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

Formats the value using the given formatter.

impl Default for TableSpec

fn default() -> Self

Returns the “default value” for a type.