pyarrow.flight.MetadataRecordBatchReader#

classpyarrow.flight.MetadataRecordBatchReader#

Bases:_MetadataRecordBatchReader

The base class for readers for Flight streams.

See also

FlightStreamReader

__init__(*args,**kwargs)#

Methods

__init__(*args, **kwargs)
read_all(self)	Read the entire contents of the stream as a Table.
read_chunk(self)	Read the next FlightStreamChunk along with any metadata.
read_pandas(self, **options)	Read contents of stream to a pandas.DataFrame.
to_reader(self)	Convert this reader into a regular RecordBatchReader.

Attributes

schema	Get the schema for this reader.
stats	Current Flight read statistics.

read_all(self)#

Read the entire contents of the stream as a Table.

read_chunk(self)#

Read the next FlightStreamChunk along with any metadata.

Returns:

chunkFlightStreamChunk

The next FlightStreamChunk in the stream.

Raises:

StopIteration

when the stream is finished

read_pandas(self,**options)#

Read contents of stream to a pandas.DataFrame.

Read all record batches as a pyarrow.Table then convert it to apandas.DataFrame using Table.to_pandas.

Parameters:

**options

Arguments to forward toTable.to_pandas().

Returns:

dfpandas.DataFrame

schema#

Get the schema for this reader.

stats#

Current Flight read statistics.

Returns:

ReadStats

to_reader(self)#

Convert this reader into a regular RecordBatchReader.

This may fail if the schema cannot be read from the remote end.

Returns:

RecordBatchReader