diff --git a/datafusion/physical-plan/src/aggregates/group_values/column.rs b/datafusion/physical-plan/src/aggregates/group_values/column.rs index bf5ab6213d13..aad4878de916 100644 --- a/datafusion/physical-plan/src/aggregates/group_values/column.rs +++ b/datafusion/physical-plan/src/aggregates/group_values/column.rs @@ -1077,9 +1077,7 @@ mod tests { use datafusion_common::utils::proxy::RawTableAllocExt; use datafusion_expr::EmitTo; - use crate::aggregates::group_values::{ - column::GroupValuesColumn, GroupValues, - }; + use crate::aggregates::group_values::{column::GroupValuesColumn, GroupValues}; use super::GroupIndexView; @@ -1151,8 +1149,7 @@ mod tests { let field = Field::new("item", DataType::Int32, true); let schema = Arc::new(Schema::new_with_metadata(vec![field], HashMap::new())); - let mut group_values = - GroupValuesColumn::::try_new(schema).unwrap(); + let mut group_values = GroupValuesColumn::::try_new(schema).unwrap(); // Insert group index views and check if success to insert insert_inline_group_index_view(&mut group_values, 0, 0); diff --git a/datafusion/physical-plan/src/aggregates/group_values/mod.rs b/datafusion/physical-plan/src/aggregates/group_values/mod.rs index 696407fbb4be..aefd9c162246 100644 --- a/datafusion/physical-plan/src/aggregates/group_values/mod.rs +++ b/datafusion/physical-plan/src/aggregates/group_values/mod.rs @@ -150,13 +150,9 @@ pub fn new_group_values( if column::supported_schema(schema.as_ref()) { if matches!(group_ordering, GroupOrdering::None) { - Ok(Box::new(GroupValuesColumn::::try_new( - schema, - )?)) + Ok(Box::new(GroupValuesColumn::::try_new(schema)?)) } else { - Ok(Box::new(GroupValuesColumn::::try_new( - schema, - )?)) + Ok(Box::new(GroupValuesColumn::::try_new(schema)?)) } } else { Ok(Box::new(GroupValuesRows::try_new(schema)?))