fix group values len method.

Rachelint · Rachelint · commit 4510f29d4ed3 · 2025-04-22T00:02:57.000+08:00
diff --git a/datafusion/physical-plan/src/aggregates/group_values/single_group_by/primitive.rs b/datafusion/physical-plan/src/aggregates/group_values/single_group_by/primitive.rs
@@ -174,7 +174,7 @@ where
     }
 
     fn len(&self) -> usize {
-        self.map.len() + self.null_group.map(|_| 1).unwrap_or_default()
+        self.values.iter().map(|block| block.len()).sum::<usize>()
     }
 
     fn emit(&mut self, emit_to: EmitTo) -> Result<Vec<ArrayRef>> {

Original file line number	Diff line number	Diff line change
`@@ -174,7 +174,7 @@ where`
`174`	`174`	`}`
`175`	`175`
`176`	`176`	`fn len(&self) -> usize {`
`177`		`- self.map.len() + self.null_group.map(\|_\| 1).unwrap_or_default()`
	`177`	`+ self.values.iter().map(\|block\| block.len()).sum::<usize>()`
`178`	`178`	`}`
`179`	`179`
`180`	`180`	`fn emit(&mut self, emit_to: EmitTo) -> Result<Vec<ArrayRef>> {`