Method Start

cpp/src/arrow/dataset/dataset_writer.cc:143–158

      : options_(options), schema_(schema), writer_state_(std::move(writer_state)) {}

  void Start(std::unique_ptr<util::ThrottledAsyncTaskScheduler> file_tasks,
             std::string filename) {
    file_tasks_ = std::move(file_tasks);
    // Because the scheduler runs one task at a time we know the writer will
    // be opened before any attempt to write
    file_tasks_->AddSimpleTask(
        [self = shared_from_this(), filename = std::move(filename)] {
          Executor* io_executor = self->options_.filesystem->io_context().executor();
          return DeferNotOk(io_executor->Submit([self, filename = std::move(filename)]() {
            ARROW_ASSIGN_OR_RAISE(self->writer_,
                                  OpenWriter(self->options_, self->schema_, filename));
            return Status::OK();
          }));
        },
        "DatasetWriter::OpenWriter"sv);
  }

  void Abort() {
    // The scheduler may be keeping this object alive through shared_ptr references