Struct mz_expr::MfpPlan

pub struct MfpPlan { /* private fields */ }

Predicates partitioned into temporal and non-temporal.

Temporal predicates require some recognition to determine their structure, and it is best to do that once and re-use the results.

There are restrictions on the temporal predicates we currently support. They must directly constrain MzLogicalTimestamp from below or above, by expressions that do not themselves contain MzLogicalTimestamp. Conjunctions of such constraints are also ok.

Implementations

impl MfpPlan

pub fn is_identity(&self) -> bool

Indicates if the planned MapFilterProject emits exactly its inputs as outputs.

pub fn into_nontemporal(self) -> Result<SafeMfpPlan, Self>

Attempt to convert self into a non-temporal MapFilterProject plan.

If that is not possible, the original instance is returned as an error.

pub fn evaluate<'b, 'a: 'b, E: From<EvalError>>(
    &'a self,
    datums: &'b mut Vec<Datum<'a>>,
    arena: &'a RowArena,
    time: Timestamp,
    diff: Diff,
    row_builder: &mut Row
) -> impl Iterator<Item = Result<(Row, Timestamp, Diff), (E, Timestamp, Diff)>>

Evaluate the predicates, temporal and non-, and return times and differences for data.

If self contains only non-temporal predicates, the result will either be (time, diff), or an evaluation error. If self contains temporal predicates, the results can be times that are greater than the input time, and may contain negated diff` values.

The row_builder is not cleared first, but emptied if the function returns an iterator with any Ok(_) element.

Trait Implementations

impl Arbitrary for MfpPlan

type Parameters = <SafeMfpPlan as Arbitrary>::Parameters

The type of parameters that arbitrary_with accepts for configuration of the generated Strategy. Parameters must implement Default.

type Strategy = Map<(<SafeMfpPlan as Arbitrary>::Strategy, BoxedStrategy<Vec<MirScalarExpr>>, BoxedStrategy<Vec<MirScalarExpr>>), fn(_: (SafeMfpPlan, Vec<MirScalarExpr>, Vec<MirScalarExpr>)) -> Self>

The type of Strategy used to generate values of type Self.

fn arbitrary_with(_top: Self::Parameters) -> Self::Strategy

Generates a Strategy for producing arbitrary values of type the implementing type (Self). The strategy is passed the arguments given in args.

fn arbitrary() -> Self::Strategy

Generates a Strategy for producing arbitrary values of type the implementing type (Self).

impl Clone for MfpPlan

fn clone(&self) -> MfpPlan

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for MfpPlan

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

Formats the value using the given formatter.

impl PartialEq<MfpPlan> for MfpPlan

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

This method tests for self and other values to be equal, and is used by ==.

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

This method tests for !=.

impl RustType<ProtoMfpPlan> for MfpPlan

fn into_proto(&self) -> ProtoMfpPlan

Convert a Self into a Proto value.

fn from_proto(proto: ProtoMfpPlan) -> Result<Self, TryFromProtoError>

Consume and convert a Proto back into a Self value.

impl StructuralPartialEq for MfpPlan