fix: min, max with append only

getdozer · Oct 4, 2023 · e06948a · e06948a
1 parent 202f108
commit e06948a
Show file tree

Hide file tree

Showing 4 changed files with 12 additions and 10 deletions.
diff --git a/dozer-sql/src/aggregation/max_append_only.rs b/dozer-sql/src/aggregation/max_append_only.rs
@@ -1,7 +1,7 @@
-use crate::aggregation::aggregator::{Aggregator};
+use crate::aggregation::aggregator::Aggregator;
 
+use crate::calculate_err_field;
 use crate::errors::{PipelineError, UnsupportedSqlError};
-use crate::{calculate_err_field};
 use dozer_sql_expression::aggregate::AggregateFunctionType::MaxAppendOnly;
 
 use dozer_types::chrono::{DateTime, FixedOffset, NaiveDate, Utc};

diff --git a/dozer-sql/src/aggregation/min_append_only.rs b/dozer-sql/src/aggregation/min_append_only.rs
@@ -1,7 +1,7 @@
-use crate::aggregation::aggregator::{Aggregator};
+use crate::aggregation::aggregator::Aggregator;
 
+use crate::calculate_err_field;
 use crate::errors::{PipelineError, UnsupportedSqlError};
-use crate::{calculate_err_field};
 use dozer_sql_expression::aggregate::AggregateFunctionType::MinAppendOnly;
 
 use dozer_types::chrono::{DateTime, FixedOffset, NaiveDate, Utc};

diff --git a/dozer-sql/src/aggregation/tests/aggregation_max_append_only_tests.rs b/dozer-sql/src/aggregation/tests/aggregation_max_append_only_tests.rs
@@ -1,7 +1,8 @@
 use crate::aggregation::tests::aggregation_tests_utils::{
-    get_date_field, get_decimal_field, get_duration_field, get_ts_field,
-    init_input_schema, init_processor, insert_exp, insert_field, update_exp,
-    DATE4, DATE8, FIELD_100_FLOAT, FIELD_100_INT, FIELD_100_UINT, FIELD_50_FLOAT, FIELD_50_INT, FIELD_50_UINT, FIELD_NULL, ITALY, SINGAPORE,
+    get_date_field, get_decimal_field, get_duration_field, get_ts_field, init_input_schema,
+    init_processor, insert_exp, insert_field, update_exp, DATE4, DATE8, FIELD_100_FLOAT,
+    FIELD_100_INT, FIELD_100_UINT, FIELD_50_FLOAT, FIELD_50_INT, FIELD_50_UINT, FIELD_NULL, ITALY,
+    SINGAPORE,
 };
 use crate::output;
 use dozer_core::DEFAULT_PORT_HANDLE;

diff --git a/dozer-sql/src/aggregation/tests/aggregation_min_append_only_tests.rs b/dozer-sql/src/aggregation/tests/aggregation_min_append_only_tests.rs
@@ -1,7 +1,8 @@
 use crate::aggregation::tests::aggregation_tests_utils::{
-    get_date_field, get_decimal_field, get_duration_field, get_ts_field,
-    init_input_schema, init_processor, insert_exp, insert_field, update_exp,
-    DATE4, DATE8, FIELD_100_FLOAT, FIELD_100_INT, FIELD_100_UINT, FIELD_50_FLOAT, FIELD_50_INT, FIELD_50_UINT, FIELD_NULL, ITALY, SINGAPORE,
+    get_date_field, get_decimal_field, get_duration_field, get_ts_field, init_input_schema,
+    init_processor, insert_exp, insert_field, update_exp, DATE4, DATE8, FIELD_100_FLOAT,
+    FIELD_100_INT, FIELD_100_UINT, FIELD_50_FLOAT, FIELD_50_INT, FIELD_50_UINT, FIELD_NULL, ITALY,
+    SINGAPORE,
 };
 use crate::output;
 use dozer_core::DEFAULT_PORT_HANDLE;