Method exchange_do_get

python/pyarrow/tests/test_flight.py:480–486

Emulate DoGet with DoExchange.

(self, context, reader, writer)

                f"Unknown command: {descriptor.command}")

    def exchange_do_get(self, context, reader, writer):
        """Emulate DoGet with DoExchange."""
        data = pa.Table.from_arrays([
            pa.array(range(0, 10 * 1024))
        ], names=["a"])
        writer.begin(data.schema)
        writer.write_table(data)

    def exchange_do_put(self, context, reader, writer):
        """Emulate DoPut with DoExchange."""