Method Prepare

be/src/exec/iceberg-merge-node.cc:129–149

}

Status IcebergMergeNode::Prepare(RuntimeState* state) {
  SCOPED_TIMER(runtime_profile_->total_time_counter());
  RETURN_IF_ERROR(ExecNode::Prepare(state));

  RETURN_IF_ERROR(ScalarExprEvaluator::Create(*row_present_, state, state->obj_pool(),
      expr_perm_pool_.get(), expr_results_pool_.get(), &row_present_evaluator_));

  RETURN_IF_ERROR(
      ScalarExprEvaluator::Create(row_meta_exprs_, state, state->obj_pool(),
          expr_perm_pool_.get(), expr_results_pool_.get(), &row_meta_evaluators_));

  RETURN_IF_ERROR(
      ScalarExprEvaluator::Create(partition_meta_exprs_, state, state->obj_pool(),
          expr_perm_pool_.get(), expr_results_pool_.get(), &partition_meta_evaluators_));

  for (auto* merge_case : all_cases_) {
    RETURN_IF_ERROR(merge_case->Prepare(state, *this));
  }

  return Status::OK();
}

Status IcebergMergeNode::Open(RuntimeState* state) {
  SCOPED_TIMER(runtime_profile_->total_time_counter());