Skip to content

Commit

Permalink
fix fmt.
Browse files Browse the repository at this point in the history
  • Loading branch information
Rachelint committed Nov 4, 2024
1 parent 2d982a1 commit e4bd579
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 11 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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;

Expand Down Expand Up @@ -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::<false>::try_new(schema).unwrap();
let mut group_values = GroupValuesColumn::<false>::try_new(schema).unwrap();

// Insert group index views and check if success to insert
insert_inline_group_index_view(&mut group_values, 0, 0);
Expand Down
8 changes: 2 additions & 6 deletions datafusion/physical-plan/src/aggregates/group_values/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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::<false>::try_new(
schema,
)?))
Ok(Box::new(GroupValuesColumn::<false>::try_new(schema)?))
} else {
Ok(Box::new(GroupValuesColumn::<true>::try_new(
schema,
)?))
Ok(Box::new(GroupValuesColumn::<true>::try_new(schema)?))
}
} else {
Ok(Box::new(GroupValuesRows::try_new(schema)?))
Expand Down

0 comments on commit e4bd579

Please sign in to comment.