Module execute 

End-to-end streaming SQL execution End-to-end streaming SQL execution (F005B)

Provides execute_streaming_sql for parsing, planning, and executing streaming SQL statements through the DataFusion engine.

Architecture

SQL string
    │
    ▼
parse_streaming_sql()  →  StreamingStatement
    │
    ▼
StreamingPlanner::plan()  →  StreamingPlan
    │
    ├─ DDL (CREATE SOURCE/SINK)  →  DdlResult
    │
    ├─ Query (windows/joins)     →  LogicalPlan → DataFrame → stream
    │                                + QueryPlan metadata
    │
    └─ Standard SQL              →  DataFusion ctx.sql() → stream

Structs

DdlResult

Result of a DDL statement execution.

QueryResult

Result of a query execution.

Enums

StreamingSqlResult

Result of executing a streaming SQL statement.

Functions

execute_streaming_sql

Executes a streaming SQL statement end-to-end.