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

Method WritePayload

cpp/src/arrow/ipc/writer.cc:1431–1441  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1429 ~PayloadStreamWriter() override = default;
1430
1431 Status WritePayload(const IpcPayload& payload) override {
1432#ifndef NDEBUG
1433 // Catch bug fixed in ARROW-3236
1434 RETURN_NOT_OK(UpdatePositionCheckAligned());
1435#endif
1436
1437 int32_t metadata_length = 0; // unused
1438 RETURN_NOT_OK(WriteIpcPayload(payload, options_, sink_, &metadata_length));
1439 RETURN_NOT_OK(UpdatePositionCheckAligned());
1440 return Status::OK();
1441 }
1442
1443 Status Close() override { return WriteEOS(); }
1444};

Callers

nothing calls this directly

Calls 2

WriteIpcPayloadFunction · 0.85
OKFunction · 0.50

Tested by

no test coverage detected