Struct ColumnSpecs 

pub struct ColumnSpecs<'a> {
    pub relation: &'a ReprRelationType,
    pub columns: Vec<ResultSpec<'a>>,
    pub unmaterializables: BTreeMap<UnmaterializableFunc, ResultSpec<'a>>,
    pub arena: &'a RowArena,
}

An interpreter that:

• stores both the type and the range of possible values for every column and unmaterializable function. (See the push_ methods.)
• given an expression (or MFP, etc.), returns the range of possible results that evaluating that expression might have. (See the eval_ methods.)

Fields

relation: &'a ReprRelationType

columns: Vec<ResultSpec<'a>>

unmaterializables: BTreeMap<UnmaterializableFunc, ResultSpec<'a>>

arena: &'a RowArena

Implementations

impl<'a> ColumnSpecs<'a>

pub fn new(relation: &'a ReprRelationType, arena: &'a RowArena) -> Self

Create a new, empty set of column specs. (Initially, the only assumption we make about the data in the column is that it matches the type.)

pub fn push_column(&mut self, id: usize, update: ResultSpec<'a>)

Restrict the set of possible values in a given column. (By intersecting it with the existing spec.)

pub fn push_unmaterializable( &mut self, func: UnmaterializableFunc, update: ResultSpec<'a>, )

Restrict the set of possible values a given unmaterializable func might return. (By intersecting it with the existing spec.)

Trait Implementations

impl<'a> Clone for ColumnSpecs<'a>

fn clone(&self) -> ColumnSpecs<'a>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a> Debug for ColumnSpecs<'a>

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

Formats the value using the given formatter.

impl<'a> Interpreter for ColumnSpecs<'a>

fn mfp_filter(&self, mfp: &MapFilterProject) -> Self::Summary

Override the default implementations of Self::mfp_filter and Self::mfp_plan_filter so that the fallibility of MFP expressions surfaces in the result, even when the expression’s result column isn’t referenced by a predicate or temporal bound.

The runtime MFP evaluator runs every expression once all the preceding predicates pass (see crate::SafeMfpPlan::evaluate_inner), so an expression that errors on the actual data will turn the whole row into an Err — even if no predicate or bound mentions that expression. The default mfp_filter / mfp_plan_filter only AND together the predicates and bounds, so the AND result misses the expression’s fallible flag and persist filter pushdown can wrongly discard a part that actually produces error rows. See database-issues#9656.

type Summary = ColumnSpec<'a>

fn column(&self, id: usize) -> Self::Summary

A column of the input row.

fn literal( &self, result: &Result<Row, EvalError>, col_type: &ReprColumnType, ) -> Self::Summary

A literal value. (Stored as a row, because we can’t own a Datum.)

fn unmaterializable(&self, func: &UnmaterializableFunc) -> Self::Summary

A call to an unmaterializable function.

fn unary(&self, func: &UnaryFunc, summary: Self::Summary) -> Self::Summary

A function call that takes one expression as an argument.

fn binary( &self, func: &BinaryFunc, left: Self::Summary, right: Self::Summary, ) -> Self::Summary

A function call that takes two expressions as arguments.

fn variadic( &self, func: &VariadicFunc, args: Vec<Self::Summary>, ) -> Self::Summary

A function call that takes an arbitrary number of arguments.

fn cond( &self, cond: Self::Summary, then: Self::Summary, els: Self::Summary, ) -> Self::Summary

Conditionally evaluated expressions.

fn mfp_plan_filter(&self, plan: &MfpPlan) -> Self::Summary

Similar to Self::mfp_filter, but includes the additional temporal filters that have been broken out.

fn expr(&self, expr: &MirScalarExpr) -> Self::Summary

Evaluate an entire expression, by delegating to the fine-grained methods on Interpreter.