| 888 | // Test app_metadata in data plane methods |
| 889 | |
| 890 | Status AppMetadataTestServer::DoGet(const ServerCallContext& context, |
| 891 | const Ticket& request, |
| 892 | std::unique_ptr<FlightDataStream>* data_stream) { |
| 893 | RecordBatchVector batches; |
| 894 | if (request.ticket == "dicts") { |
| 895 | RETURN_NOT_OK(ExampleDictBatches(&batches)); |
| 896 | } else if (request.ticket == "floats") { |
| 897 | RETURN_NOT_OK(ExampleFloatBatches(&batches)); |
| 898 | } else { |
| 899 | RETURN_NOT_OK(ExampleIntBatches(&batches)); |
| 900 | } |
| 901 | ARROW_ASSIGN_OR_RAISE(auto batch_reader, RecordBatchReader::Make(batches)); |
| 902 | *data_stream = std::make_unique<NumberingStream>( |
| 903 | std::make_unique<RecordBatchStream>(batch_reader)); |
| 904 | return Status::OK(); |
| 905 | } |
| 906 | Status AppMetadataTestServer::DoPut(const ServerCallContext& context, |
| 907 | std::unique_ptr<FlightMessageReader> reader, |
| 908 | std::unique_ptr<FlightMetadataWriter> writer) { |
no test coverage detected