Struct RowFilter 

pub struct RowFilter {
    pub column: String,
    pub eq: Option<FilterValue>,
    pub is_in: Option<Vec<FilterValue>>,
    pub ge: Option<FilterValue>,
    pub le: Option<FilterValue>,
}

A backend-neutral row filter on one column — the YAML face of the scan predicate the Iceberg source pushes down.

Backend-neutral on purpose: bifrost’s core carries no engine dependency (the skade source is an optional feature), so the spec type lives here and is lowered to skade::ScanFilter only inside the Iceberg source. Exactly ONE of eq / in / (ge,le) must be set.

filter: { column: country, eq: SE }            # equality (partition pruning)
filter: { column: country, in: [SE, NO, DK] }  # set membership
filter: { column: year, ge: 2020, le: 2026 }   # inclusive range

Fields

column: String

The column the predicate is on.

eq: Option<FilterValue>

column == value.

is_in: Option<Vec<FilterValue>>

column IN (values…).

ge: Option<FilterValue>

Inclusive lower bound (value <= column).

le: Option<FilterValue>

Inclusive upper bound (column <= value).

Implementations

impl RowFilter

pub fn eq(column: impl Into<String>, value: impl Into<FilterValue>) -> Self

column == value.

pub fn is_in<V: Into<FilterValue>>( column: impl Into<String>, values: impl IntoIterator<Item = V>, ) -> Self

column IN (values…).

pub fn range( column: impl Into<String>, lo: Option<impl Into<FilterValue>>, hi: Option<impl Into<FilterValue>>, ) -> Self

Inclusive range lo <= column <= hi; either bound may be None.

pub fn validate(&self) -> Result<()>

Reject a filter that names no form (or more than one) — a mapping that says filter: { column: x } silently matching everything would be a pushdown that quietly does nothing.

Trait Implementations

impl Clone for RowFilter

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 RowFilter

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RowFilter

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for RowFilter

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for RowFilter

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for RowFilter