| 1052 | |
| 1053 | class 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. |
nothing calls this directly
no test coverage detected