implement HAVING (#1198)

* having support for insert and deletes * introduced `generate_op_for_existing_segment()` * test completed * clippy fix * fmt * clippy update * clippy fix
getdozer · Mar 9, 2023 · 3e47907 · 3e47907
1 parent bdd5377
commit 3e47907
Show file tree

Hide file tree

Showing 8 changed files with 524 additions and 112 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/dozer-ingestion/src/connectors/snowflake/connection/client.rs b/dozer-ingestion/src/connectors/snowflake/connection/client.rs
@@ -210,7 +210,7 @@ impl Client {
         conn_hashmap.insert("Role".to_string(), "ACCOUNTADMIN".to_string());
 
         let mut parts = vec![];
-        conn_hashmap.keys().into_iter().for_each(|k| {
+        conn_hashmap.keys().for_each(|k| {
             parts.push(format!("{}={}", k, conn_hashmap.get(k).unwrap()));
         });
 

diff --git a/dozer-sql/src/pipeline/aggregation/factory.rs b/dozer-sql/src/pipeline/aggregation/factory.rs
@@ -84,6 +84,7 @@ impl ProcessorFactory<SchemaSQLContext> for AggregationProcessorFactory {
                     planner.groupby,
                     planner.aggregation_output,
                     planner.projection_output,
+                    planner.having,
                     input_schema.clone(),
                     planner.post_aggregation_schema,
                 )