From bf9532a42d8fc165229321fb5dd0ca09add26334 Mon Sep 17 00:00:00 2001
From: "R. Tyler Croy" <rtyler@brokenco.de>
Date: Sun, 26 May 2024 21:49:12 +0000
Subject: [PATCH] wip

---
 crates/core/src/operations/update.rs | 3 +++
 crates/core/src/table/state_arrow.rs | 2 +-
 2 files changed, 4 insertions(+), 1 deletion(-)

diff --git a/crates/core/src/operations/update.rs b/crates/core/src/operations/update.rs
index 9a088c6ae9..9920c41ea8 100644
--- 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
index 9d23f3169f..fe35787cb4 100644
--- 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 {