Enum PipelineBreaker 

pub enum PipelineBreaker {
    Aggregate {
        group_exprs: Vec<Expr>,
        aggr_exprs: Vec<Expr>,
    },
    Sort {
        order_exprs: Vec<Expr>,
    },
    Join {
        join_type: String,
        left_keys: Vec<Expr>,
        right_keys: Vec<Expr>,
    },
    Sink,
}

Stateful operators that break pipeline fusion.

A breaker sits between two pipelines: it consumes output from the upstream pipeline and feeds input to the downstream pipeline.

Variants

Aggregate

GROUP BY aggregation.

Fields

group_exprs: Vec<Expr>

Group-by key expressions.

aggr_exprs: Vec<Expr>

Aggregate function expressions.

Sort

ORDER BY (requires full materialization).

Fields

order_exprs: Vec<Expr>

Sort key expressions.

Join

Stream-stream or lookup join.

Fields

join_type: String

The type of join (inner, left, right, full).

left_keys: Vec<Expr>

Left-side join key expressions.

right_keys: Vec<Expr>

Right-side join key expressions.

Sink

Terminal sink (no downstream pipeline).

Trait Implementations

impl Clone for PipelineBreaker

fn clone(&self) -> PipelineBreaker

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PipelineBreaker

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

Formats the value using the given formatter.