Most of the examples I've seen for loading data into Spark convert a
FlightStreamReader to pandas using to_pandas().

However this seems to load the entire contents of the stream into memory.
Is there an easy way to load individual chunks from the FlightStream into
dataframes? I figure you could call get_chunk() to get a record batch then
convert the batch to a dataframe.

-- 

*James Duong*
Lead Software Developer
Bit Quill Technologies Inc.
Direct: +1.604.562.6082 | [email protected]
https://www.bitquilltech.com

This email message is for the sole use of the intended recipient(s) and may
contain confidential and privileged information.  Any unauthorized review,
use, disclosure, or distribution is prohibited.  If you are not the
intended recipient, please contact the sender by reply email and destroy
all copies of the original message.  Thank you.

Reply via email to