We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 23fc979 commit 9cd8cdbCopy full SHA for 9cd8cdb
1 file changed
datafusion/functions-aggregate/src/sum.rs
@@ -289,10 +289,12 @@ impl AggregateUDFImpl for Sum {
289
) -> Result<Box<dyn GroupsAccumulator>> {
290
macro_rules! helper {
291
($t:ty, $dt:expr) => {
292
- Ok(Box::new(PrimitiveGroupsAccumulator::<$t, _>::new(
293
- &$dt,
294
- |x, y| *x = x.add_wrapping(y),
295
- ).with_starting_value_as_identity()))
+ Ok(Box::new(
+ PrimitiveGroupsAccumulator::<$t, _>::new(&$dt, |x, y| {
+ *x = x.add_wrapping(y)
+ })
296
+ .with_starting_value_as_identity(),
297
+ ))
298
};
299
}
300
downcast_sum!(args, helper)
0 commit comments