MCPcopy Create free account
hub / github.com/apache/arrow / do_get

Method do_get

python/pyarrow/tests/test_flight.py:221–222  ·  view source on GitHub ↗
(self, context, ticket)

Source from the content-addressed store, hash-verified

219 self.expected_schema = expected_schema
220
221 def do_get(self, context, ticket):
222 return flight.RecordBatchStream(self.last_message)
223
224 def do_put(self, context, descriptor, reader, writer):
225 if self.expected_schema:

Callers 15

DoGetMethod · 0.45
test_flight_do_get_intsFunction · 0.45
test_do_get_ints_pandasFunction · 0.45
test_flight_do_get_dictsFunction · 0.45
test_flight_do_get_ticketFunction · 0.45
test_flight_domain_socketFunction · 0.45
test_flight_large_messageFunction · 0.45
test_flight_generator_stream_of_batchesFunction · 0.45
test_flight_generator_stream_of_batches_with_dictFunction · 0.45
test_flight_generator_stream_of_tableFunction · 0.45
test_flight_generator_stream_of_table_with_dictFunction · 0.45
test_flight_generator_stream_of_record_batch_readerFunction · 0.45

Calls 1

RecordBatchStreamMethod · 0.80

Tested by

no test coverage detected