Struct mz_transform::join_implementation::JoinImplementation

pub struct JoinImplementation {
    recursion_guard: RecursionGuard,
}

Determines the join implementation for join operators.

Fields

recursion_guard: RecursionGuard

Implementations

impl JoinImplementation

pub fn action_recursive( &self, relation: &mut MirRelationExpr, indexes: &mut IndexMap<'_>, stats: &dyn StatisticsOracle, features: &OptimizerFeatures, ) -> Result<(), TransformError>

Pre-order visitor for each MirRelationExpr to find join operators.

This method accumulates state about let-bound arrangements, so that join operators can more accurately assess their available arrangements.

pub fn action( &self, relation: &mut MirRelationExpr, mfp_above: MapFilterProject, indexes: &IndexMap<'_>, stats: &dyn StatisticsOracle, features: &OptimizerFeatures, ) -> Result<(), TransformError>

Determines the join implementation for join operators.

Trait Implementations

impl CheckedRecursion for JoinImplementation

fn recursion_guard(&self) -> &RecursionGuard

Extracts a reference to the recursion guard embedded within the type.

fn checked_recur<F, T, E>(&self, f: F) -> Result<T, E>

where F: FnOnce(&Self) -> Result<T, E>, E: From<RecursionLimitError>,

Checks whether it is safe to recur and calls f if so.

fn checked_recur_mut<F, T, E>(&mut self, f: F) -> Result<T, E>

where F: FnOnce(&mut Self) -> Result<T, E>, E: From<RecursionLimitError>,

Like CheckedRecursion::checked_recur, but operates on a mutable reference to Self.

impl Debug for JoinImplementation

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

Formats the value using the given formatter.

impl Default for JoinImplementation

fn default() -> JoinImplementation

Construct a new JoinImplementation where recursion_guard is initialized with RECURSION_LIMIT as limit.

impl Transform for JoinImplementation

fn name(&self) -> &'static str

A short string naming the transform, as it will be reported in metrics.

fn actually_perform_transform( &self, relation: &mut MirRelationExpr, ctx: &mut TransformCtx<'_>, ) -> Result<(), TransformError>

Transform a relation into a functionally equivalent relation.

fn transform( &self, relation: &mut MirRelationExpr, args: &mut TransformCtx<'_>, ) -> Result<(), TransformError>

Transforms a relation into a functionally equivalent relation.

fn debug(&self) -> String

A string describing the transform.