Method L_COMMENT

cpp/src/arrow/acero/tpch_node.cc:2349–2375

  }

  Status L_COMMENT(size_t thread_index) {
    ThreadLocalData& tld = thread_local_data_[thread_index];
    if (!tld.generated_lineitem[LINEITEM::L_COMMENT]) {
      tld.generated_lineitem[LINEITEM::L_COMMENT] = true;

      size_t ibatch = 0;
      for (int64_t irow = 0; irow < tld.lineitem_to_generate; ibatch++) {
        // Comments are kind of sneaky: we always generate the full batch and then just
        // bump the length
        size_t batch_offset = 0;
        if (tld.lineitem[ibatch][LINEITEM::L_COMMENT].kind() == Datum::NONE) {
          ARROW_ASSIGN_OR_RAISE(tld.lineitem[ibatch][LINEITEM::L_COMMENT],
                                g_text.GenerateComments(batch_size_, 10, 43, tld.rng));
          batch_offset = 0;
        }
        if (irow == 0) batch_offset = tld.first_batch_offset;

        int64_t remaining_in_batch = static_cast<int64_t>(batch_size_ - batch_offset);
        int64_t next_run = std::min(tld.lineitem_to_generate - irow, remaining_in_batch);

        batch_offset += next_run;
        irow += next_run;
        tld.lineitem[ibatch][LINEITEM::L_COMMENT].array()->length = batch_offset;
      }
    }
    return Status::OK();
  }

  struct ThreadLocalData {
    std::vector<Datum> orders;