Enum MetalOp 

#[non_exhaustive]
pub enum MetalOp {
    Sort {
        keys: Vec<SortKey>,
        fetch: Option<usize>,
    },
    Aggregate {
        keys: Vec<usize>,
        aggs: Vec<AggSpec>,
    },
    Filter {
        predicate: String,
        projection: Option<Vec<usize>>,
    },
    Join {
        how: JoinHow,
        left_keys: Vec<usize>,
        right_keys: Vec<usize>,
        projection: Vec<usize>,
        left_columns: usize,
    },
}

What a MetalExec computes, in terms of its input’s column indices.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

Sort

A sort (fetch: under a LIMIT).

Fields

keys: Vec<SortKey>

The ORDER BY keys, first to last.

fetch: Option<usize>

The LIMIT, if any.

Aggregate

A GROUP BY over column keys (no aggregates: DISTINCT).

Fields

keys: Vec<usize>

The key columns.

aggs: Vec<AggSpec>

The aggregates, in output order after the keys.

Filter

A filter, with the projection DataFusion’s FilterExec carried.

Fields

predicate: String

An ArrowMetal s-expression over columns named c{i}.

projection: Option<Vec<usize>>

The output columns, if the filter projects.

Join

An equi-join over column keys (DataFusion’s HashJoinExec), both inputs collected. The output is DataFusion’s: the left input’s columns, then the right input’s, through projection.

Fields

how: JoinHow

Which unmatched rows are kept.

left_keys: Vec<usize>

The key columns of the left (build) input, in the join’s on order.

right_keys: Vec<usize>

The key columns of the right (probe) input, in the same order.

projection: Vec<usize>

The output columns, as indices into the left input’s columns followed by the right’s.

left_columns: usize

The number of columns of the left input.

Trait Implementations

impl Clone for MetalOp

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MetalOp

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

Formats the value using the given formatter.

impl PartialEq for MetalOp

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for MetalOp