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

Method DoGet

cpp/src/arrow/flight/test_definitions.cc:1054–1061  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1052
1053class IpcOptionsTestServer : public FlightServerBase {
1054 Status DoGet(const ServerCallContext& context, const Ticket& request,
1055 std::unique_ptr<FlightDataStream>* data_stream) override {
1056 RecordBatchVector batches;
1057 RETURN_NOT_OK(ExampleNestedBatches(&batches));
1058 ARROW_ASSIGN_OR_RAISE(auto reader, RecordBatchReader::Make(batches));
1059 *data_stream = std::make_unique<RecordBatchStream>(reader);
1060 return Status::OK();
1061 }
1062
1063 // Just echo the number of batches written. The client will try to
1064 // call this method with different write options set.

Callers

nothing calls this directly

Calls 2

ExampleNestedBatchesFunction · 0.85
OKFunction · 0.50

Tested by

no test coverage detected