Module translator 

SQL to operator configuration translation

This module translates parsed SQL AST into Ring 0 operator configurations that can be instantiated and executed.

Re-exports

pub use crate::parser::order_analyzer::RankType;

pub use analytic_translator::AnalyticFunctionConfig;

pub use analytic_translator::AnalyticWindowConfig;

pub use dag_planner::format_dag_explain;

pub use dag_planner::DagExplainOutput;

pub use order_translator::OrderOperatorConfig;

pub use order_translator::PerGroupTopKConfig;

pub use order_translator::TopKConfig;

pub use order_translator::WatermarkSortConfig;

pub use order_translator::WindowLocalSortConfig;

pub use streaming_ddl::sql_type_to_arrow;

pub use streaming_ddl::BackpressureStrategy as StreamingBackpressure;

pub use streaming_ddl::ColumnDefinition;

pub use streaming_ddl::SinkDefinition;

pub use streaming_ddl::SourceConfigOptions;

pub use streaming_ddl::SourceDefinition;

pub use streaming_ddl::WaitStrategy as StreamingWaitStrategy;

pub use streaming_ddl::WatermarkSpec;

Modules

analytic_translator

Analytic window function operator configuration builder Analytic window function operator configuration builder

dag_planner

DAG EXPLAIN formatter DAG EXPLAIN formatter.

order_translator

ORDER BY operator configuration builder ORDER BY operator configuration builder

streaming_ddl

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

Structs

AsofJoinTranslatorConfig

Configuration for ASOF join operator

LookupJoinConfig

Configuration for lookup join operator

StreamJoinConfig

Configuration for stream-stream join operator

WindowOperatorConfig

Complete configuration for instantiating a window operator.

Enums

AsofSqlJoinType

ASOF join type

JoinOperatorConfig

Union type for join operator configurations

LookupJoinType

Lookup join types

StreamJoinType

Stream-stream join types

WindowType

Type of window operation