(self, context, criteria)
| 63 | table.num_rows, data_size) |
| 64 | |
| 65 | def list_flights(self, context, criteria): |
| 66 | for key, table in self.flights.items(): |
| 67 | if key[1] is not None: |
| 68 | descriptor = \ |
| 69 | pyarrow.flight.FlightDescriptor.for_command(key[1]) |
| 70 | else: |
| 71 | descriptor = pyarrow.flight.FlightDescriptor.for_path(*key[2]) |
| 72 | |
| 73 | yield self._make_flight_info(key, descriptor, table) |
| 74 | |
| 75 | def get_flight_info(self, context, descriptor): |
| 76 | key = FlightServer.descriptor_to_key(descriptor) |