Struct mz_expr::interpret::MfpEval

pub(crate) struct MfpEval<'a, E: Interpreter + ?Sized> {
    evaluator: &'a E,
    input_arity: usize,
    expressions: Vec<E::Summary>,
}

Wrap another interpreter, but tack a few extra columns on at the end. An internal implementation detail of eval_mfp and eval_mfp_plan.

Fields

evaluator: &'a E

input_arity: usize

expressions: Vec<E::Summary>

Implementations

impl<'a, E: Interpreter + ?Sized> MfpEval<'a, E>

pub(crate) fn new( evaluator: &'a E, input_arity: usize, expressions: &[MirScalarExpr], ) -> Self

Trait Implementations

impl<'a, E: Interpreter + ?Sized> Interpreter for MfpEval<'a, E>

type Summary = <E as Interpreter>::Summary

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

A column of the input row.

fn literal( &self, result: &Result<Row, EvalError>, col_type: &ColumnType, ) -> 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, expr: 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, exprs: 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 expr(&self, expr: &MirScalarExpr) -> Self::Summary

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

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

Specifically, this evaluates the map and filters stages of an MFP: summarize each of the map expressions, then and together all of the filters.

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.