Enum StreamingPlan 

pub enum StreamingPlan {
    RegisterSource(SourceInfo),
    RegisterSink(SinkInfo),
    Query(QueryPlan),
    Standard(Box<Statement>),
    DagExplain(DagExplainOutput),
    RegisterLookupTable(LookupTableInfo),
    DropLookupTable {
        name: String,
    },
}

Result of planning a streaming statement

Variants

RegisterSource(SourceInfo)

Source registration (DDL)

RegisterSink(SinkInfo)

Sink registration (DDL)

Query(QueryPlan)

Query plan with streaming configurations

Standard(Box<Statement>)

Standard SQL statement (pass-through to DataFusion)

DagExplain(DagExplainOutput)

DAG topology explanation (from EXPLAIN DAG)

RegisterLookupTable(LookupTableInfo)

Lookup table registration (DDL)

DropLookupTable

Drop a lookup table

Fields

name: String

Name of the lookup table to drop.

Trait Implementations

impl Debug for StreamingPlan

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

Formats the value using the given formatter.