Update field output name for aggregates

timsaucer · timsaucer · commit 1f9da9fc39c7 · 2025-04-30T15:55:14.000-04:00
diff --git a/datafusion/physical-expr/src/aggregate.rs b/datafusion/physical-expr/src/aggregate.rs
@@ -373,7 +373,7 @@ impl AggregateFunctionExpr {
 
     /// the field of the final result of this aggregation.
     pub fn field(&self) -> Field {
-        self.return_field.clone()
+        self.return_field.clone().with_name(&self.name)
     }
 
     /// the accumulator used to accumulate values from the expressions.

Original file line number	Diff line number	Diff line change
`@@ -373,7 +373,7 @@ impl AggregateFunctionExpr {`
`373`	`373`
`374`	`374`	`/// the field of the final result of this aggregation.`
`375`	`375`	`pub fn field(&self) -> Field {`
`376`		`- self.return_field.clone()`
	`376`	`+ self.return_field.clone().with_name(&self.name)`
`377`	`377`	`}`
`378`	`378`
`379`	`379`	`/// the accumulator used to accumulate values from the expressions.`