Method InitEncoder

cpp/src/arrow/acero/hash_join.cc:98–107

 private:
  void InitEncoder(int side, HashJoinProjection projection_handle, RowEncoder* encoder) {
    std::vector<TypeHolder> data_types;
    int num_cols = schema_[side]->num_cols(projection_handle);
    data_types.resize(num_cols);
    for (int icol = 0; icol < num_cols; ++icol) {
      data_types[icol] = schema_[side]->data_type(projection_handle, icol);
    }
    encoder->Init(data_types, ctx_->exec_context());
    encoder->Clear();
  }

  Status InitLocalStateIfNeeded(size_t thread_index) {
    DCHECK_LT(thread_index, local_states_.size());