(self, context, descriptor, reader, writer)
| 2749 | |
| 2750 | class DeltaFlightServer(ConstantFlightServer): |
| 2751 | def do_exchange(self, context, descriptor, reader, writer): |
| 2752 | expected_table = simple_dicts_table() |
| 2753 | received_table = reader.read_all() |
| 2754 | assert received_table.equals(expected_table) |
| 2755 | assert reader.stats == expected_stats[descriptor.command.decode()] |
| 2756 | if descriptor.command == b'dict_deltas': |
| 2757 | options = pa.ipc.IpcWriteOptions(emit_dictionary_deltas=True) |
| 2758 | writer.begin(expected_table.schema, options=options) |
| 2759 | writer.write_table(expected_table) |
| 2760 | if descriptor.command == b'dict_replacement': |
| 2761 | writer.begin(expected_table.schema) |
| 2762 | writer.write_table(expected_table) |
| 2763 | |
| 2764 | with DeltaFlightServer() as server, \ |
| 2765 | FlightClient(('localhost', server.port)) as client: |
nothing calls this directly
no test coverage detected