cargo fmt --all

Author: KSDaemon

rust/cubesqlplanner/cubesqlplanner/src/logical_plan/optimizers/pre_aggregation/measure_matcher.rs

@@ -24,7 +24,9 @@ impl MeasureMatcher {
     pub fn try_match(&self, symbol: &Rc<MemberSymbol>) -> Result<bool, CubeError> {
         match symbol.as_ref() {
             MemberSymbol::Measure(measure) => {
-                if self.pre_aggregation_measures.contains(&measure.full_name()) && (!self.only_addictive || measure.is_addictive()) {
+                if self.pre_aggregation_measures.contains(&measure.full_name())
+                    && (!self.only_addictive || measure.is_addictive())
+                {
                     return Ok(true);
                 }
             }

rust/cubesqlplanner/cubesqlplanner/src/logical_plan/optimizers/pre_aggregation/optimizer.rs

@@ -233,7 +233,9 @@ impl PreAggregationOptimizer {
         }
 
         if let Some(multi_stage_item) = multi_stage_queries
-            .iter().find(|&query| &query.name == multi_stage_name).cloned()
+            .iter()
+            .find(|&query| &query.name == multi_stage_name)
+            .cloned()
         {
             match &multi_stage_item.member_type {
                 MultiStageMemberLogicalType::LeafMeasure(multi_stage_leaf_measure) => self

rust/cubesqlplanner/cubesqlplanner/src/physical_plan_builder/builder.rs

@@ -19,8 +19,7 @@ use std::rc::Rc;
 const TOTAL_COUNT: &str = "total_count";
 const ORIGINAL_QUERY: &str = "original_query";
 
-#[derive(Clone, Debug)]
-#[derive(Default)]
+#[derive(Clone, Debug, Default)]
 struct PhysicalPlanBuilderContext {
     pub alias_prefix: Option<String>,
     pub render_measure_as_state: bool, //Render measure as state, for example hll state for count_approx
@@ -29,7 +28,6 @@ struct PhysicalPlanBuilderContext {
     pub original_sql_pre_aggregations: HashMap<String, String>,
 }
 
-
 impl PhysicalPlanBuilderContext {
     pub fn make_sql_nodes_factory(&self) -> SqlNodesFactory {
         let mut factory = SqlNodesFactory::new();

rust/cubesqlplanner/cubesqlplanner/src/planner/query_properties.rs

@@ -796,7 +796,8 @@ impl QueryProperties {
                 result.multi_stage_measures.push(m.clone())
             } else {
                 let join = self
-                    .compute_join_multi_fact_groups_with_measures(&vec![m.clone()])?.first()
+                    .compute_join_multi_fact_groups_with_measures(&vec![m.clone()])?
+                    .first()
                     .expect("No join groups returned for single measure multi-fact join group")
                     .0
                     .clone();
@@ -843,9 +844,7 @@ impl QueryProperties {
             }
             FilterItem::Item(item) => {
                 let item_member_name = item.member_name();
-                if !measures
-                    .iter().any(|m| m.full_name() == item_member_name)
-                {
+                if !measures.iter().any(|m| m.full_name() == item_member_name) {
                     measures.push(BaseMeasure::try_new_required(
                         item.member_evaluator().clone(),
                         self.query_tools.clone(),

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

@@ -27,7 +27,9 @@ impl SubQueryDimensionsCollector {
 
     fn check_dim_has_measures(&self, dim: &DimensionSymbol) -> bool {
         for dep in dim.get_dependencies().iter() {
-            if let MemberSymbol::Measure(_) = dep.as_ref() { return true }
+            if let MemberSymbol::Measure(_) = dep.as_ref() {
+                return true;
+            }
         }
         false
     }

rust/cubesqlplanner/cubesqlplanner/src/planner/time_dimension/sql_interval.rs

@@ -3,8 +3,7 @@ use itertools::Itertools;
 use std::ops::{Add, AddAssign, Neg, Sub};
 use std::str::FromStr;
 
-#[derive(Debug, PartialEq, Clone, Hash, Eq)]
-#[derive(Default)]
+#[derive(Debug, PartialEq, Clone, Hash, Eq, Default)]
 pub struct SqlInterval {
     pub year: i32,
     pub month: i32,

rust/cubesqlplanner/cubesqlplanner/src/planner/visitor_context.rs

@@ -12,7 +12,6 @@ pub struct FiltersContext {
     pub use_local_tz: bool,
 }
 
-
 pub struct VisitorContext {
     node_processor: Rc<dyn SqlNode>,
     all_filters: Option<Filter>, //To pass to FILTER_PARAMS and FILTER_GROUP