Enum PipelineNode 

pub enum PipelineNode {
    Where(Expression),
    Select(Vec<String>),
    GroupBy {
        fields: Vec<String>,
        aggregates: Vec<AggregateExpr>,
    },
    Having(Expression),
    SortBy {
        fields: Vec<(String, SortDirection)>,
    },
    Limit(u64),
    Offset(u64),
    Distinct,
    Alert(String),
    If {
        condition: Expression,
        then_branch: Vec<Self>,
        else_branch: Option<Vec<Self>>,
    },
    Set {
        field: String,
        value: SetValue,
    },
    Fill {
        field: String,
        default: SetValue,
        condition: Option<Expression>,
    },
    Let {
        name: String,
        value: Expression,
    },
    Debug,
    Assert(Expression),
    RowNumber {
        alias: String,
    },
    Rank {
        field: String,
        alias: String,
    },
    Lag {
        field: String,
        alias: String,
        offset: u64,
    },
    Lead {
        field: String,
        alias: String,
        offset: u64,
    },
}

Variants

Where(Expression)

Select(Vec<String>)

GroupBy

Fields

fields: Vec<String>

aggregates: Vec<AggregateExpr>

Having(Expression)

SortBy

Fields

fields: Vec<(String, SortDirection)>

Limit(u64)

Offset(u64)

Distinct

Alert(String)

If

Fields

condition: Expression

then_branch: Vec<Self>

else_branch: Option<Vec<Self>>

Set

Fields

field: String

value: SetValue

Fill

Fields

field: String

default: SetValue

The default value expression (supports if/case/when like set).

condition: Option<Expression>

Optional condition: only fill rows that match this condition.

Let

Fields

name: String

value: Expression

Debug

Print debug info (row count and schema) to stderr. Does not modify the data stream.

Assert(Expression)

Assert that a condition holds for every row. If any row fails the condition, the query fails with an error. Acts as a pass-through when all rows pass.

RowNumber

Assign a sequential row number (1-based) to each row.

Fields

alias: String

The alias/column name for the row number.

Rank

Rank rows by a field value (ties get same rank).

Fields

field: String

Field to rank by.

alias: String

The alias/column name for the rank.

Lag

Access the value of a field from the previous row (like SQL LAG).

Fields

field: String

Field whose value from the previous row to retrieve.

alias: String

The alias/column name for the lag value.

offset: u64

How many rows to look back (default 1).

Lead

Access the value of a field from the next row (like SQL LEAD).

Fields

field: String

Field whose value from the next row to retrieve.

alias: String

The alias/column name for the lead value.

offset: u64

How many rows to look ahead (default 1).

Trait Implementations

impl Clone for PipelineNode

fn clone(&self) -> PipelineNode

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PipelineNode

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

Formats the value using the given formatter.

impl PartialEq for PipelineNode

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for PipelineNode

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for PipelineNode