Struct SafeMfpPlan

pub struct SafeMfpPlan {
    pub(crate) mfp: MapFilterProject,
}

A wrapper type which indicates it is safe to simply evaluate all expressions.

Fields

mfp: MapFilterProject

the inner MapFilterProject that is safe to evaluate.

Implementations

impl SafeMfpPlan

pub fn permute( &mut self, map: BTreeMap<usize, usize>, new_arity: usize, ) -> Result<(), Error>

See MapFilterProject::permute.

pub fn eval_batch_into(&self, batch: &mut Batch) -> Result<Batch, EvalError>

similar to [MapFilterProject::evaluate_into], just in batch, and rows that don’t pass the predicates are not included in the output.

so it’s not guaranteed that the output will have the same number of rows as the input.

pub fn eval_batch_inner( &self, batch: &mut Batch, ) -> Result<BooleanVector, EvalError>

similar to [MapFilterProject::evaluate_into], just in batch.

pub fn evaluate_into( &self, values: &mut Vec<Value>, row_buf: &mut Row, ) -> Result<Option<Row>, EvalError>

Evaluates the linear operator on a supplied list of datums.

The arguments are the initial datums associated with the row, and an appropriately lifetimed arena for temporary allocations needed by scalar evaluation.

An Ok result will either be None if any predicate did not evaluate to Value::Boolean(true), or the values of the columns listed by self.projection if all predicates passed. If an error occurs in the evaluation it is returned as an Err variant. As the evaluation exits early with failed predicates, it may miss some errors that would occur later in evaluation.

The row is not cleared first, but emptied if the function returns `Ok(Some(row)).

pub fn evaluate_inner(&self, values: &mut Vec<Value>) -> Result<bool, EvalError>

Populates values with self.expressions and tests self.predicates.

This does not apply self.projection, which is up to the calling method.

Methods from Deref<Target = MapFilterProject>

pub fn get_nth_expr(&self, n: usize) -> Option<ScalarExpr>

pub fn output_arity(&self) -> usize

The number of columns expected in the output row.

pub fn is_identity(&self) -> bool

True if the operator describes the identity transformation.

pub fn as_map_filter_project( &self, ) -> (Vec<ScalarExpr>, Vec<ScalarExpr>, Vec<usize>)

As the arguments to Map, Filter, and Project operators.

In principle, this operator can be implemented as a sequence of more elemental operators, likely less efficiently.

pub fn get_old_to_new_mapping(&self) -> BTreeMap<usize, usize>

get the mapping of old columns to new columns after the mfp

pub fn demand(&self) -> BTreeSet<usize>

Lists input columns whose values are used in outputs.

It is entirely appropriate to determine the demand of an instance and then both apply a projection to the subject of the instance and self.permute this instance.

Trait Implementations

impl Clone for SafeMfpPlan

fn clone(&self) -> SafeMfpPlan

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for SafeMfpPlan

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

Formats the value using the given formatter.

impl Ord for SafeMfpPlan

fn cmp(&self, other: &SafeMfpPlan) -> Ordering

This method returns an Ordering between self and other.

fn max(self, other: Self) -> Self

where Self: Sized,

Compares and returns the maximum of two values.

fn min(self, other: Self) -> Self

where Self: Sized,

Compares and returns the minimum of two values.

fn clamp(self, min: Self, max: Self) -> Self

where Self: Sized,

Restrict a value to a certain interval.

impl PartialEq for SafeMfpPlan

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl PartialOrd for SafeMfpPlan

fn partial_cmp(&self, other: &SafeMfpPlan) -> Option<Ordering>

This method returns an ordering between self and other values if one exists.

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

Tests less than (for self and other) and is used by the < operator.

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

Tests less than or equal to (for self and other) and is used by the <= operator.

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

Tests greater than (for self and other) and is used by the > operator.

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

Tests greater than or equal to (for self and other) and is used by the >= operator.

impl Deref for SafeMfpPlan

type Target = MapFilterProject

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl Eq for SafeMfpPlan

impl StructuralPartialEq for SafeMfpPlan