Skip to main content

laminar_sql/translator/
mod.rs

1//! SQL to operator configuration translation
2//!
3//! This module translates parsed SQL AST into Ring 0 operator configurations
4//! that can be instantiated and executed.
5
6/// Analytic window function operator configuration builder
7pub mod analytic_translator;
8/// DAG EXPLAIN formatter
9pub mod dag_planner;
10/// HAVING clause filter configuration
11pub mod having_translator;
12mod join_translator;
13/// ORDER BY operator configuration builder
14pub mod order_translator;
15/// Streaming DDL (CREATE SOURCE/SINK) translator
16pub mod streaming_ddl;
17mod window_translator;
18
19pub use crate::parser::order_analyzer::RankType;
20pub use analytic_translator::{
21    AnalyticFunctionConfig, AnalyticWindowConfig, WindowFrameConfig, WindowFrameFunctionConfig,
22};
23pub use dag_planner::{format_dag_explain, DagExplainOutput};
24pub use having_translator::HavingFilterConfig;
25pub use join_translator::{
26    AsofJoinTranslatorConfig, AsofSqlJoinType, JoinOperatorConfig, LookupJoinConfig,
27    LookupJoinType, StreamJoinConfig, StreamJoinType,
28};
29pub use order_translator::{
30    OrderOperatorConfig, PerGroupTopKConfig, TopKConfig, WatermarkSortConfig, WindowLocalSortConfig,
31};
32pub use streaming_ddl::{
33    sql_type_to_arrow, BackpressureStrategy as StreamingBackpressure, ColumnDefinition,
34    SinkDefinition, SourceConfigOptions, SourceDefinition, WaitStrategy as StreamingWaitStrategy,
35    WatermarkSpec,
36};
37pub use window_translator::{WindowOperatorConfig, WindowType};