Skip to content

chore(tesseract): replace SqlNode trait with Op pipeline #10848

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
waralexrom wants to merge 11 commits into
base: master
Choose a base branch
from
Open

chore(tesseract): replace SqlNode trait with Op pipeline #10848

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
11 commits
Select commit Hold shift + click to select a range
6d44259
chore(tesseract): introduce Op pipeline foundation in sql_nodes
waralexrom May 8, 2026
dfeb4ad
chore(tesseract): migrate AutoPrefix/GeoDimension/MeasureFilter/Rende…
waralexrom May 8, 2026
d46b194
chore(tesseract): migrate Masked/Case/Root to Op (kind dispatch)
waralexrom May 8, 2026
155abbd
chore(tesseract): migrate measure final wrappers to Op
waralexrom May 8, 2026
1f165a2
chore(tesseract): migrate time/multi-stage/rolling nodes to Op
waralexrom May 8, 2026
cae252a
chore(tesseract): add structural validation for Op pipelines
waralexrom May 8, 2026
af7f841
chore(tesseract): drop SqlNode trait, factory returns NodeProcessor
waralexrom May 8, 2026
19c5267
chore(tesseract): tighten Op pipeline docstrings
waralexrom May 8, 2026
b68adfa
chore(tesseract): fix clippy warnings in Op pipeline
waralexrom May 8, 2026
6690d67
chore(tesseract): add Debug, fold Op dispatch into a macro, drop unwrap
waralexrom May 8, 2026
c6fb073
chore(tesseract): move nested_pipelines into OpExec
waralexrom May 8, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions rust/cube/cubesqlplanner/cubesqlplanner/src/physical_plan/cube_ref_evaluator.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
use super::sql_nodes::SqlNode;
use super::sql_nodes::NodeProcessor;
use super::SqlEvaluatorVisitor;
use crate::planner::query_tools::QueryTools;
use crate::planner::sql_call::CubeRef;
Expand Down Expand Up @@ -27,7 +27,7 @@ impl CubeRefEvaluator {
&self,
cube_ref: &CubeRef,
visitor: &SqlEvaluatorVisitor,
node_processor: Rc<dyn SqlNode>,
node_processor: Rc<NodeProcessor>,
query_tools: Rc<QueryTools>,
templates: &PlanSqlTemplates,
) -> Result<String, CubeError> {
Expand Down
4 changes: 2 additions & 2 deletions rust/cube/cubesqlplanner/cubesqlplanner/src/physical_plan/filter/base_filter.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
use super::ToSql;
use crate::physical_plan::sql_nodes::SqlNode;
use crate::physical_plan::sql_nodes::NodeProcessor;
use crate::physical_plan::SqlEvaluatorVisitor;
use crate::planner::filter::typed_filter::resolve_base_symbol;
use crate::planner::filter::BaseFilter;
Expand All @@ -13,7 +13,7 @@ impl ToSql for BaseFilter {
fn to_sql(
&self,
visitor: &SqlEvaluatorVisitor,
node_processor: Rc<dyn SqlNode>,
node_processor: Rc<NodeProcessor>,
query_tools: Rc<QueryTools>,
templates: &PlanSqlTemplates,
filters_ctx: &FiltersContext,
Expand Down
4 changes: 2 additions & 2 deletions rust/cube/cubesqlplanner/cubesqlplanner/src/physical_plan/filter/base_segment.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
use super::ToSql;
use crate::physical_plan::sql_nodes::SqlNode;
use crate::physical_plan::sql_nodes::NodeProcessor;
use crate::physical_plan::SqlEvaluatorVisitor;
use crate::planner::filter::BaseSegment;
use crate::planner::query_tools::QueryTools;
Expand All @@ -12,7 +12,7 @@ impl ToSql for BaseSegment {
fn to_sql(
&self,
visitor: &SqlEvaluatorVisitor,
node_processor: Rc<dyn SqlNode>,
node_processor: Rc<NodeProcessor>,
_query_tools: Rc<QueryTools>,
templates: &PlanSqlTemplates,
_filters_ctx: &FiltersContext,
Expand Down
6 changes: 3 additions & 3 deletions rust/cube/cubesqlplanner/cubesqlplanner/src/physical_plan/filter/filter.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
use super::ToSql;
use crate::physical_plan::sql_nodes::SqlNode;
use crate::physical_plan::sql_nodes::NodeProcessor;
use crate::physical_plan::SqlEvaluatorVisitor;
use crate::planner::filter::{Filter, FilterItem};
use crate::planner::query_tools::QueryTools;
Expand All @@ -12,7 +12,7 @@ impl ToSql for FilterItem {
fn to_sql(
&self,
visitor: &SqlEvaluatorVisitor,
node_processor: Rc<dyn SqlNode>,
node_processor: Rc<NodeProcessor>,
query_tools: Rc<QueryTools>,
templates: &PlanSqlTemplates,
filters_ctx: &FiltersContext,
Expand Down Expand Up @@ -62,7 +62,7 @@ impl ToSql for Filter {
fn to_sql(
&self,
visitor: &SqlEvaluatorVisitor,
node_processor: Rc<dyn SqlNode>,
node_processor: Rc<NodeProcessor>,
query_tools: Rc<QueryTools>,
templates: &PlanSqlTemplates,
filters_ctx: &FiltersContext,
Expand Down
4 changes: 2 additions & 2 deletions rust/cube/cubesqlplanner/cubesqlplanner/src/physical_plan/filter/operators/measure_filter.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
use crate::physical_plan::sql_nodes::SqlNode;
use crate::physical_plan::sql_nodes::NodeProcessor;
use crate::physical_plan::SqlEvaluatorVisitor;
use crate::planner::filter::operators::measure_filter::MeasureFilterOp;
use crate::planner::query_tools::QueryTools;
Expand All @@ -12,7 +12,7 @@ impl MeasureFilterOp {
&self,
member_evaluator: &Rc<MemberSymbol>,
visitor: &SqlEvaluatorVisitor,
node_processor: Rc<dyn SqlNode>,
node_processor: Rc<NodeProcessor>,
query_tools: Rc<QueryTools>,
plan_templates: &PlanSqlTemplates,
) -> Result<String, CubeError> {
Expand Down
4 changes: 2 additions & 2 deletions rust/cube/cubesqlplanner/cubesqlplanner/src/physical_plan/filter/to_sql.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
use crate::physical_plan::sql_nodes::SqlNode;
use crate::physical_plan::sql_nodes::NodeProcessor;
use crate::physical_plan::SqlEvaluatorVisitor;
use crate::planner::query_tools::QueryTools;
use crate::planner::sql_templates::PlanSqlTemplates;
Expand All @@ -10,7 +10,7 @@ pub trait ToSql {
fn to_sql(
&self,
visitor: &SqlEvaluatorVisitor,
node_processor: Rc<dyn SqlNode>,
node_processor: Rc<NodeProcessor>,
query_tools: Rc<QueryTools>,
templates: &PlanSqlTemplates,
filters_ctx: &FiltersContext,
Expand Down
4 changes: 2 additions & 2 deletions rust/cube/cubesqlplanner/cubesqlplanner/src/physical_plan/filter/typed_filter.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
use super::operators::{FilterOperationSql, FilterSqlContext};
use super::ToSql;
use crate::cube_bridge::member_sql::FilterParamsColumn;
use crate::physical_plan::sql_nodes::SqlNode;
use crate::physical_plan::sql_nodes::NodeProcessor;
use crate::physical_plan::SqlEvaluatorVisitor;
use crate::planner::filter::typed_filter::{resolve_base_symbol, FilterOp, TypedFilter};
use crate::planner::query_tools::QueryTools;
Expand All @@ -14,7 +14,7 @@ impl ToSql for TypedFilter {
fn to_sql(
&self,
visitor: &SqlEvaluatorVisitor,
node_processor: Rc<dyn SqlNode>,
node_processor: Rc<NodeProcessor>,
query_tools: Rc<QueryTools>,
templates: &PlanSqlTemplates,
filters_ctx: &FiltersContext,
Expand Down
119 changes: 0 additions & 119 deletions rust/cube/cubesqlplanner/cubesqlplanner/src/physical_plan/sql_nodes/auto_prefix.rs
View file
Open in desktop

This file was deleted.

108 changes: 0 additions & 108 deletions rust/cube/cubesqlplanner/cubesqlplanner/src/physical_plan/sql_nodes/calendar_time_shift.rs
View file
Open in desktop

This file was deleted.

Loading
Loading