Module streaming_ddl 

Streaming DDL (CREATE SOURCE/SINK) translator SQL DDL to streaming API translation.

Structs

ColumnDefinition

Column definition for a streaming source.

SinkDefinition

A validated streaming sink definition.

SourceConfigOptions

Configuration options for a streaming source.

SourceDefinition

A validated streaming source definition.

WatermarkSpec

Watermark specification for a source.

Functions

sql_type_to_arrow

Converts SQL data type to Arrow data type.

translate_create_sink

Translates a CREATE SINK statement to a typed SinkDefinition.

translate_create_source

Translates a CREATE SOURCE statement to a typed SourceDefinition.

translate_create_source_with_columns

Translate a CREATE SOURCE statement using an already-resolved column list. Used by the DDL layer after discover_schema so WATERMARK FOR validates against the discovered columns rather than the SQL text.