Method Init

cpp/src/arrow/acero/util.cc:79–86

}

Status TableSinkNodeConsumer::Init(const std::shared_ptr<Schema>& schema,
                                   BackpressureControl* backpressure_control,
                                   ExecPlan* plan) {
  // If the user is collecting into a table then backpressure is meaningless
  ARROW_UNUSED(backpressure_control);
  schema_ = schema;
  return Status::OK();
}

Status TableSinkNodeConsumer::Consume(ExecBatch batch) {
  auto guard = consume_mutex_.Lock();