Skip to content

Commit 0608859

Browse files
committed
style: Address unused variable warnings
1 parent e924d2a commit 0608859

File tree

4 files changed

+2
-5
lines changed

4 files changed

+2
-5
lines changed

datafusion/src/physical_plan/groups_accumulator.rs

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,9 +18,7 @@
1818
//! Vectorized [`GroupsAccumulator`]
1919
2020
use crate::error::{DataFusionError, Result};
21-
use crate::scalar::ScalarValue;
2221
use arrow::array::{ArrayRef, BooleanArray};
23-
use smallvec::SmallVec;
2422

2523
/// From upstream: This replaces a datafusion_common::{not_impl_err} import.
2624
macro_rules! not_impl_err {

datafusion/src/physical_plan/groups_accumulator_adapter.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,6 @@ use arrow::{
3333
compute,
3434
datatypes::UInt32Type,
3535
};
36-
use smallvec::SmallVec;
3736

3837
/// An adapter that implements [`GroupsAccumulator`] for any [`Accumulator`]
3938
///

datafusion/src/physical_plan/groups_accumulator_prim_op.rs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,8 @@
1515
// specific language governing permissions and limitations
1616
// under the License.
1717

18+
//! PrimitiveGroupsAccumulator
19+
1820
use std::any::type_name;
1921
use std::marker::PhantomData;
2022
use std::mem::size_of;

datafusion/src/physical_plan/hash_aggregate.rs

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1174,8 +1174,6 @@ pub(crate) fn create_batch_from_map(
11741174
// 4. collect all in a vector per key of vec<ArrayRef>, vec[i][j]
11751175
// 5. concatenate the arrays over the second index [j] into a single vec<ArrayRef>.
11761176

1177-
let mut key_columns: Vec<Box<dyn ArrayBuilder>> = Vec::with_capacity(num_group_expr);
1178-
11791177
let key_columns: Vec<Box<dyn ArrayBuilder>> = write_group_result_rows_for_keys(
11801178
&accumulation_state.flattened_group_by_values,
11811179
accumulation_state.next_group_index,

0 commit comments

Comments
 (0)