Skip to content

Commit 7d3e01f

Browse files
committed
fix_pr_comments
1 parent 8a8b5d2 commit 7d3e01f

File tree

1 file changed

+5
-2
lines changed
  • datafusion/functions-aggregate-common/src/aggregate/count_distinct

1 file changed

+5
-2
lines changed

datafusion/functions-aggregate-common/src/aggregate/count_distinct/groups.rs

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@
1818
use arrow::array::{
1919
ArrayRef, AsArray, BooleanArray, Int64Array, ListArray, PrimitiveArray,
2020
};
21-
use arrow::buffer::OffsetBuffer;
21+
use arrow::buffer::{OffsetBuffer, ScalarBuffer};
2222
use arrow::datatypes::{ArrowPrimitiveType, Field};
2323
use datafusion_common::HashSet;
2424
use datafusion_common::hash_utils::RandomState;
@@ -142,7 +142,10 @@ where
142142
let _ = emit_to.take_needed(&mut self.counts);
143143
}
144144

145-
let values_array = Arc::new(PrimitiveArray::<T>::from_iter_values(all_values));
145+
let values_array = Arc::new(PrimitiveArray::<T>::new(
146+
ScalarBuffer::from(all_values),
147+
None,
148+
));
146149
let list_array = ListArray::new(
147150
Arc::new(Field::new_list_field(T::DATA_TYPE, true)),
148151
OffsetBuffer::new(offsets.into()),

0 commit comments

Comments
 (0)