Skip to content

Commit dcf6cf7

Browse files
Formatting
1 parent 4b7c1d8 commit dcf6cf7

2 files changed

Lines changed: 8 additions & 3 deletions

File tree

  • asap-common/dependencies/rs/sql_utilities/src/ast_matching
  • asap-query-engine/src/engines/simple_engine

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

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -311,4 +311,3 @@ pub fn detect_sql_topk(query_data: &SQLQueryData) -> Option<SqlTopk> {
311311
}
312312
Some(SqlTopk { k, weighting })
313313
}
314-

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

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -772,7 +772,9 @@ impl SimpleEngine {
772772
#[cfg(test)]
773773
mod detect_topk_tests {
774774
use sql_utilities::ast_matching::{detect_sql_topk, SQLPatternParser, SqlTopk, TopkWeighting};
775-
use sql_utilities::sqlhelper::{AggregationInfo, OrderByItem, SQLQueryData, SQLSchema, Table, TimeInfo};
775+
use sql_utilities::sqlhelper::{
776+
AggregationInfo, OrderByItem, SQLQueryData, SQLSchema, Table, TimeInfo,
777+
};
776778
use sqlparser::dialect::GenericDialect;
777779
use sqlparser::parser::Parser;
778780
use std::collections::HashSet;
@@ -841,7 +843,11 @@ mod detect_topk_tests {
841843
// The parser path can normalize/canonicalize identifiers; verify directly on
842844
// SQLQueryData that alias matching in detect_sql_topk is case-insensitive.
843845
let qd = SQLQueryData {
844-
aggregation_info: AggregationInfo::new("COUNT".to_string(), "pkt_len".to_string(), vec![]),
846+
aggregation_info: AggregationInfo::new(
847+
"COUNT".to_string(),
848+
"pkt_len".to_string(),
849+
vec![],
850+
),
845851
aggregation_alias: Some("transfer_events".to_string()),
846852
metric: "netflow_table".to_string(),
847853
labels: HashSet::from(["srcip".to_string()]),

0 commit comments

Comments
 (0)