Skip to content

Commit 69136a2

Browse files
committed
simplify code
1 parent 28e3b99 commit 69136a2

File tree

1 file changed

+3
-8
lines changed

1 file changed

+3
-8
lines changed

datafusion/common/src/hash_utils.rs

Lines changed: 3 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -321,20 +321,15 @@ fn hash_fixed_list_array(
321321
hashes_buffer: &mut [u64],
322322
) -> Result<()> {
323323
let values = Arc::clone(array.values());
324-
let value_len = array.value_length();
325-
let offset_size = if array.len() == 0 {
326-
0
327-
} else {
328-
value_len as usize / array.len()
329-
};
324+
let value_length = array.value_length() as usize;
330325
let nulls = array.nulls();
331326
let mut values_hashes = vec![0u64; values.len()];
332327
create_hashes(&[values], random_state, &mut values_hashes)?;
333328
if let Some(nulls) = nulls {
334329
for i in 0..array.len() {
335330
if nulls.is_valid(i) {
336331
let hash = &mut hashes_buffer[i];
337-
for values_hash in &values_hashes[i * offset_size..(i + 1) * offset_size]
332+
for values_hash in &values_hashes[i * value_length..(i + 1) * value_length]
338333
{
339334
*hash = combine_hashes(*hash, *values_hash);
340335
}
@@ -343,7 +338,7 @@ fn hash_fixed_list_array(
343338
} else {
344339
for i in 0..array.len() {
345340
let hash = &mut hashes_buffer[i];
346-
for values_hash in &values_hashes[i * offset_size..(i + 1) * offset_size] {
341+
for values_hash in &values_hashes[i * value_length..(i + 1) * value_length] {
347342
*hash = combine_hashes(*hash, *values_hash);
348343
}
349344
}

0 commit comments

Comments
 (0)