Skip to content

Commit 4293241

Browse files
committed
remove dublicated functions
1 parent 9fd7eb7 commit 4293241

File tree

6 files changed

+21
-36
lines changed

6 files changed

+21
-36
lines changed

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

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -34,8 +34,8 @@ impl FullKeyAggregateQueryPlanner {
3434
};
3535

3636
let schema = LogicalSchema::default()
37-
.set_dimensions(self.query_properties.dimension_symbols())
38-
.set_time_dimensions(self.query_properties.time_dimension_symbols())
37+
.set_dimensions(self.query_properties.dimensions().clone())
38+
.set_time_dimensions(self.query_properties.time_dimensions().clone())
3939
.set_measures(measures)
4040
.into_rc();
4141
Ok(Rc::new(FullKeyAggregate {
@@ -62,9 +62,9 @@ impl FullKeyAggregateQueryPlanner {
6262
.rendered_as_multiplied_measures
6363
.clone();
6464
let schema = LogicalSchema::default()
65-
.set_dimensions(self.query_properties.dimension_symbols())
66-
.set_time_dimensions(self.query_properties.time_dimension_symbols())
67-
.set_measures(self.query_properties.measure_symbols())
65+
.set_dimensions(self.query_properties.dimensions().clone())
66+
.set_time_dimensions(self.query_properties.time_dimensions().clone())
67+
.set_measures(self.query_properties.measures().clone())
6868
.set_multiplied_measures(multiplied_measures)
6969
.into_rc();
7070

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -154,8 +154,8 @@ impl MultiStageMemberQueryPlanner {
154154
};
155155

156156
let schema = LogicalSchema::default()
157-
.set_dimensions(self.query_properties.dimension_symbols())
158-
.set_time_dimensions(self.query_properties.time_dimension_symbols())
157+
.set_dimensions(self.query_properties.dimensions().clone())
158+
.set_time_dimensions(self.query_properties.time_dimensions().clone())
159159
.set_measures(vec![self.description.member().evaluation_node().clone()])
160160
.into_rc();
161161

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -289,8 +289,8 @@ impl MultiStageQueryPlanner {
289289
.iter()
290290
.map(|d| d.as_time_dimension())
291291
.collect::<Result<Vec<_>, _>>()?;
292-
for dim in self.query_properties.dimension_symbols() {
293-
let dim = dim.resolve_reference_chain();
292+
for dim in self.query_properties.dimensions() {
293+
let dim = dim.clone().resolve_reference_chain();
294294
if let Ok(time_dimension) = dim.as_time_dimension() {
295295
time_dimensions.push(time_dimension);
296296
}

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

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -103,8 +103,8 @@ impl MultipliedMeasuresQueryPlanner {
103103
.map(|m| m.clone())
104104
.collect_vec();
105105
let schema = LogicalSchema::default()
106-
.set_time_dimensions(self.query_properties.time_dimension_symbols())
107-
.set_dimensions(self.query_properties.dimension_symbols())
106+
.set_time_dimensions(self.query_properties.time_dimensions().clone())
107+
.set_dimensions(self.query_properties.dimensions().clone())
108108
.set_measures(all_measures)
109109
.set_multiplied_measures(
110110
full_key_aggregate_measures
@@ -150,8 +150,8 @@ impl MultipliedMeasuresQueryPlanner {
150150
self.key_query(&primary_keys_dimensions, key_join.clone(), key_cube_name)?;
151151

152152
let schema = LogicalSchema::default()
153-
.set_dimensions(self.query_properties.dimension_symbols())
154-
.set_time_dimensions(self.query_properties.time_dimension_symbols())
153+
.set_dimensions(self.query_properties.dimensions().clone())
154+
.set_time_dimensions(self.query_properties.time_dimensions().clone())
155155
.set_measures(measures.clone())
156156
.set_multiplied_measures(
157157
self.full_key_aggregate_measures
@@ -272,8 +272,8 @@ impl MultipliedMeasuresQueryPlanner {
272272
.make_join_logical_plan(join, subquery_dimension_queries.clone())?;
273273

274274
let schema = LogicalSchema::default()
275-
.set_dimensions(self.query_properties.dimension_symbols())
276-
.set_time_dimensions(self.query_properties.time_dimension_symbols())
275+
.set_dimensions(self.query_properties.dimensions().clone())
276+
.set_time_dimensions(self.query_properties.time_dimensions().clone())
277277
.set_measures(measures.clone())
278278
.set_multiplied_measures(
279279
self.full_key_aggregate_measures
@@ -337,8 +337,8 @@ impl MultipliedMeasuresQueryPlanner {
337337
});
338338

339339
let schema = LogicalSchema::default()
340-
.set_dimensions(self.query_properties.dimension_symbols())
341-
.set_time_dimensions(self.query_properties.time_dimension_symbols())
340+
.set_dimensions(self.query_properties.dimensions().clone())
341+
.set_time_dimensions(self.query_properties.time_dimensions().clone())
342342
.into_rc();
343343

344344
let keys_query = KeysSubQuery {

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -29,9 +29,9 @@ impl SimpleQueryPlanner {
2929
.rendered_as_multiplied_measures
3030
.clone();
3131
let schema = LogicalSchema::default()
32-
.set_dimensions(self.query_properties.dimension_symbols())
33-
.set_measures(self.query_properties.measure_symbols())
34-
.set_time_dimensions(self.query_properties.time_dimension_symbols())
32+
.set_dimensions(self.query_properties.dimensions().clone())
33+
.set_measures(self.query_properties.measures().clone())
34+
.set_time_dimensions(self.query_properties.time_dimensions().clone())
3535
.set_multiplied_measures(multiplied_measures)
3636
.into_rc();
3737
let logical_filter = Rc::new(LogicalFilter {
@@ -58,7 +58,7 @@ impl SimpleQueryPlanner {
5858
pub fn source_and_subquery_dimensions(&self) -> Result<Rc<LogicalJoin>, CubeError> {
5959
let join = self.query_properties.simple_query_join()?;
6060
let subquery_dimensions = collect_sub_query_dimensions_from_symbols(
61-
&self.query_properties.all_member_symbols(false),
61+
&self.query_properties.all_members(false),
6262
&self.join_planner,
6363
&join,
6464
)?;

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

Lines changed: 0 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -620,18 +620,6 @@ impl QueryProperties {
620620
&self.dimensions
621621
}
622622

623-
pub fn dimension_symbols(&self) -> Vec<Rc<MemberSymbol>> {
624-
self.dimensions.clone()
625-
}
626-
627-
pub fn time_dimension_symbols(&self) -> Vec<Rc<MemberSymbol>> {
628-
self.time_dimensions.clone()
629-
}
630-
631-
pub fn measure_symbols(&self) -> Vec<Rc<MemberSymbol>> {
632-
self.measures().clone()
633-
}
634-
635623
pub fn time_dimensions(&self) -> &Vec<Rc<MemberSymbol>> {
636624
&self.time_dimensions
637625
}
@@ -715,9 +703,6 @@ impl QueryProperties {
715703
.collect_vec()
716704
}
717705
}
718-
pub fn all_member_symbols(&self, exclude_time_dimensions: bool) -> Vec<Rc<MemberSymbol>> {
719-
self.all_members(exclude_time_dimensions)
720-
}
721706

722707
pub fn get_member_symbols(
723708
&self,

0 commit comments

Comments
 (0)