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;
10mod join_translator;
11/// ORDER BY operator configuration builder
12pub mod order_translator;
13/// Streaming DDL (CREATE SOURCE/SINK) translator
14pub mod streaming_ddl;
15mod window_translator;
16
17pub use crate::parser::order_analyzer::RankType;
18pub use analytic_translator::{AnalyticFunctionConfig, AnalyticWindowConfig};
19pub use dag_planner::{format_dag_explain, DagExplainOutput};
20pub use join_translator::{
21    AsofJoinTranslatorConfig, AsofSqlJoinType, JoinOperatorConfig, LookupJoinConfig,
22    LookupJoinType, StreamJoinConfig, StreamJoinType,
23};
24pub use order_translator::{
25    OrderOperatorConfig, PerGroupTopKConfig, TopKConfig, WatermarkSortConfig, WindowLocalSortConfig,
26};
27pub use streaming_ddl::{
28    sql_type_to_arrow, BackpressureStrategy as StreamingBackpressure, ColumnDefinition,
29    SinkDefinition, SourceConfigOptions, SourceDefinition, WaitStrategy as StreamingWaitStrategy,
30    WatermarkSpec,
31};
32pub use window_translator::{WindowOperatorConfig, WindowType};