| 401 | } |
| 402 | |
| 403 | Status TestFlightServer::GetSchema(const ServerCallContext& context, |
| 404 | const FlightDescriptor& request, |
| 405 | std::unique_ptr<SchemaResult>* schema) { |
| 406 | std::vector<FlightInfo> flights = ExampleFlightInfo(); |
| 407 | |
| 408 | for (const auto& info : flights) { |
| 409 | if (info.descriptor().Equals(request)) { |
| 410 | *schema = std::make_unique<SchemaResult>(info.serialized_schema()); |
| 411 | return Status::OK(); |
| 412 | } |
| 413 | } |
| 414 | return Status::Invalid("Flight not found: ", request.ToString()); |
| 415 | } |
| 416 | |
| 417 | } // namespace arrow::flight |
nothing calls this directly
no test coverage detected