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

Method Init

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

Source from the content-addressed store, hash-verified

1332 static constexpr bool kIsFileFormat = false;
1333
1334 Status Init(const std::shared_ptr<Schema>& schema, const IpcWriteOptions& options) {
1335 ARROW_ASSIGN_OR_RAISE(buffer_, AllocateResizableBuffer(0));
1336 sink_.reset(new io::BufferOutputStream(buffer_));
1337 ARROW_ASSIGN_OR_RAISE(writer_, MakeStreamWriter(sink_.get(), schema, options));
1338 return Status::OK();
1339 }
1340
1341 Status WriteBatch(const std::shared_ptr<RecordBatch>& batch,
1342 const std::shared_ptr<const KeyValueMetadata>& metadata = nullptr) {

Callers

nothing calls this directly

Calls 6

AllocateResizableBufferFunction · 0.85
MakeStreamWriterFunction · 0.85
ARROW_ASSIGN_OR_RAISEFunction · 0.70
OKFunction · 0.50
resetMethod · 0.45
getMethod · 0.45

Tested by

no test coverage detected