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

Method DoPut

cpp/src/arrow/flight/perf_server.cc:204–216  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

202 }
203
204 Status DoPut(const ServerCallContext& context,
205 std::unique_ptr<FlightMessageReader> reader,
206 std::unique_ptr<FlightMetadataWriter> writer) override {
207 FlightStreamChunk chunk;
208 while (true) {
209 ARROW_ASSIGN_OR_RAISE(chunk, reader->Next());
210 if (!chunk.data) break;
211 if (chunk.app_metadata) {
212 RETURN_NOT_OK(writer->WriteMetadata(*chunk.app_metadata));
213 }
214 }
215 return Status::OK();
216 }
217
218 Status DoAction(const ServerCallContext& context, const Action& action,
219 std::unique_ptr<ResultStream>* result) override {

Callers

nothing calls this directly

Calls 4

ARROW_ASSIGN_OR_RAISEFunction · 0.70
OKFunction · 0.50
NextMethod · 0.45
WriteMetadataMethod · 0.45

Tested by

no test coverage detected