Skip to content

Commit eba3fde

Browse files
formatting
1 parent 8140ea7 commit eba3fde

2 files changed

Lines changed: 7 additions & 22 deletions

File tree

asap-common/dependencies/rs/sql_utilities/src/ast_matching/sqlpattern_parser.rs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -217,7 +217,8 @@ impl SQLPatternParser {
217217
let subquery = match &select.from[0].relation {
218218
TableFactor::Derived { subquery, .. } => match subquery.body.as_ref() {
219219
SetExpr::Select(inner_select) => {
220-
let (inner_aggregation, inner_alias) = self.get_aggregation(inner_select)?;
220+
let (inner_aggregation, inner_alias) =
221+
self.get_aggregation(inner_select)?;
221222
let inner_group_bys = self.get_groupbys(inner_select)?;
222223
if !self.select_identifiers_subset_of(inner_select, &inner_group_bys) {
223224
return None;

asap-query-engine/src/engines/simple_engine/sql.rs

Lines changed: 5 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -336,8 +336,7 @@ impl SimpleEngine {
336336
query: String,
337337
time: f64,
338338
) -> Option<QueryExecutionContext> {
339-
self.build_sql_query_pieces(query, time)
340-
.map(|(ctx, _)| ctx)
339+
self.build_sql_query_pieces(query, time).map(|(ctx, _)| ctx)
341340
}
342341

343342
/// Internal: parses + plans a SQL query and returns both the execution
@@ -769,21 +768,14 @@ mod sort_and_truncate_tests {
769768
#[test]
770769
fn order_by_label_ascending_default() {
771770
// ORDER BY <group-by column> with no ASC/DESC defaults to ascending.
772-
let input = vec![
773-
elem(&["c"], 1.0),
774-
elem(&["a"], 2.0),
775-
elem(&["b"], 3.0),
776-
];
771+
let input = vec![elem(&["c"], 1.0), elem(&["a"], 2.0), elem(&["b"], 3.0)];
777772
let order_by = vec![OrderByItem {
778773
column: "L".to_string(),
779774
ascending: true,
780775
}];
781776
let result =
782777
sort_and_truncate_instant_vector(input, &label_names(&["L"]), None, &order_by, None);
783-
let labels: Vec<&str> = result
784-
.iter()
785-
.map(|e| e.labels.labels[0].as_str())
786-
.collect();
778+
let labels: Vec<&str> = result.iter().map(|e| e.labels.labels[0].as_str()).collect();
787779
assert_eq!(labels, vec!["a", "b", "c"]);
788780
}
789781

@@ -824,11 +816,7 @@ mod sort_and_truncate_tests {
824816

825817
#[test]
826818
fn limit_only_no_orderby_truncates_in_place() {
827-
let input = vec![
828-
elem(&["a"], 1.0),
829-
elem(&["b"], 2.0),
830-
elem(&["c"], 3.0),
831-
];
819+
let input = vec![elem(&["a"], 1.0), elem(&["b"], 2.0), elem(&["c"], 3.0)];
832820
let result =
833821
sort_and_truncate_instant_vector(input, &label_names(&["L"]), None, &[], Some(2));
834822
assert_eq!(result.len(), 2);
@@ -839,11 +827,7 @@ mod sort_and_truncate_tests {
839827
#[test]
840828
fn nan_values_do_not_panic() {
841829
// partial_cmp returns None for NaN; we map to Equal to keep the comparator total.
842-
let input = vec![
843-
elem(&["a"], f64::NAN),
844-
elem(&["b"], 1.0),
845-
elem(&["c"], 2.0),
846-
];
830+
let input = vec![elem(&["a"], f64::NAN), elem(&["b"], 1.0), elem(&["c"], 2.0)];
847831
let order_by = vec![OrderByItem {
848832
column: "p99".to_string(),
849833
ascending: false,

0 commit comments

Comments
 (0)