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/// HAVING clause filter configuration
9pub mod having_translator;
10mod join_translator;
11/// ORDER BY operator configuration builder
12pub mod order_translator;
13/// Streaming DDL (CREATE SOURCE/SINK) translator
14pub mod streaming_ddl;
15/// Temporal probe join configuration
16pub mod temporal_probe;
17mod window_translator;
18
19pub use crate::parser::order_analyzer::RankType;
20pub use analytic_translator::{
21    AnalyticFunctionConfig, AnalyticWindowConfig, WindowFrameConfig, WindowFrameFunctionConfig,
22};
23pub use having_translator::HavingFilterConfig;
24pub use join_translator::{
25    AsofJoinTranslatorConfig, AsofSqlJoinType, JoinOperatorConfig, LookupJoinConfig,
26    LookupJoinType, StreamJoinConfig, StreamJoinType, TemporalJoinTranslatorConfig,
27};
28pub use laminar_core::streaming::config::{
29    BackpressureStrategy as StreamingBackpressure, WaitStrategy as StreamingWaitStrategy,
30};
31pub use order_translator::{
32    OrderOperatorConfig, PerGroupTopKConfig, TopKConfig, WatermarkSortConfig, WindowLocalSortConfig,
33};
34pub use streaming_ddl::{
35    sql_type_to_arrow, ColumnDefinition, SinkDefinition, SourceConfigOptions, SourceDefinition,
36    WatermarkSpec,
37};
38pub use temporal_probe::{parse_interval_to_ms, ProbeOffsetSpec, TemporalProbeConfig};
39pub use window_translator::{WindowOperatorConfig, WindowType};
laminar_sql/translator/mod.rs

laminar_sql/translator/
mod.rs
