Skip to content

Commit

Permalink
Drop fossil docs refs to 'read_streaming'/'execute_streaming_sql'. (g…
Browse files Browse the repository at this point in the history
  • Loading branch information
tseaver authored and lukesneeringer committed Apr 6, 2017
1 parent f29bef3 commit f95e997
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 117 deletions.
40 changes: 1 addition & 39 deletions docs/spanner-session-implicit-txn-usage.rst
Original file line number Diff line number Diff line change
Expand Up @@ -22,28 +22,10 @@ fails if the result set is too large,
for row in result.rows:
print(row)
Read Streaming Table Data
-------------------------

Read data for selected rows from a table in the session's database. Calls
the ``StreamingRead`` API, which returns partial result sets.
:meth:`Session.streaming_read` coalesces these partial result sets as its
result object's rows are iterated.

.. code:: python
result = session.read_streaming(
table='table-name', columns=['first_name', 'last_name', 'age'],
key_set=VERY_LONG_LIST_OF_KEYS)
for row in result.rows:
print(row)
.. note::

If streaming a chunk fails due to a "resumable" error,
:meth:`Session.read_streaming` retries the ``StreamingRead`` API reqeust,
:meth:`Session.read` retries the ``StreamingRead`` API reqeust,
passing the ``resume_token`` from the last partial result streamed.


Expand All @@ -66,26 +48,6 @@ fails if the result set is too large,
print(row)
Execute a Streaming SQL Select Statement
----------------------------------------

Read data a query against tables in the session's database. Calls
the ``ExecuteStreamingSql`` API, which returns partial result sets.
:meth:`Session.execute_streaming_sql` coalesces these partial result sets as
its result object's rows are iterated.

.. code:: python
QUERY = (
'SELECT e.first_name, e.last_name, p.telephone '
'FROM employees as e, phones as p '
'WHERE p.employee_id == e.employee_id')
result = session.execute_streaming_sql(QUERY)
for row in result.rows:
print(row)
Next Step
---------

Expand Down
40 changes: 1 addition & 39 deletions docs/spanner-snapshot-usage.rst
Original file line number Diff line number Diff line change
Expand Up @@ -52,28 +52,10 @@ fails if the result set is too large,
for row in result.rows:
print(row)
Read Streaming Table Data
-------------------------

Read data for selected rows from a table in the session's database. Calls
the ``StreamingRead`` API, which returns partial result sets.
:meth:`Session.streaming_read` coalesces these partial result sets as its
result object's rows are iterated.

.. code:: python
result = snapshot.read_streaming(
table='table-name', columns=['first_name', 'last_name', 'age'],
key_set=VERY_LONG_LIST_OF_KEYS)
for row in result.rows:
print(row)
.. note::

If streaming a chunk fails due to a "resumable" error,
:meth:`Session.read_streaming` retries the ``StreamingRead`` API reqeust,
:meth:`Session.read` retries the ``StreamingRead`` API reqeust,
passing the ``resume_token`` from the last partial result streamed.


Expand All @@ -96,26 +78,6 @@ fails if the result set is too large,
print(row)
Execute a Streaming SQL Select Statement
----------------------------------------

Read data a query against tables in the session's database. Calls
the ``ExecuteStreamingSql`` API, which returns partial result sets.
:meth:`Session.execute_streaming_sql` coalesces these partial result sets as
its result object's rows are iterated.

.. code:: python
QUERY = (
'SELECT e.first_name, e.last_name, p.telephone '
'FROM employees as e, phones as p '
'WHERE p.employee_id == e.employee_id')
result = snapshot.execute_streaming_sql(QUERY)
for row in result.rows:
print(row)
Next Step
---------

Expand Down
40 changes: 1 addition & 39 deletions docs/spanner-transaction-usage.rst
Original file line number Diff line number Diff line change
Expand Up @@ -32,28 +32,10 @@ fails if the result set is too large,
for row in result.rows:
print(row)
Read Streaming Table Data
-------------------------

Read data for selected rows from a table in the session's database. Calls
the ``StreamingRead`` API, which returns partial result sets.
:meth:`Session.streaming_read` coalesces these partial result sets as its
result object's rows are iterated.

.. code:: python
result = transaction.read_streaming(
table='table-name', columns=['first_name', 'last_name', 'age'],
key_set=VERY_LONG_LIST_OF_KEYS)
for row in result.rows:
print(row)
.. note::

If streaming a chunk fails due to a "resumable" error,
:meth:`Session.read_streaming` retries the ``StreamingRead`` API reqeust,
:meth:`Session.read` retries the ``StreamingRead`` API reqeust,
passing the ``resume_token`` from the last partial result streamed.


Expand All @@ -76,26 +58,6 @@ fails if the result set is too large,
print(row)
Execute a Streaming SQL Select Statement
----------------------------------------

Read data a query against tables in the session's database. Calls
the ``ExecuteStreamingSql`` API, which returns partial result sets.
:meth:`Session.execute_streaming_sql` coalesces these partial result sets as
its result object's rows are iterated.

.. code:: python
QUERY = (
'SELECT e.first_name, e.last_name, p.telephone '
'FROM employees as e, phones as p '
'WHERE p.employee_id == e.employee_id')
result = transaction.execute_streaming_sql(QUERY)
for row in result.rows:
print(row)
Insert records using a Transaction
----------------------------------

Expand Down

0 comments on commit f95e997

Please sign in to comment.