Skip to content

Commit 6a1cc02

Browse files
committed
Keep hash_array rehash behavior
1 parent 80f4df6 commit 6a1cc02

1 file changed

Lines changed: 3 additions & 2 deletions

File tree

datafusion/common/src/hash_utils.rs

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -356,7 +356,7 @@ where
356356
if rehash {
357357
for (i, hash) in hashes_buffer.iter_mut().enumerate() {
358358
let value = unsafe { array.value_unchecked(i) };
359-
*hash = hash_strategy.rehash(&value, *hash);
359+
*hash = combine_hashes(hash_strategy.hash_one(&value), *hash);
360360
}
361361
} else {
362362
for (i, hash) in hashes_buffer.iter_mut().enumerate() {
@@ -367,7 +367,8 @@ where
367367
} else if rehash {
368368
for i in array.nulls().unwrap().valid_indices() {
369369
let value = unsafe { array.value_unchecked(i) };
370-
hashes_buffer[i] = hash_strategy.rehash(&value, hashes_buffer[i]);
370+
hashes_buffer[i] =
371+
combine_hashes(hash_strategy.hash_one(&value), hashes_buffer[i]);
371372
}
372373
} else {
373374
for i in array.nulls().unwrap().valid_indices() {

0 commit comments

Comments
 (0)