Method Write

cpp/src/arrow/dataset/file_ipc_test.cc:47–56

 public:
  using FormatType = IpcFileFormat;
  static Result<std::shared_ptr<Buffer>> Write(RecordBatchReader* reader) {
    ARROW_ASSIGN_OR_RAISE(auto sink, io::BufferOutputStream::Create());
    ARROW_ASSIGN_OR_RAISE(auto writer, ipc::MakeFileWriter(sink, reader->schema()));
    ARROW_ASSIGN_OR_RAISE(auto batches, reader->ToRecordBatches());
    for (auto batch : batches) {
      RETURN_NOT_OK(writer->WriteRecordBatch(*batch));
    }
    RETURN_NOT_OK(writer->Close());
    return sink->Finish();
  }

  static std::shared_ptr<IpcFileFormat> MakeFormat() {
    return std::make_shared<IpcFileFormat>();