Enum StreamingOperator 

pub enum StreamingOperator {
    Projection {
        exprs: Vec<Expr>,
        kind: ProjectionKind,
    },
    Filter {
        predicate: Expr,
    },
    ForwardSlice {
        offset: usize,
        len: usize,
    },
}

Physical plan compiler and plan node types. Per-batch operator selected by the streaming compiler.

Variants

Projection

Projection/select or with-columns applied to one batch.

Fields

exprs: Vec<Expr>

Expressions in declaration order.

kind: ProjectionKind

Projection behavior.

Filter

Predicate applied to one batch.

Fields

predicate: Expr

Predicate expression.

ForwardSlice

Forward-only head/slice operation.

Fields

offset: usize

Rows to skip from the stream start.

len: usize

Maximum rows to publish.

Trait Implementations

impl Clone for StreamingOperator

fn clone(&self) -> StreamingOperator

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamingOperator

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

Formats the value using the given formatter.