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 crate::temporal::TemporalJoinKind;

pub use crate::temporal::TemporalProbeSchedule;

pub use analytic_translator::AnalyticFunctionConfig;

pub use analytic_translator::AnalyticWindowConfig;

pub use analytic_translator::WindowFrameConfig;

pub use analytic_translator::WindowFrameFunctionConfig;

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::ColumnDefinition;

pub use streaming_ddl::SourceConfigOptions;

pub use streaming_ddl::SourceDefinition;

pub use streaming_ddl::WatermarkSpec;

Modules

analytic_translator

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

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

LookupJoinConfig

Configuration for lookup join operator

StreamJoinConfig

Configuration for stream-stream join operator

TemporalJoinTranslatorConfig

Configuration for temporal join operator (FOR SYSTEM_TIME AS OF).

WindowOperatorConfig

Complete configuration for instantiating a window operator.

Enums

JoinOperatorConfig

Union type for join operator configurations

LookupJoinType

Lookup join types

WindowType

Type of window operation