Enum StreamingStatement 

pub enum StreamingStatement {
    Standard(Box<Statement>),
    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>,
    },
    CreateMaterializedView {
        name: ObjectName,
        query: Box<StreamingStatement>,
        emit_clause: Option<EmitClause>,
        or_replace: bool,
        if_not_exists: bool,
    },
    CreateStream {
        name: ObjectName,
        query: Box<StreamingStatement>,
        emit_clause: Option<EmitClause>,
        or_replace: bool,
        if_not_exists: bool,
    },
    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,
    },
}

Streaming-specific SQL statements

Variants

Standard(Box<Statement>)

Standard SQL statement

CreateSource(Box<CreateSourceStatement>)

CREATE SOURCE statement

CreateSink(Box<CreateSinkStatement>)

CREATE SINK statement

CreateContinuousQuery

CREATE CONTINUOUS QUERY

Fields

name: ObjectName

Query name

query: Box<StreamingStatement>

SQL query with streaming extensions

emit_clause: Option<EmitClause>

EMIT clause if present

DropSource

DROP SOURCE statement

Fields

name: ObjectName

Source name to drop

if_exists: bool

Whether IF EXISTS was specified

cascade: bool

Whether CASCADE was specified (drops dependent streams/MVs)

DropSink

DROP SINK statement

Fields

name: ObjectName

Sink name to drop

if_exists: bool

Whether IF EXISTS was specified

cascade: bool

Whether CASCADE was specified

DropMaterializedView

DROP MATERIALIZED VIEW statement

Fields

name: ObjectName

View name to drop

if_exists: bool

Whether IF EXISTS was specified

cascade: bool

Whether CASCADE was specified

Show(ShowCommand)

SHOW SOURCES/SINKS/QUERIES/MATERIALIZED VIEWS

Describe

DESCRIBE source, sink, or other streaming object

Fields

name: ObjectName

Object name to describe

extended: bool

Whether EXTENDED was specified for additional detail

Explain

EXPLAIN a streaming query plan

Fields

statement: Box<StreamingStatement>

The statement to explain

CreateMaterializedView

CREATE MATERIALIZED VIEW

Fields

name: ObjectName

View name

query: Box<StreamingStatement>

The backing query

emit_clause: Option<EmitClause>

Optional EMIT clause

or_replace: bool

Whether OR REPLACE was specified

if_not_exists: bool

Whether IF NOT EXISTS was specified

CreateStream

CREATE STREAM — named streaming pipeline

Fields

name: ObjectName

Stream name

query: Box<StreamingStatement>

Backing query (AS SELECT …)

emit_clause: Option<EmitClause>

Optional EMIT clause

or_replace: bool

Whether OR REPLACE was specified

if_not_exists: bool

Whether IF NOT EXISTS was specified

DropStream

DROP STREAM statement

Fields

name: ObjectName

Stream name to drop

if_exists: bool

Whether IF EXISTS was specified

cascade: bool

Whether CASCADE was specified

AlterSource

ALTER SOURCE — modify a source definition

Fields

name: ObjectName

Source name to alter

operation: AlterSourceOperation

The alteration to apply

InsertInto

INSERT INTO a streaming source or table

Fields

table_name: ObjectName

Target table or source name

columns: Vec<Ident>

Column names (empty if not specified)

values: Vec<Vec<Expr>>

Row values

CreateLookupTable(Box<CreateLookupTableStatement>)

CREATE LOOKUP TABLE statement

DropLookupTable

DROP LOOKUP TABLE statement

Fields

name: ObjectName

Lookup table name to drop

if_exists: bool

Whether IF EXISTS was specified

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

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 StructuralPartialEq for StreamingStatement