Struct mz_compute_types::plan::join::JoinClosure

pub struct JoinClosure {
    pub ready_equivalences: Vec<Vec<MirScalarExpr>>,
    pub before: SafeMfpPlan,
}

A manual closure implementation of filtering and logic application.

This manual implementation exists to express lifetime constraints clearly, as there is a relationship between the borrowed lifetime of the closed-over state and the arguments it takes when invoked. It was not clear how to do this with a Rust closure (glorious battle was waged, but ultimately lost).

Fields

ready_equivalences: Vec<Vec<MirScalarExpr>>

TODO(database-issues#7533): Add documentation.

before: SafeMfpPlan

TODO(database-issues#7533): Add documentation.

Implementations

impl JoinClosure

pub fn apply<'a>( &'a self, datums: &mut Vec<Datum<'a>>, temp_storage: &'a RowArena, row: &'a mut Row, ) -> Result<Option<Row>, EvalError>

Applies per-row filtering and logic.

fn build( columns: &mut BTreeMap<usize, usize>, equivalences: &mut Vec<Vec<MirScalarExpr>>, mfp: &mut MapFilterProject, permutation: BTreeMap<usize, usize>, thinned_arity_with_key: usize, ) -> Self

Construct an instance of the closure from available columns.

This method updates the available columns, equivalences, and the MapFilterProject instance. The columns are updated to include reference to any columns added by the application of this logic, which might result from partial application of the MapFilterProject instance.

If all columns are available for mfp, this method works extra hard to ensure that the closure contains all the work, and mfp is left as an identity transform (which can then be ignored).

pub fn is_identity(&self) -> bool

True iff the closure neither filters nor transforms records.

pub fn could_error(&self) -> bool

Returns true if evaluation could introduce an error on non-error inputs.

Trait Implementations

impl Arbitrary for JoinClosure

type Parameters = ()

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

type Strategy = BoxedStrategy<JoinClosure>

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

fn arbitrary_with(_: 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 JoinClosure

fn clone(&self) -> JoinClosure

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for JoinClosure

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for JoinClosure

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl DisplayText<PlanRenderingContext<'_, Plan>> for JoinClosure

fn fmt_text( &self, f: &mut Formatter<'_>, ctx: &mut PlanRenderingContext<'_, Plan>, ) -> Result

impl Ord for JoinClosure

fn cmp(&self, other: &JoinClosure) -> 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 + PartialOrd,

Restrict a value to a certain interval.

impl PartialEq for JoinClosure

fn eq(&self, other: &JoinClosure) -> 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 JoinClosure

fn partial_cmp(&self, other: &JoinClosure) -> 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 RustType<ProtoJoinClosure> for JoinClosure

fn into_proto(&self) -> ProtoJoinClosure

Convert a Self into a Proto value.

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

Consume and convert a Proto back into a Self value.

fn into_proto_owned(self) -> Proto

A zero clone version of Self::into_proto that types can optionally implement, otherwise, the default implementation delegates to Self::into_proto.

impl Serialize for JoinClosure

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for JoinClosure

impl StructuralPartialEq for JoinClosure