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.

Modules

aggregation_parser

Aggregate function detection and extraction

analytic_parser

Analytic window function detection and extraction

join_parser

Join query analysis and extraction

order_analyzer

ORDER BY analysis for streaming SQL queries

Structs

CreateSinkStatement

CREATE SINK statement

CreateSourceStatement

CREATE SOURCE statement

FormatSpec

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

LateDataClause

Late data handling clause.

StreamingParser

Parser for streaming SQL extensions.

WatermarkDef

Watermark definition

WindowRewriter

Rewrites window functions in SQL queries

Enums

EmitClause

EMIT clause for controlling output timing.

EmitStrategy

Emit strategy for runtime operator configuration.

ParseError

SQL parsing errors

ShowCommand

SHOW command variants for listing streaming objects.

SinkFrom

Source for a sink

StreamingStatement

Streaming-specific SQL statements

WindowFunction

Window function types

Functions

parse_streaming_sql

Parses SQL with streaming extensions.