Crate mz_expr

Core expression language.

Modules

canonicalize

Utility functions to transform parts of a single MirRelationExpr into canonical form.

explain

This module houses a pretty printer for MirRelationExprs.

func

id 🔒

like_pattern

linear 🔒

relation 🔒

scalar 🔒

virtual_syntax

A set of virtual nodes that are used to recover some high-level concepts that are desugared to non-trival terms in some IRs.

visit

Visitor support for recursive data types.

Structs

AggregateExpr

Describes an aggregation expression.

AnalyzedRegex

CaptureGroupDesc

ColumnOrder

Specification for an ordering by a column.

JoinInputMapper

Any column in a join expression exists in two contexts:

LocalId

The identifier for a local component of a dataflow.

MapFilterProject

A compound operator that can be applied row-by-row.

MfpPlan

Predicates partitioned into temporal and non-temporal.

OptimizedMirRelationExpr

A MirRelationExpr that claims to have been optimized, e.g., by an transform::Optimizer.

ProtoAggregateExpr

ProtoAggregateFunc

ProtoColumnOrder

ProtoDomainLimit

ProtoEvalError

ProtoId

ProtoLocalId

ProtoMapFilterProject

ProtoMfpPlan

ProtoMirScalarExpr

ProtoRowSetFinishing

ProtoSafeMfpPlan

ProtoTableFunc

RowSetFinishing

Instructions for finishing the result of a query.

SafeMfpPlan

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

SourceInstanceId

Unique identifier for an instantiation of a source.

WindowFrame

Describe a window frame, e.g. RANGE UNBOUNDED PRECEDING or ROWS BETWEEN 5 PRECEDING AND CURRENT ROW.

Enums

AggregateFunc

BinaryFunc

EvalError

Id

An opaque identifier for a dataflow component. In other words, identifies the target of a MirRelationExpr::Get.

JoinImplementation

Describe a join implementation in dataflow.

LagLeadType

Identify whether the given aggregate function is Lag or Lead, since they share implementations.

MirRelationExpr

An abstract syntax tree which defines a collection.

MirScalarExpr

PartitionId

Unique identifier for each part of a whole source. Kafka -> partition None -> sources that have no notion of partitioning (e.g file sources)

TableFunc

UnaryFunc

UnmaterializableFunc

VariadicFunc

WindowFrameBound

Specifies WindowFrame’s start_bound and end_bound

WindowFrameUnits

Describe how frame bounds are interpreted

Constants

RECURSION_LIMIT

A recursion limit to be used for stack-safe traversals of MirRelationExpr trees.

Traits

CollectionPlan

A trait for types that describe how to build a collection.

Functions

compare_columns

Compare left and right using order. If that doesn’t produce a strict ordering, call tiebreaker.

join_permutations

Given the permutations (see permutation_for_arrangement and (dataflow::plan::AvailableCollections) corresponding to two collections with the same key arity, computes the permutation for the result of joining them.

memoize_expr

Recursively memoize parts of expr, storing those parts in memoized_parts.

permutation_for_arrangement

Return the map associating columns in the logical, unthinned representation of a collection to columns in the thinned representation of the arrangement corresponding to key.