Skip to content

Commit

Permalink
remove it to below
Browse files Browse the repository at this point in the history
  • Loading branch information
Light-City committed Apr 11, 2024
1 parent b01adf1 commit 50eb59d
Showing 1 changed file with 5 additions and 3 deletions.
8 changes: 5 additions & 3 deletions cpp/src/arrow/acero/swiss_join.cc
Original file line number Diff line number Diff line change
Expand Up @@ -2160,16 +2160,18 @@ Status JoinResidualFilter::FilterOneBatch(const ExecBatch& keypayload_batch,
bool output_key_ids, bool output_payload_ids,
arrow::util::TempVectorStack* temp_stack,
int* num_passing_rows) const {
if (num_batch_rows == 0) {
return Status::OK();
}
// Caller must do shortcuts for trivial filter.
ARROW_DCHECK(!filter_.IsNullLiteral() && filter_ != literal(true) &&
filter_ != literal(false));
ARROW_DCHECK(!output_key_ids || key_ids_maybe_null);
ARROW_DCHECK(!output_payload_ids || payload_ids_maybe_null);

*num_passing_rows = 0;

if (num_batch_rows == 0) {
return Status::OK();
}

ARROW_ASSIGN_OR_RAISE(Datum mask,
EvalFilter(keypayload_batch, num_batch_rows, batch_row_ids,
key_ids_maybe_null, payload_ids_maybe_null));
Expand Down

0 comments on commit 50eb59d

Please sign in to comment.