rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-05-25 09:20:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

remove rule

Browse Source 
Signed-off-by: Ruihang Xia <waynestxia@gmail.com>
This commit is contained in:
Ruihang Xia
2026-04-03 13:02:57 +08:00
parent 36a5023f67
commit 2bf9ba2496
4 changed files with 0 additions and 1295 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
src/query/src/optimizer.rs
View File

@@ -15,7 +15,6 @@
pub mod constant_term;
pub mod count_nest_aggr;
pub mod count_wildcard;
pub mod join_reduce;
pub mod parallelize_scan;
pub mod pass_distribution;
pub mod remove_duplicate;

1285
src/query/src/optimizer/join_reduce.rs
View File

File diff suppressed because it is too large Load Diff

5
src/query/src/query_engine/state.rs
View File

@@ -62,7 +62,6 @@ use crate::optimizer::ExtensionAnalyzerRule;
use crate::optimizer::constant_term::MatchesConstantTermOptimizer;
use crate::optimizer::count_nest_aggr::CountNestAggrRule;
use crate::optimizer::count_wildcard::CountWildcardToTimeIndexRule;
use crate::optimizer::join_reduce::JoinReduceRule;
use crate::optimizer::parallelize_scan::ParallelizeScan;
use crate::optimizer::pass_distribution::PassDistribution;
use crate::optimizer::remove_duplicate::RemoveDuplicate;
@@ -174,10 +173,6 @@ impl QueryEngineState {
analyzer.rules.push(Arc::new(FixStateUdafOrderingAnalyzer));
let mut optimizer = Optimizer::new();
let join_reduce_insert_at = optimizer.rules.len().saturating_sub(1);
optimizer
.rules
.insert(join_reduce_insert_at, Arc::new(JoinReduceRule));
optimizer.rules.push(Arc::new(ScanHintRule));
// add physical optimizer

4
tests/cases/standalone/common/tql-explain-analyze/explain.result
View File

@@ -123,7 +123,6 @@ TQL EXPLAIN VERBOSE (0, 10, '5s') test;
| logical_plan after common_sub_expression_eliminate_| SAME TEXT AS ABOVE_|
| logical_plan after extract_leaf_expressions_| SAME TEXT AS ABOVE_|
| logical_plan after push_down_leaf_projections_| SAME TEXT AS ABOVE_|
| logical_plan after JoinReduceRule_| SAME TEXT AS ABOVE_|
| logical_plan after optimize_projections_| MergeScan [is_placeholder=false, remote_input=[_|
|_| PromInstantManipulate: range=[0..10000], lookback=[300000], interval=[5000], time index=[j]_|
|_|_PromSeriesDivide: tags=["k"]_|
@@ -155,7 +154,6 @@ TQL EXPLAIN VERBOSE (0, 10, '5s') test;
| logical_plan after common_sub_expression_eliminate_| SAME TEXT AS ABOVE_|
| logical_plan after extract_leaf_expressions_| SAME TEXT AS ABOVE_|
| logical_plan after push_down_leaf_projections_| SAME TEXT AS ABOVE_|
| logical_plan after JoinReduceRule_| SAME TEXT AS ABOVE_|
| logical_plan after optimize_projections_| SAME TEXT AS ABOVE_|
| logical_plan after ScanHintRule_| SAME TEXT AS ABOVE_|
| logical_plan_| MergeScan [is_placeholder=false, remote_input=[_|
@@ -269,7 +267,6 @@ TQL EXPLAIN VERBOSE (0, 10, '5s') test AS series;
| logical_plan after common_sub_expression_eliminate_| SAME TEXT AS ABOVE_|
| logical_plan after extract_leaf_expressions_| SAME TEXT AS ABOVE_|
| logical_plan after push_down_leaf_projections_| SAME TEXT AS ABOVE_|
| logical_plan after JoinReduceRule_| SAME TEXT AS ABOVE_|
| logical_plan after optimize_projections_| MergeScan [is_placeholder=false, remote_input=[_|
|_| Projection: test.i AS series, test.k, test.j_|
|_|_PromInstantManipulate: range=[0..10000], lookback=[300000], interval=[5000], time index=[j]_|
@@ -302,7 +299,6 @@ TQL EXPLAIN VERBOSE (0, 10, '5s') test AS series;
| logical_plan after common_sub_expression_eliminate_| SAME TEXT AS ABOVE_|
| logical_plan after extract_leaf_expressions_| SAME TEXT AS ABOVE_|
| logical_plan after push_down_leaf_projections_| SAME TEXT AS ABOVE_|
| logical_plan after JoinReduceRule_| SAME TEXT AS ABOVE_|
| logical_plan after optimize_projections_| SAME TEXT AS ABOVE_|
| logical_plan after ScanHintRule_| SAME TEXT AS ABOVE_|
| logical_plan_| MergeScan [is_placeholder=false, remote_input=[_|