ReadRowsIterable(reader, read_session=None)An iterable of rows from a read session.
| Parameters | |
|---|---|
| Name | Description | 
| reader | google.cloud.bigquery_storage_v1.reader.ReadRowsStreamA read rows stream. | 
| read_session | Optional[ReadSession]DEPRECATED. This argument was used to specify the schema of the rows in the stream, but now the first message in a read stream contains this information. | 
Properties
pages
A generator of all pages in the stream.
| Returns | |
|---|---|
| Type | Description | 
| types.GeneratorType[google.cloud.bigquery_storage_v1.ReadRowsPage] | A generator of pages. | 
Methods
__iter__
__iter__()Iterator for each row in all pages.
to_arrow
to_arrow()Create a pyarrow.Table of all rows in the stream.
This method requires the pyarrow library and a stream using the Arrow format.
| Returns | |
|---|---|
| Type | Description | 
| pyarrow.Table | A table of all rows in the stream. | 
to_dataframe
to_dataframe(dtypes=None)Create a pandas.DataFrame of all rows in the stream.
This method requires the pandas libary to create a data frame and the fastavro library to parse row messages.
| Parameter | |
|---|---|
| Name | Description | 
| dtypes | Map[str, Union[str, pandas.Series.dtype]]Optional. A dictionary of column names pandas  | 
| Returns | |
|---|---|
| Type | Description | 
| pandas.DataFrame | A data frame of all rows in the stream. |