Skip to content

Commit

Permalink
clippy warnings
Browse files Browse the repository at this point in the history
  • Loading branch information
korowa committed Jan 2, 2024
1 parent 541fca8 commit 570f4f3
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions datafusion/physical-expr/src/aggregate/count_distinct.rs
Original file line number Diff line number Diff line change
Expand Up @@ -403,7 +403,7 @@ where
let unique_values = emit_to.take_needed(&mut self.unique_values);

// Final state is represented by Int64 array, where each element is a length of corresponding HashSet from `self.unique_values`
return Ok(Arc::new(Int64Array::from(
Ok(Arc::new(Int64Array::from(
unique_values
.into_iter()
.map(|set| set.len() as i64)
Expand Down Expand Up @@ -1124,7 +1124,7 @@ mod tests {
Some(4.752399),
Some(5.239493),
None,
Some(7.34058740),
Some(7.3405874),
Some(<$PRIM_TYPE>::INFINITY),
Some(<$PRIM_TYPE>::NEG_INFINITY),
];
Expand Down Expand Up @@ -1200,7 +1200,7 @@ mod tests {
vec![1.234],
vec![],
vec![4.752399, 5.239493],
vec![7.34058740],
vec![7.3405874],
vec![<$PRIM_TYPE>::INFINITY, <$PRIM_TYPE>::NEG_INFINITY],
];

Expand Down Expand Up @@ -1257,7 +1257,7 @@ mod tests {
vec![1.234],
vec![],
vec![4.752399, 5.239493],
vec![7.34058740],
vec![7.3405874],
vec![<$PRIM_TYPE>::INFINITY, <$PRIM_TYPE>::NEG_INFINITY],
vec![8.23329],
];
Expand Down

0 comments on commit 570f4f3

Please sign in to comment.