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

Method WriteMetadata

cpp/src/arrow/flight/transport_server.cc:234–244  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

232 }
233
234 Status WriteMetadata(std::shared_ptr<Buffer> app_metadata) override {
235 FlightPayload payload{};
236 payload.app_metadata = app_metadata;
237 ARROW_ASSIGN_OR_RAISE(auto success, stream_->WriteData(payload));
238 if (!success) {
239 ARROW_RETURN_NOT_OK(Close());
240 return MakeFlightError(FlightStatusCode::Internal,
241 "Could not write metadata to stream (client disconnect?)");
242 }
243 return Status::OK();
244 }
245
246 Status WriteWithMetadata(const RecordBatch& batch,
247 std::shared_ptr<Buffer> app_metadata) override {

Callers

nothing calls this directly

Calls 3

MakeFlightErrorFunction · 0.85
CloseFunction · 0.50
OKFunction · 0.50

Tested by

no test coverage detected