Method MaterializeBatch

be/src/exec/union-node-ir.cc:35–54

}

void UnionNode::MaterializeBatch(RowBatch* dst_batch, uint8_t** tuple_buf) {
  // Take all references to member variables out of the loop to reduce the number of
  // loads and stores.
  RowBatch* child_batch = child_batch_.get();
  int tuple_byte_size = tuple_desc_->byte_size();
  uint8_t* cur_tuple = *tuple_buf;
  const std::vector<ScalarExprEvaluator*>& child_expr_evals =
      child_expr_evals_lists_[child_idx_];

  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;
}