Method Prepare

be/src/exec/data-source-scan-node.cc:181–198

}

Status DataSourceScanNode::Prepare(RuntimeState* state) {
  RETURN_IF_ERROR(ScanNode::Prepare(state));
  tuple_desc_ = state->desc_tbl().GetTupleDescriptor(data_src_node_.tuple_id);
  DCHECK(tuple_desc_ != NULL);

  // Point at the plan node's shared connection. The object is owned by the plan node
  // and lives for the lifetime of the fragment; no construction needed here.
  shared_conn_ = &plan_node_.shared_conn;

  cols_next_val_idx_.resize(tuple_desc_->slots().size(), 0);
  num_ext_data_source_get_next_ =
      PROFILE_NumExternalDataSourceGetNext.Instantiate(runtime_profile_);
  jdbc_jni_wait_timer_ = PROFILE_JdbcJniWaitTime.Instantiate(runtime_profile_);
  jdbc_cursor_fetch_timer_ = PROFILE_JdbcCursorFetchTime.Instantiate(runtime_profile_);
  jdbc_lock_wait_timer_ = PROFILE_JdbcLockWaitTime.Instantiate(runtime_profile_);
  jdbc_jni_call_count_ = PROFILE_JdbcJniCallCount.Instantiate(runtime_profile_);
  return Status::OK();
}

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