| 161 | } |
| 162 | |
| 163 | std::vector<FlightInfo> ExampleFlightInfo() { |
| 164 | Location location1 = *Location::ForGrpcTcp("foo1.bar.com", 12345); |
| 165 | Location location2 = *Location::ForGrpcTcp("foo2.bar.com", 12345); |
| 166 | Location location3 = *Location::ForGrpcTcp("foo3.bar.com", 12345); |
| 167 | Location location4 = *Location::ForGrpcTcp("foo4.bar.com", 12345); |
| 168 | Location location5 = *Location::ForGrpcTcp("foo5.bar.com", 12345); |
| 169 | |
| 170 | FlightEndpoint endpoint1({Ticket{"ticket-ints-1"}, {location1}, std::nullopt, {}}); |
| 171 | FlightEndpoint endpoint2({Ticket{"ticket-ints-2"}, {location2}, std::nullopt, {}}); |
| 172 | FlightEndpoint endpoint3({Ticket{"ticket-cmd"}, {location3}, std::nullopt, {}}); |
| 173 | FlightEndpoint endpoint4({Ticket{"ticket-dicts-1"}, {location4}, std::nullopt, {}}); |
| 174 | FlightEndpoint endpoint5({Ticket{"ticket-floats-1"}, {location5}, std::nullopt, {}}); |
| 175 | |
| 176 | FlightDescriptor descr1{FlightDescriptor::PATH, "", {"examples", "ints"}}; |
| 177 | FlightDescriptor descr2{FlightDescriptor::CMD, "my_command", {}}; |
| 178 | FlightDescriptor descr3{FlightDescriptor::PATH, "", {"examples", "dicts"}}; |
| 179 | FlightDescriptor descr4{FlightDescriptor::PATH, "", {"examples", "floats"}}; |
| 180 | |
| 181 | auto schema1 = ExampleIntSchema(); |
| 182 | auto schema2 = ExampleStringSchema(); |
| 183 | auto schema3 = ExampleDictSchema(); |
| 184 | auto schema4 = ExampleFloatSchema(); |
| 185 | |
| 186 | return { |
| 187 | MakeFlightInfo(*schema1, descr1, {endpoint1, endpoint2}, 1000, 100000, false, ""), |
| 188 | MakeFlightInfo(*schema2, descr2, {endpoint3}, 1000, 100000, false, ""), |
| 189 | MakeFlightInfo(*schema3, descr3, {endpoint4}, -1, -1, false, ""), |
| 190 | MakeFlightInfo(*schema4, descr4, {endpoint5}, 1000, 100000, false, ""), |
| 191 | }; |
| 192 | } |
| 193 | |
| 194 | Status ExampleIntBatches(RecordBatchVector* out) { |
| 195 | std::shared_ptr<RecordBatch> batch; |
no test coverage detected