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

Method Init

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

Source from the content-addressed store, hash-verified

1171 static constexpr bool kIsFileFormat = true;
1172
1173 Status Init(const std::shared_ptr<Schema>& schema, const IpcWriteOptions& options,
1174 const std::shared_ptr<const KeyValueMetadata>& metadata = nullptr) {
1175 num_batches_written_ = 0;
1176
1177 ARROW_ASSIGN_OR_RAISE(buffer_, AllocateResizableBuffer(0));
1178 sink_.reset(new io::BufferOutputStream(buffer_));
1179 ARROW_ASSIGN_OR_RAISE(writer_,
1180 MakeFileWriter(sink_.get(), schema, options, metadata));
1181 return Status::OK();
1182 }
1183
1184 Status WriteBatch(const std::shared_ptr<RecordBatch>& batch,
1185 const std::shared_ptr<const KeyValueMetadata>& metadata = nullptr) {

Callers 12

TestWriteAfterCloseMethod · 0.45
RoundTripHelperMethod · 0.45
TESTFunction · 0.45
TEST_FFunction · 0.45
RoundTripMethod · 0.45
RoundTripTableMethod · 0.45
CheckWritingFailsMethod · 0.45

Calls 6

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

Tested by

no test coverage detected