lint

Author: waralexrom

rust/cubesqlplanner/cubesqlplanner/src/cube_bridge/measure_definition.rs

@@ -1,5 +1,4 @@
 use super::case_variant::CaseVariant;
-use super::cube_definition::CubeDefinition;
 use super::member_order_by::{MemberOrderBy, NativeMemberOrderBy};
 use super::member_sql::{MemberSql, NativeMemberSql};
 use super::struct_with_sql_member::{NativeStructWithSqlMember, StructWithSqlMember};

rust/cubesqlplanner/cubesqlplanner/src/logical_plan/multistage/dimension.rs

@@ -3,8 +3,6 @@ use crate::planner::query_properties::OrderByItem;
 use crate::planner::sql_evaluator::collectors::has_multi_stage_members;
 use crate::planner::sql_evaluator::MemberSymbol;
 use cubenativeutils::CubeError;
-use itertools::Itertools;
-use std::collections::HashSet;
 use std::rc::Rc;
 use typed_builder::TypedBuilder;
 

rust/cubesqlplanner/cubesqlplanner/src/physical_plan_builder/context.rs

@@ -1,12 +1,10 @@
 use cubenativeutils::CubeError;
-use itertools::Itertools;
 
-use crate::logical_plan::LogicalSchema;
 use crate::plan::Schema;
 use crate::planner::planners::multi_stage::TimeShiftState;
 use crate::planner::sql_evaluator::sql_nodes::SqlNodesFactory;
 use crate::planner::sql_evaluator::MemberSymbol;
-use std::collections::{HashMap, HashSet};
+use std::collections::HashMap;
 use std::rc::Rc;
 
 #[derive(Clone, Debug, Default)]

rust/cubesqlplanner/cubesqlplanner/src/physical_plan_builder/processors/full_key_aggregate.rs

@@ -1,6 +1,6 @@
 use super::super::{LogicalNodeProcessor, ProcessableNode, PushDownBuilderContext};
 use crate::logical_plan::{
-    pretty_print, FullKeyAggregate, LogicalJoin, ResolvedMultipliedMeasures,
+    FullKeyAggregate, LogicalJoin, ResolvedMultipliedMeasures,
 };
 use crate::physical_plan_builder::PhysicalPlanBuilder;
 use crate::plan::{

rust/cubesqlplanner/cubesqlplanner/src/physical_plan_builder/processors/multi_stage_dimension_calculation.rs

@@ -1,11 +1,10 @@
 use super::super::context::PushDownBuilderContext;
 use super::super::{LogicalNodeProcessor, ProcessableNode};
-use crate::logical_plan::{MultiStageCalculationWindowFunction, MultiStageDimensionCalculation};
+use crate::logical_plan::MultiStageDimensionCalculation;
 use crate::physical_plan_builder::PhysicalPlanBuilder;
 use crate::plan::{Expr, MemberExpression, QueryPlan, SelectBuilder};
 use crate::planner::sql_evaluator::ReferencesBuilder;
 use cubenativeutils::CubeError;
-use itertools::Itertools;
 use std::rc::Rc;
 
 pub struct MultiStageDimensionCalculationProcessor<'a> {
@@ -25,7 +24,7 @@ impl<'a> LogicalNodeProcessor<'a, MultiStageDimensionCalculation>
         measure_calculation: &MultiStageDimensionCalculation,
         context: &PushDownBuilderContext,
     ) -> Result<Self::PhysycalNode, CubeError> {
-        let (query_tools, templates) = self.builder.qtools_and_templates();
+        let query_tools = self.builder.query_tools();
         let mut context_factory = context.make_sql_nodes_factory()?;
         let from = self
             .builder

rust/cubesqlplanner/cubesqlplanner/src/physical_plan_builder/processors/query.rs

@@ -24,15 +24,6 @@ impl QueryProcessor<'_> {
             QuerySource::LogicalJoin(_) => false,
         }
     }
-    fn is_multi_stage_source(&self, logical_plan: &Query) -> bool {
-        match logical_plan.source() {
-            QuerySource::FullKeyAggregate(full_key_aggregate) => {
-                !full_key_aggregate.multi_stage_subquery_refs().is_empty()
-            }
-            QuerySource::PreAggregation(_) => false,
-            QuerySource::LogicalJoin(_) => false,
-        }
-    }
 }
 
 impl<'a> LogicalNodeProcessor<'a, Query> for QueryProcessor<'a> {

rust/cubesqlplanner/cubesqlplanner/src/planner/planners/dimension_subquery_planner.rs

@@ -9,7 +9,7 @@ use crate::planner::sql_evaluator::{
 use crate::planner::QueryProperties;
 use cubenativeutils::CubeError;
 use std::cell::{Ref, RefCell};
-use std::collections::{HashMap, HashSet};
+use std::collections::HashMap;
 use std::rc::Rc;
 
 pub struct DimensionSubqueryPlanner {

rust/cubesqlplanner/cubesqlplanner/src/planner/planners/multi_stage/member.rs

@@ -1,5 +1,5 @@
 use crate::planner::sql_evaluator::{MeasureTimeShifts, MemberSymbol};
-use std::{collections::HashSet, rc::Rc};
+use std::rc::Rc;
 
 #[derive(Clone)]
 pub struct TimeSeriesDescription {

rust/cubesqlplanner/cubesqlplanner/src/planner/planners/multi_stage/member_query_planner.rs

@@ -11,7 +11,6 @@ use crate::planner::{OrderByItem, QueryProperties};
 
 use cubenativeutils::CubeError;
 use itertools::Itertools;
-use std::collections::HashSet;
 use std::rc::Rc;
 use std::vec;
 

rust/cubesqlplanner/cubesqlplanner/src/planner/sql_evaluator/collectors/join_hints_collector.rs

@@ -1,5 +1,4 @@
 use crate::cube_bridge::join_hints::JoinHintItem;
-use crate::planner::sql_evaluator::collectors::has_multi_stage_members;
 use crate::planner::sql_evaluator::{MemberSymbol, TraversalVisitor};
 use cubenativeutils::CubeError;
 use itertools::Itertools;