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

Method WritePayload

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

Source from the content-addressed store, hash-verified

1436 ~PayloadStreamWriter() override = default;
1437
1438 Status WritePayload(const IpcPayload& payload) override {
1439#ifndef NDEBUG
1440 // Catch bug fixed in ARROW-3236
1441 RETURN_NOT_OK(UpdatePositionCheckAligned());
1442#endif
1443
1444 int32_t metadata_length = 0; // unused
1445 RETURN_NOT_OK(WriteIpcPayload(payload, options_, sink_, &metadata_length));
1446 RETURN_NOT_OK(UpdatePositionCheckAligned());
1447 return Status::OK();
1448 }
1449
1450 Status Close() override { return WriteEOS(); }
1451};

Callers

nothing calls this directly

Calls 2

WriteIpcPayloadFunction · 0.85
OKFunction · 0.50

Tested by

no test coverage detected