Enum StreamingStatement 

pub enum StreamingStatement {
    Standard(Box<Statement>),
    TemporalProbeQuery {
        statement: Box<Statement>,
        analysis: Box<JoinAnalysis>,
    },
    CreateSource(Box<CreateSourceStatement>),
    CreateSink(Box<CreateSinkStatement>),
    CreateContinuousQuery {
        name: ObjectName,
        query: Box<StreamingStatement>,
        emit_clause: Option<EmitClause>,
    },
    DropSource {
        name: ObjectName,
        if_exists: bool,
        cascade: bool,
    },
    DropSink {
        name: ObjectName,
        if_exists: bool,
        cascade: bool,
    },
    DropMaterializedView {
        name: ObjectName,
        if_exists: bool,
        cascade: bool,
    },
    Show(ShowCommand),
    Describe {
        name: ObjectName,
        extended: bool,
    },
    Explain {
        statement: Box<StreamingStatement>,
        analyze: bool,
    },
    CreateMaterializedView {
        name: ObjectName,
        query: Box<StreamingStatement>,
        emit_clause: Option<EmitClause>,
        or_replace: bool,
        if_not_exists: bool,
        query_sql: String,
    },
    CreateStream {
        name: ObjectName,
        query: Box<StreamingStatement>,
        emit_clause: Option<EmitClause>,
        or_replace: bool,
        if_not_exists: bool,
        query_sql: String,
        retention_bytes: Option<u64>,
    },
    DropStream {
        name: ObjectName,
        if_exists: bool,
        cascade: bool,
    },
    AlterSource {
        name: ObjectName,
        operation: AlterSourceOperation,
    },
    InsertInto {
        table_name: ObjectName,
        columns: Vec<Ident>,
        values: Vec<Vec<Expr>>,
    },
    CreateLookupTable(Box<CreateLookupTableStatement>),
    DropLookupTable {
        name: ObjectName,
        if_exists: bool,
    },
    Checkpoint,
    RestoreCheckpoint {
        checkpoint_id: u64,
    },
    Subscribe(Box<SubscribeStatement>),
    DeclareCursorForSubscribe {
        name: Ident,
        no_scroll: bool,
        subscribe: Box<SubscribeStatement>,
    },
}

SQL statements understood by the streaming parser.

Variants

Standard(Box<Statement>)

A standard SQL statement without streaming syntax.

TemporalProbeQuery

A multi-horizon temporal probe normalized to the canonical AS-OF query shape.

Fields

statement: Box<Statement>

AST used for projection and non-join analysis.

analysis: Box<JoinAnalysis>

Parsed temporal-join contract.

CreateSource(Box<CreateSourceStatement>)

CREATE SOURCE.

CreateSink(Box<CreateSinkStatement>)

CREATE SINK.

CreateContinuousQuery

CREATE CONTINUOUS QUERY.

Fields

name: ObjectName

Query name.

query: Box<StreamingStatement>

Streaming query body.

emit_clause: Option<EmitClause>

Optional output strategy.

DropSource

DROP SOURCE.

Fields

name: ObjectName

Source to drop.

if_exists: bool

Ignore a missing source.

cascade: bool

Also drop dependent streams and materialized views.

DropSink

DROP SINK.

Fields

name: ObjectName

Sink to drop.

if_exists: bool

Ignore a missing sink.

cascade: bool

Also drop dependent objects.

DropMaterializedView

DROP MATERIALIZED VIEW.

Fields

name: ObjectName

View to drop.

if_exists: bool

Ignore a missing view.

cascade: bool

Also drop dependent objects.

Show(ShowCommand)

A SHOW command.

Describe

DESCRIBE a streaming object.

Fields

name: ObjectName

Object to describe.

extended: bool

Include extended details.

Explain

EXPLAIN [ANALYZE] a streaming query plan.

Fields

statement: Box<StreamingStatement>

Statement to explain.

analyze: bool

Execute the query and collect metrics.

CreateMaterializedView

CREATE MATERIALIZED VIEW.

Fields

name: ObjectName

View name.

query: Box<StreamingStatement>

Backing query.

emit_clause: Option<EmitClause>

Optional output strategy.

or_replace: bool

Replace an existing view.

if_not_exists: bool

Ignore an existing view.

query_sql: String

Raw query text between AS and EMIT.

CreateStream

CREATE STREAM for a named streaming pipeline.

Fields

name: ObjectName

Stream name.

query: Box<StreamingStatement>

Backing query.

emit_clause: Option<EmitClause>

Optional output strategy.

or_replace: bool

Replace an existing stream.

if_not_exists: bool

Ignore an existing stream.

query_sql: String

Raw query text between AS and EMIT.

retention_bytes: Option<u64>

RETAIN_HISTORY cap in bytes from the trailing WITH (...).

DropStream

DROP STREAM.

Fields

name: ObjectName

Stream to drop.

if_exists: bool

Ignore a missing stream.

cascade: bool

Also drop dependent objects.

AlterSource

ALTER SOURCE.

Fields

name: ObjectName

Source to alter.

operation: AlterSourceOperation

Requested alteration.

InsertInto

INSERT INTO a streaming source or table.

Fields

table_name: ObjectName

Target source or table.

columns: Vec<Ident>

Empty when the statement does not name columns.

values: Vec<Vec<Expr>>

Rows to insert.

CreateLookupTable(Box<CreateLookupTableStatement>)

CREATE LOOKUP TABLE.

DropLookupTable

DROP LOOKUP TABLE.

Fields

name: ObjectName

Lookup table to drop.

if_exists: bool

Ignore a missing table.

Checkpoint

Trigger an immediate checkpoint.

RestoreCheckpoint

RESTORE FROM CHECKPOINT <id>.

Fields

checkpoint_id: u64

Durable checkpoint identifier.

Subscribe(Box<SubscribeStatement>)

SUBSCRIBE <name> [WHERE ...] [WITH (...)].

DeclareCursorForSubscribe

DECLARE <name> [NO SCROLL] CURSOR [WITHOUT HOLD] FOR SUBSCRIBE …

Forward-only cursor over a SUBSCRIBE, scoped to the current SimpleQuery connection. SCROLL, BINARY, WITH HOLD, INSENSITIVE, and ASENSITIVE are rejected at parse time.

Fields

name: Ident

Cursor identifier.

no_scroll: bool

NO SCROLL was explicit in the source. We never emit SCROLL.

subscribe: Box<SubscribeStatement>

The SUBSCRIBE body the cursor wraps.

Trait Implementations

impl Clone for StreamingStatement

fn clone(&self) -> StreamingStatement

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamingStatement

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

Formats the value using the given formatter.

impl PartialEq for StreamingStatement

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for StreamingStatement