Method Begin

cpp/src/arrow/flight/transport_server.cc:215–228

        ipc_options_(::arrow::ipc::IpcWriteOptions::Defaults()) {}

  Status Begin(const std::shared_ptr<Schema>& schema,
               const ipc::IpcWriteOptions& options) override {
    if (batch_writer_) {
      return Status::Invalid("This writer has already been started.");
    }
    ipc_options_ = options;
    std::unique_ptr<ipc::internal::IpcPayloadWriter> payload_writer(
        new TransportMessagePayloadWriter(stream_, &app_metadata_));

    ARROW_ASSIGN_OR_RAISE(batch_writer_,
                          ipc::internal::OpenRecordBatchWriter(std::move(payload_writer),
                                                               schema, ipc_options_));
    return Status::OK();
  }

  Status WriteRecordBatch(const RecordBatch& batch) override {
    return WriteWithMetadata(batch, nullptr);