MCPcopy Create free account
hub / github.com/apache/arrow / ReadBatch

Method ReadBatch

cpp/src/arrow/ipc/read_write_test.cc:1861–1867  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1859 }
1860
1861 Status ReadBatch(std::shared_ptr<RecordBatch>* out_batch) {
1862 auto buf_reader = std::make_shared<io::BufferReader>(buffer_);
1863 std::shared_ptr<RecordBatchReader> reader;
1864 ARROW_ASSIGN_OR_RAISE(
1865 reader, RecordBatchStreamReader::Open(buf_reader, IpcReadOptions::Defaults()))
1866 return reader->ReadNext(out_batch);
1867 }
1868
1869 std::unique_ptr<internal::IpcPayloadWriter> payload_writer_;
1870 const Schema& schema_;

Callers 1

TESTFunction · 0.45

Calls 3

ARROW_ASSIGN_OR_RAISEFunction · 0.70
DefaultsFunction · 0.50
ReadNextMethod · 0.45

Tested by

no test coverage detected