Core expression language.
Utility functions to transform parts of a single
into canonical form.
Describes an aggregation expression.
Specification for an ordering by a column.
Any column in a join expression exists in two contexts:
The identifier for a local component of a dataflow.
A compound operator that can be applied row-by-row.
Predicates partitioned into temporal and non-temporal.
MirRelationExpr that claims to have been optimized, e.g., by an
Instructions for finishing the result of a query.
A wrapper type which indicates it is safe to simply evaluate all expressions.
Unique identifier for an instantiation of a source.
The identifier for a global dataflow.
An opaque identifier for a dataflow component. In other words, identifies
the target of a
Describe a join implementation in dataflow.
An abstract syntax tree which defines a collection.
Unique identifier for each part of a whole source. Kafka -> partition None -> sources that have no notion of partitioning (e.g file sources)
A trait for humanizing components of an expression.
order. If that doesn’t produce a strict ordering, call
Recursively memoize parts of
expr, storing those parts in
Takes a permutation represented as an array
ith column being
j implies that column
i in the original row
corresponds to column
j in the permuted row; see
and converts it to a column map along with the arity of the permuted representation