Struct StreamingParser 

pub struct StreamingParser;

Parser for streaming SQL extensions.

Provides static methods for parsing streaming SQL statements. Uses sqlparser’s Parser API internally for structured parsing of identifiers, data types, expressions, and queries.

Implementations

impl StreamingParser

pub fn parse_sql(sql: &str) -> Result<Vec<StreamingStatement>, ParserError>

Parse a SQL string with streaming extensions.

Tokenizes the input to detect statement type, then routes to the appropriate parser:

• CREATE SOURCE → source_parser
• CREATE SINK → sink_parser
• CREATE CONTINUOUS QUERY → continuous_query_parser
• Everything else → sqlparser::parser::Parser

Errors

Returns ParserError if the SQL syntax is invalid.

pub fn has_window_function(expr: &Expr) -> bool

Check if an expression contains a window function.

pub fn parse_emit_clause(sql: &str) -> Result<Option<EmitClause>, ParseError>

Parse EMIT clause from SQL string.

Errors

Returns ParseError::StreamingError if the EMIT clause syntax is invalid.

pub fn parse_late_data_clause( sql: &str, ) -> Result<Option<LateDataClause>, ParseError>

Parse late data handling clause from SQL string.

Errors

Returns ParseError::StreamingError if the clause syntax is invalid.