Method C_NAME

cpp/src/arrow/acero/tpch_node.cc:2936–2967

  }

  Status C_NAME(size_t thread_index) {
    ThreadLocalData& tld = thread_local_data_[thread_index];
    if (tld.batch[CUSTOMER::C_NAME].kind() == Datum::NONE) {
      RETURN_NOT_OK(C_CUSTKEY(thread_index));
      const int32_t* c_custkey = reinterpret_cast<const int32_t*>(
          tld.batch[CUSTOMER::C_CUSTKEY].array()->buffers[1]->data());
      ARROW_ASSIGN_OR_RAISE(std::unique_ptr<Buffer> offset_buff,
                            AllocateBuffer((tld.to_generate + 1) * sizeof(int32_t)));
      int32_t* offsets = reinterpret_cast<int32_t*>(offset_buff->mutable_data());
      const char* customer = "Customer#";
      const size_t customer_length = std::strlen(customer);
      offsets[0] = 0;
      for (int64_t irow = 0; irow < tld.to_generate; irow++) {
        int num_digits = GetNumDigits(c_custkey[irow]);
        int num_chars = std::max(num_digits, 9);
        offsets[irow + 1] =
            static_cast<int32_t>(offsets[irow] + num_chars + customer_length);
      }
      ARROW_ASSIGN_OR_RAISE(std::unique_ptr<Buffer> str_buff,
                            AllocateBuffer(offsets[tld.to_generate]));
      char* str = reinterpret_cast<char*>(str_buff->mutable_data());
      for (int64_t irow = 0; irow < tld.to_generate; irow++) {
        char* out = str + offsets[irow];
        std::memcpy(out, customer, customer_length);
        AppendNumberPaddedToNineDigits(out + customer_length, c_custkey[irow]);
      }
      ArrayData ad(utf8(), tld.to_generate,
                   {nullptr, std::move(offset_buff), std::move(str_buff)});
      tld.batch[CUSTOMER::C_NAME] = std::move(ad);
    }
    return Status::OK();
  }

  Status C_ADDRESS(size_t thread_index) {
    ThreadLocalData& tld = thread_local_data_[thread_index];