Convenience wrapper for consuming a ReadRows streaming response.
The ReadRowsRequest message used to create a ReadRowsResponse iterator. If the iterator fails, a new iterator is created, allowing the scan to continue from the point just beyond the last successfully read row, identified by self.last_scanned_row_key. The retry happens inside of the Retry class, using a predicate for the expected exceptions during iteration.
(Optional) Retry delay and deadline arguments. To override, the default value DEFAULT_RETRY_READ_ROWS can be used and modified with the google.api_core.retry.Retry.with_delay method or the google.api_core.retry.Retry.with_deadline method.
builtins.object > PartialRowsData
State machine state.
name of state corresponding to current row / chunk processing.
Consume the ReadRowsResponse s from the stream.
Read the rows and yield each to the reader
Parse the response and its chunks into a new/existing row in
_rows. Rows are returned in order by row key.
Cancels the iterator, closing the stream.
Consume the streamed responses until there are no more.
(Optional) Maximum number of times to try to consume an additional ReadRowsResponse. You can use this to avoid long wait times.