Function FOREACH_ROW_LIMIT

be/src/exec/union-node-ir.cc:46–50

  int num_rows_to_process = std::min(child_batch->num_rows() - child_row_idx_,
      dst_batch->capacity() - dst_batch->num_rows());
  FOREACH_ROW_LIMIT(child_batch, child_row_idx_, num_rows_to_process, batch_iter) {
    TupleRow* child_row = batch_iter.Get();
    MaterializeExprs(child_expr_evals, child_row, cur_tuple, dst_batch);
    cur_tuple += tuple_byte_size;
  }

  child_row_idx_ += num_rows_to_process;
  *tuple_buf = cur_tuple;