Enum StreamingSource 

pub enum StreamingSource {
    Scan(ScanSource),
    Concat {
        inputs: Vec<StreamingPhysicalPlan>,
        schema: Option<SchemaRef>,
    },
}

Physical plan compiler and plan node types. Streaming source tree preserving concat input order and child operators.

Variants

Scan(ScanSource)

A single scan source with no nested stream boundary.

Concat

Strict vertical concat of independently compiled child streams.

Fields

inputs: Vec<StreamingPhysicalPlan>

Children in declared output order.

schema: Option<SchemaRef>

Validated common schema, or deferred bounded source preflight.

Trait Implementations

impl Clone for StreamingSource

fn clone(&self) -> StreamingSource

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamingSource

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

Formats the value using the given formatter.