Module parser 

SQL parser with streaming extensions.

Routes streaming DDL (CREATE SOURCE/SINK/CONTINUOUS QUERY) to custom parsers that use sqlparser primitives. Routes standard SQL to sqlparser with GenericDialect.

Re-exports

pub use lookup_table::CreateLookupTableStatement;

Modules

aggregation_parser

Aggregate function detection and extraction

analytic_parser

Analytic window function detection and extraction

join_parser

Join query analysis and extraction

lookup_table

Parser for CREATE/DROP LOOKUP TABLE DDL statements Parser for CREATE/DROP LOOKUP TABLE DDL statements.

order_analyzer

ORDER BY analysis for streaming SQL queries

Structs

CreateSinkStatement

Parsed CREATE SINK statement.

CreateSourceStatement

Parsed CREATE SOURCE statement.

FormatSpec

Format specification for serialization (e.g., FORMAT JSON, FORMAT AVRO).

LateDataClause

SQL configuration for events that arrive after their window closes.

StreamingParser

Parser for streaming SQL extensions.

SubscribeStatement

SUBSCRIBE <name> [AS OF EPOCH n] [WHERE <fragment>] [WITH (...)].

WatermarkDef

Parsed watermark definition.

WindowRewriter

Rewrites window functions in SQL queries

Enums

AlterSourceOperation

Operations for ALTER SOURCE statements.

EmitClause

Parsed EMIT strategy.

EmitStrategy

Runtime output strategy for a streaming operator.

ParseError

SQL parsing errors

ShowCommand

Supported SHOW commands.

SinkFrom

Input selected by a sink.

StreamingStatement

SQL statements understood by the streaming parser.

WindowFunction

Parsed streaming window function.

Functions

parse_streaming_sql

Parses SQL with streaming extensions.