diff --git a/cpp/src/arrow/acero/swiss_join.cc b/cpp/src/arrow/acero/swiss_join.cc index bfa9a354c29f9..a61cc97b7210c 100644 --- a/cpp/src/arrow/acero/swiss_join.cc +++ b/cpp/src/arrow/acero/swiss_join.cc @@ -193,10 +193,12 @@ Status RowArray::DecodeSelected(ResizableArrayData* output, int column_id, // Process nulls // #ifdef ARROW_HAVE_RUNTIME_AVX2 - if (use_avx2) { - num_rows_processed = - DecodeNulls_avx2(output, num_rows_before, column_id, num_rows_to_append, row_ids); - } + // if (use_avx2) { + // num_rows_processed = + // DecodeNulls_avx2(output, num_rows_before, column_id, num_rows_to_append, + // row_ids); + // } + num_rows_processed = 0; #endif DecodeNulls(output, num_rows_before + num_rows_processed, column_id, num_rows_to_append - num_rows_processed, row_ids + num_rows_processed); diff --git a/cpp/src/arrow/acero/swiss_join_avx2.cc b/cpp/src/arrow/acero/swiss_join_avx2.cc index 2a8e6395cc44b..696eb9a591eae 100644 --- a/cpp/src/arrow/acero/swiss_join_avx2.cc +++ b/cpp/src/arrow/acero/swiss_join_avx2.cc @@ -405,11 +405,11 @@ int RowArray::DecodeFixedLength_avx2(ResizableArrayData* output, int output_star // off the cost of the heavy gather instructions. // For fixed length 0 (boolean column), the vectorized code wins by batching 8 bits into // a single byte instead of modifying the same byte 8 times in the scalar code. - if (!(fixed_length == 0 || fixed_length > 8)) { - DecodeFixedLength(output, output_start_row, column_id, fixed_length, - num_rows_to_append, row_ids); - return num_rows_to_append; - } + // if (!(fixed_length == 0 || fixed_length > 8)) { + // DecodeFixedLength(output, output_start_row, column_id, fixed_length, + // num_rows_to_append, row_ids); + // return num_rows_to_append; + // } DCHECK_EQ(output_start_row % 8, 0); @@ -484,8 +484,8 @@ int RowArray::DecodeOffsets_avx2(ResizableArrayData* output, int output_start_ro int column_id, int num_rows_to_append, const uint32_t* row_ids) const { // Same reason as DecodeFixedLength_avx2. - DecodeOffsets(output, output_start_row, column_id, num_rows_to_append, row_ids); - return num_rows_to_append; + // DecodeOffsets(output, output_start_row, column_id, num_rows_to_append, row_ids); + // return num_rows_to_append; uint32_t* offsets = reinterpret_cast(output->mutable_data(1)) + output_start_row;