wip

delta-io · May 26, 2024 · bf9532a · bf9532a
1 parent 68382e7
commit bf9532a
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/crates/core/src/operations/update.rs b/crates/core/src/operations/update.rs
@@ -250,6 +250,7 @@ async fn execute(
     let mut expressions: Vec<(Arc<dyn PhysicalExpr>, String)> = Vec::new();
     let scan_schema = scan.schema();
     for (i, field) in scan_schema.fields().into_iter().enumerate() {
+        println!("GIN: {:#?}", field.name());
         expressions.push((
             Arc::new(expressions::Column::new(field.name(), i)),
             field.name().to_owned(),
@@ -328,12 +329,14 @@ async fn execute(
         if !control_columns.contains(field.name()) {
             match map.get(field.name()) {
                 Some(value) => {
+                    println!("PUSH {:#?}", field.name());
                     expressions.push((
                         Arc::new(expressions::Column::new(field.name(), *value)),
                         field.name().to_owned(),
                     ));
                 }
                 None => {
+                    println!("NONE {:#?}", field.name());
                     expressions.push((
                         Arc::new(expressions::Column::new(field.name(), i)),
                         field.name().to_owned(),

diff --git a/crates/core/src/table/state_arrow.rs b/crates/core/src/table/state_arrow.rs
@@ -572,7 +572,7 @@ impl DeltaTableState {
                 // into StructArrays, until it is consolidated into a single array.
                 columnar_stats = columnar_stats
                     .into_iter()
-                    .group_by(|col_stat| {
+                    .chunk_by(|col_stat| {
                         if col_stat.path.len() < level {
                             col_stat.path.clone()
                         } else {