From 525106d789f1ace9eff8eb904525f2cf99d58a54 Mon Sep 17 00:00:00 2001 From: Emil Ejbyfeldt Date: Fri, 23 Aug 2024 09:54:07 +0200 Subject: [PATCH] Add cast to support all numeric types --- datafusion/functions-aggregate/src/variance.rs | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/datafusion/functions-aggregate/src/variance.rs b/datafusion/functions-aggregate/src/variance.rs index e13febfa0fe7c..32e54d92e6c3b 100644 --- a/datafusion/functions-aggregate/src/variance.rs +++ b/datafusion/functions-aggregate/src/variance.rs @@ -491,7 +491,8 @@ impl GroupsAccumulator for VarianceGroupsAccumulator { total_num_groups: usize, ) -> Result<()> { assert_eq!(values.len(), 1, "single argument to update_batch"); - let values = downcast_value!(values[0], Float64Array); + let values = &cast(&values[0], &DataType::Float64)?; + let values = downcast_value!(values, Float64Array); self.resize(total_num_groups); accumulate(group_indices, values, opt_filter, |group_index, value| {