Method ReadBatches

cpp/src/arrow/ipc/read_write_test.cc:1207–1230

  }

  virtual Status ReadBatches(const IpcReadOptions& options,
                             RecordBatchVector* out_batches,
                             ReadStats* out_stats = nullptr,
                             MetadataVector* out_metadata_list = nullptr) {
    auto buf_reader = std::make_shared<io::BufferReader>(buffer_);
    ARROW_ASSIGN_OR_RAISE(auto reader, RecordBatchFileReader::Open(
                                           buf_reader.get(), footer_offset_, options));

    EXPECT_EQ(num_batches_written_, reader->num_record_batches());
    for (int i = 0; i < num_batches_written_; ++i) {
      ARROW_ASSIGN_OR_RAISE(auto chunk_with_metadata,
                            reader->ReadRecordBatchWithCustomMetadata(i));
      auto chunk = chunk_with_metadata.batch;
      out_batches->push_back(chunk);
      if (out_metadata_list) {
        auto metadata = chunk_with_metadata.custom_metadata;
        out_metadata_list->push_back(metadata);
      }
    }
    if (out_stats) {
      *out_stats = reader->stats();
    }
    return Status::OK();
  }

  Status ReadSchema(std::shared_ptr<Schema>* out) {
    return ReadSchema(ipc::IpcReadOptions::Defaults(), out);