lint

Author: waralexrom

rust/cubesqlplanner/cubesqlplanner/src/logical_plan/full_key_aggregate.rs

@@ -117,26 +117,30 @@ impl LogicalNode for FullKeyAggregate {
             check_inputs_len(&inputs, 1, self.node_name())?;
             let input_source = &inputs[0];
 
-            Some(match self.multiplied_measures_resolver().as_ref().unwrap() {
-                ResolvedMultipliedMeasures::ResolveMultipliedMeasures(_) => {
-                    ResolvedMultipliedMeasures::ResolveMultipliedMeasures(
-                        input_source.clone().into_logical_node()?,
-                    )
-                }
-                ResolvedMultipliedMeasures::PreAggregation(_) => {
-                    ResolvedMultipliedMeasures::PreAggregation(
-                        input_source.clone().into_logical_node()?,
-                    )
-                }
-            })
+            Some(
+                match self.multiplied_measures_resolver().as_ref().unwrap() {
+                    ResolvedMultipliedMeasures::ResolveMultipliedMeasures(_) => {
+                        ResolvedMultipliedMeasures::ResolveMultipliedMeasures(
+                            input_source.clone().into_logical_node()?,
+                        )
+                    }
+                    ResolvedMultipliedMeasures::PreAggregation(_) => {
+                        ResolvedMultipliedMeasures::PreAggregation(
+                            input_source.clone().into_logical_node()?,
+                        )
+                    }
+                },
+            )
         };
 
-        Ok(Rc::new(Self::builder()
-            .schema(self.schema().clone())
-            .use_full_join_and_coalesce(self.use_full_join_and_coalesce())
-            .multiplied_measures_resolver(multiplied_measures_resolver)
-            .multi_stage_subquery_refs(self.multi_stage_subquery_refs().clone())
-            .build()))
+        Ok(Rc::new(
+            Self::builder()
+                .schema(self.schema().clone())
+                .use_full_join_and_coalesce(self.use_full_join_and_coalesce())
+                .multiplied_measures_resolver(multiplied_measures_resolver)
+                .multi_stage_subquery_refs(self.multi_stage_subquery_refs().clone())
+                .build(),
+        ))
     }
 
     fn node_name(&self) -> &'static str {

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

@@ -86,7 +86,10 @@ impl MultiStageMeasureCalculation {
 impl PrettyPrint for MultiStageMeasureCalculation {
     fn pretty_print(&self, result: &mut PrettyPrintResult, state: &PrettyPrintState) {
         result.println(
-            &format!("Measure Calculation: {}", self.calculation_type().to_string()),
+            &format!(
+                "Measure Calculation: {}",
+                self.calculation_type().to_string()
+            ),
             state,
         );
         let state = state.new_level();
@@ -145,15 +148,17 @@ impl LogicalNode for MultiStageMeasureCalculation {
         check_inputs_len(&inputs, 1, self.node_name())?;
         let source = &inputs[0];
 
-        Ok(Rc::new(Self::builder()
-            .schema(self.schema().clone())
-            .is_ungrouped(self.is_ungrouped())
-            .calculation_type(self.calculation_type().clone())
-            .partition_by(self.partition_by().clone())
-            .window_function_to_use(self.window_function_to_use().clone())
-            .order_by(self.order_by().clone())
-            .source(source.clone().into_logical_node()?)
-            .build()))
+        Ok(Rc::new(
+            Self::builder()
+                .schema(self.schema().clone())
+                .is_ungrouped(self.is_ungrouped())
+                .calculation_type(self.calculation_type().clone())
+                .partition_by(self.partition_by().clone())
+                .window_function_to_use(self.window_function_to_use().clone())
+                .order_by(self.order_by().clone())
+                .source(source.clone().into_logical_node()?)
+                .build(),
+        ))
     }
 
     fn node_name(&self) -> &'static str {

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

@@ -1,7 +1,5 @@
 use super::super::{LogicalNodeProcessor, ProcessableNode, PushDownBuilderContext};
-use crate::logical_plan::{
-    FullKeyAggregate, LogicalJoin, ResolvedMultipliedMeasures,
-};
+use crate::logical_plan::{FullKeyAggregate, LogicalJoin, ResolvedMultipliedMeasures};
 use crate::physical_plan_builder::PhysicalPlanBuilder;
 use crate::plan::{
     Expr, From, FromSource, JoinBuilder, JoinCondition, QualifiedColumnName, SelectBuilder,

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

@@ -38,12 +38,14 @@ impl FullKeyAggregateQueryPlanner {
             .set_time_dimensions(self.query_properties.time_dimensions().clone())
             .set_measures(measures)
             .into_rc();
-        Ok(Rc::new(FullKeyAggregate::builder()
-            .multiplied_measures_resolver(resolved_multiplied_source)
-            .multi_stage_subquery_refs(multi_stage_subquery_refs)
-            .use_full_join_and_coalesce(true)
-            .schema(schema)
-            .build()))
+        Ok(Rc::new(
+            FullKeyAggregate::builder()
+                .multiplied_measures_resolver(resolved_multiplied_source)
+                .multi_stage_subquery_refs(multi_stage_subquery_refs)
+                .use_full_join_and_coalesce(true)
+                .schema(schema)
+                .build(),
+        ))
     }
 
     pub fn plan_logical_plan(

rust/cubesqlplanner/cubesqlplanner/src/planner/sql_evaluator/symbols/measure_symbol.rs

@@ -5,8 +5,8 @@ use crate::cube_bridge::measure_definition::{MeasureDefinition, RollingWindow};
 use crate::cube_bridge::member_sql::MemberSql;
 use crate::planner::query_tools::QueryTools;
 use crate::planner::sql_evaluator::collectors::find_owned_by_cube_child;
-use crate::planner::sql_evaluator::{sql_nodes::SqlNode, Compiler, SqlCall, SqlEvaluatorVisitor};
 use crate::planner::sql_evaluator::CubeTableSymbol;
+use crate::planner::sql_evaluator::{sql_nodes::SqlNode, Compiler, SqlCall, SqlEvaluatorVisitor};
 use crate::planner::sql_templates::PlanSqlTemplates;
 use crate::planner::SqlInterval;
 use cubenativeutils::CubeError;

rust/cubesqlplanner/cubesqlplanner/src/planner/sql_evaluator/symbols/member_symbol.rs

@@ -135,7 +135,9 @@ impl MemberSymbol {
         match self {
             MemberSymbol::Dimension(dimension_symbol) => dimension_symbol.case(),
             MemberSymbol::Measure(measure_symbol) => measure_symbol.case(),
-            MemberSymbol::TimeDimension(time_dimension_symbol) => time_dimension_symbol.base_symbol().case(),
+            MemberSymbol::TimeDimension(time_dimension_symbol) => {
+                time_dimension_symbol.base_symbol().case()
+            }
             _ => None,
         }
     }

rust/cubesqlplanner/cubesqlplanner/src/planner/sql_templates/plan.rs

@@ -1,8 +1,8 @@
 use super::{TemplateGroupByColumn, TemplateOrderByColumn, TemplateProjectionColumn};
+use crate::cube_bridge::driver_tools::DriverTools;
 use crate::cube_bridge::sql_templates_render::SqlTemplatesRender;
 use crate::plan::join::JoinType;
 use crate::planner::sql_templates::structs::TemplateCalcGroup;
-use crate::cube_bridge::driver_tools::DriverTools;
 use convert_case::{Boundary, Case, Casing};
 use cubenativeutils::CubeError;
 use minijinja::context;