Method InitPartsupp

cpp/src/arrow/acero/tpch_node.cc:1084–1094

  }

  Status InitPartsupp(size_t thread_index) {
    ThreadLocalData& tld = thread_local_data_[thread_index];
    tld.generated_partsupp.reset();
    int64_t num_batches = PartsuppBatchesToGenerate(thread_index);
    tld.partsupp.resize(num_batches);
    for (std::vector<Datum>& batch : tld.partsupp) {
      batch.resize(PARTSUPP::kNumCols);
      std::fill(batch.begin(), batch.end(), Datum());
    }
    return Status::OK();
  }

  Status AllocatePartSuppBatch(size_t thread_index, size_t ibatch, int column) {
    ThreadLocalData& tld = thread_local_data_[thread_index];