chore: Release v2.0.0

CHANGELOG.md

@@ -4,6 +4,17 @@
 
 [1]: https://pypi.org/project/google-cloud-bigquery-storage/#history
 
+## 2.0.0
+
+09-24-2020 08:21 PDT
+
+### Implementation Changes
+
+- Transition the library to microgenerator. ([#62](https://github.com/googleapis/python-bigquery-storage/pull/62))
+  This is a **breaking change** that introduces several **method signature changes** and **drops support
+  for Python 2.7 and 3.5**. See [migration guide](https://googleapis.dev/python/bigquerystorage/latest/UPGRADING.html)
+  for more info.
+
 ## 1.1.0
 
 09-14-2020 08:51 PDT

UPGRADING.md

@@ -33,9 +33,10 @@ The 2.0.0 release requires Python 3.6+.
 
 ## Import Path
 
-The library was moved into `google.cloud.bigquery` namespace. It is recommended
-to use this path in order to reduce the chance of future compatibility issues
-in case the library is restuctured internally.
+The library's top-level namespace is `google.cloud.bigquery_storage`. Importing
+from `google.cloud.bigquery_storage_v1` still works, but it is advisable to use
+the `google.cloud.bigquery_storage` path in order to reduce the chance of future
+compatibility issues should the library be restuctured internally.
 
 **Before:**
 ```py
@@ -44,7 +45,7 @@ from google.cloud.bigquery_storage_v1 import BigQueryReadClient
 
 **After:**
 ```py
-from google.cloud.bigquery.storage import BigQueryReadClient
+from google.cloud.bigquery_storage import BigQueryReadClient
 ```
 
 
@@ -65,7 +66,7 @@ data_format = BigQueryReadClient.enums.DataFormat.ARROW
 
 **After:**
 ```py
-from google.cloud.bigquery.storage import types
+from google.cloud.bigquery_storage import types
 
 data_format = types.DataFormat.ARROW
 ```
@@ -157,13 +158,13 @@ session = client.create_read_session(
 
 **After:**
 ```py
-from google.cloud.bigquery import storage
+from google.cloud import bigquery_storage
 
-client = storage.BigQueryReadClient()
+client = bigquery_storage.BigQueryReadClient()
 
-requested_session = storage.types.ReadSession(
+requested_session = bigquery_storage.types.ReadSession(
     table="projects/PROJECT_ID/datasets/DATASET_ID/tables/TABLE_ID",
-    data_format=storage.types.DataFormat.ARROW,
+    data_format=bigquery_storage.types.DataFormat.ARROW,
 )
 session = client.create_read_session(
     request={

docs/storage_v1/services.rst → docs/bigquery_storage_v1/services.rst

@@ -1,6 +1,6 @@
 Services for Google Cloud Bigquery Storage v1 API
 =================================================
 
-.. automodule:: google.cloud.bigquery.storage_v1.services.big_query_read
+.. automodule:: google.cloud.bigquery_storage_v1.services.big_query_read
     :members:
     :inherited-members:

docs/storage_v1/types.rst → docs/bigquery_storage_v1/types.rst

@@ -1,5 +1,5 @@
 Types for Google Cloud Bigquery Storage v1 API
 ==============================================
 
-.. automodule:: google.cloud.bigquery.storage_v1.types
+.. automodule:: google.cloud.bigquery_storage_v1.types
     :members:

docs/index.rst

@@ -18,9 +18,9 @@ API Reference
 .. toctree::
     :maxdepth: 2
 
-    storage_v1/library
-    storage_v1/services
-    storage_v1/types
+    bigquery_storage_v1/library
+    bigquery_storage_v1/services
+    bigquery_storage_v1/types
 
 
 Migration Guide

google/cloud/bigquery/storage/__init__.py → google/cloud/bigquery_storage/__init__.py

@@ -16,22 +16,22 @@
 #
 
 from google.cloud.bigquery_storage_v1 import BigQueryReadClient
-from google.cloud.bigquery_storage_v1 import types
+from google.cloud.bigquery_storage_v1 import gapic_types as types
 from google.cloud.bigquery_storage_v1 import __version__
-from google.cloud.bigquery.storage_v1.types.arrow import ArrowRecordBatch
-from google.cloud.bigquery.storage_v1.types.arrow import ArrowSchema
-from google.cloud.bigquery.storage_v1.types.avro import AvroRows
-from google.cloud.bigquery.storage_v1.types.avro import AvroSchema
-from google.cloud.bigquery.storage_v1.types.storage import CreateReadSessionRequest
-from google.cloud.bigquery.storage_v1.types.storage import ReadRowsRequest
-from google.cloud.bigquery.storage_v1.types.storage import ReadRowsResponse
-from google.cloud.bigquery.storage_v1.types.storage import SplitReadStreamRequest
-from google.cloud.bigquery.storage_v1.types.storage import SplitReadStreamResponse
-from google.cloud.bigquery.storage_v1.types.storage import StreamStats
-from google.cloud.bigquery.storage_v1.types.storage import ThrottleState
-from google.cloud.bigquery.storage_v1.types.stream import DataFormat
-from google.cloud.bigquery.storage_v1.types.stream import ReadSession
-from google.cloud.bigquery.storage_v1.types.stream import ReadStream
+from google.cloud.bigquery_storage_v1.types.arrow import ArrowRecordBatch
+from google.cloud.bigquery_storage_v1.types.arrow import ArrowSchema
+from google.cloud.bigquery_storage_v1.types.avro import AvroRows
+from google.cloud.bigquery_storage_v1.types.avro import AvroSchema
+from google.cloud.bigquery_storage_v1.types.storage import CreateReadSessionRequest
+from google.cloud.bigquery_storage_v1.types.storage import ReadRowsRequest
+from google.cloud.bigquery_storage_v1.types.storage import ReadRowsResponse
+from google.cloud.bigquery_storage_v1.types.storage import SplitReadStreamRequest
+from google.cloud.bigquery_storage_v1.types.storage import SplitReadStreamResponse
+from google.cloud.bigquery_storage_v1.types.storage import StreamStats
+from google.cloud.bigquery_storage_v1.types.storage import ThrottleState
+from google.cloud.bigquery_storage_v1.types.stream import DataFormat
+from google.cloud.bigquery_storage_v1.types.stream import ReadSession
+from google.cloud.bigquery_storage_v1.types.stream import ReadStream
 
 __all__ = (
     "__version__",

google/cloud/bigquery_storage_v1/client.py

@@ -23,8 +23,8 @@
 
 import google.api_core.gapic_v1.method
 
-from google.cloud.bigquery import storage_v1
 from google.cloud.bigquery_storage_v1 import reader
+from google.cloud.bigquery_storage_v1.services import big_query_read
 
 
 _SCOPES = (
@@ -33,7 +33,7 @@
 )
 
 
-class BigQueryReadClient(storage_v1.BigQueryReadClient):
+class BigQueryReadClient(big_query_read.BigQueryReadClient):
     """Client for interacting with BigQuery Storage API.
 
     The BigQuery storage API can be used to read data stored in BigQuery.
@@ -60,9 +60,9 @@ def read_rows(
         to read data.
 
         Example:
-            >>> from google.cloud.bigquery import storage
+            >>> from google.cloud import bigquery_storage
             >>>
-            >>> client = storage.BigQueryReadClient()
+            >>> client = bigquery_storage.BigQueryReadClient()
             >>>
             >>> # TODO: Initialize ``table``:
             >>> table = "projects/{}/datasets/{}/tables/{}".format(
@@ -74,9 +74,9 @@ def read_rows(
             >>> # TODO: Initialize `parent`:
             >>> parent = 'projects/your-billing-project-id'
             >>>
-            >>> requested_session = storage.types.ReadSession(
+            >>> requested_session = bigquery_storage.types.ReadSession(
             ...     table=table,
-            ...     data_format=storage.types.DataFormat.AVRO,
+            ...     data_format=bigquery_storage.types.DataFormat.AVRO,
             ... )
             >>> session = client.create_read_session(
             ...     parent=parent, read_session=requested_session

google/cloud/bigquery_storage_v1/types.py → google/cloud/bigquery_storage_v1/gapic_types.py

@@ -22,10 +22,10 @@
 
 import proto
 
-from google.cloud.bigquery.storage_v1.types import arrow
-from google.cloud.bigquery.storage_v1.types import avro
-from google.cloud.bigquery.storage_v1.types import storage
-from google.cloud.bigquery.storage_v1.types import stream
+from google.cloud.bigquery_storage_v1.types import arrow
+from google.cloud.bigquery_storage_v1.types import avro
+from google.cloud.bigquery_storage_v1.types import storage
+from google.cloud.bigquery_storage_v1.types import stream
 
 from google.protobuf import message as protobuf_message
 from google.protobuf import timestamp_pb2

google/cloud/bigquery_storage_v1/reader.py

@@ -81,11 +81,11 @@ def __init__(self, wrapped, client, name, offset, read_rows_kwargs):
 
         Args:
             wrapped (Iterable[ \
-                ~google.cloud.bigquery.storage.types.ReadRowsResponse \
+                ~google.cloud.bigquery_storage.types.ReadRowsResponse \
             ]):
                 The ReadRows stream to read.
             client ( \
-                ~google.cloud.bigquery.storage_v1.services. \
+                ~google.cloud.bigquery_storage_v1.services. \
                     big_query_read.BigQueryReadClient \
             ):
                 A GAPIC client used to reconnect to a ReadRows stream. This
@@ -104,7 +104,7 @@ def __init__(self, wrapped, client, name, offset, read_rows_kwargs):
 
         Returns:
             Iterable[ \
-                ~google.cloud.bigquery_storage_v1.types.ReadRowsResponse \
+                ~google.cloud.bigquery_storage.types.ReadRowsResponse \
             ]:
                 A sequence of row messages.
         """

google/cloud/bigquery/storage_v1/services/big_query_read/async_client.py → google/cloud/bigquery_storage_v1/services/big_query_read/async_client.py

@@ -28,10 +28,10 @@
 from google.auth import credentials  # type: ignore
 from google.oauth2 import service_account  # type: ignore
 
-from google.cloud.bigquery.storage_v1.types import arrow
-from google.cloud.bigquery.storage_v1.types import avro
-from google.cloud.bigquery.storage_v1.types import storage
-from google.cloud.bigquery.storage_v1.types import stream
+from google.cloud.bigquery_storage_v1.types import arrow
+from google.cloud.bigquery_storage_v1.types import avro
+from google.cloud.bigquery_storage_v1.types import storage
+from google.cloud.bigquery_storage_v1.types import stream
 from google.protobuf import timestamp_pb2 as timestamp  # type: ignore
 
 from .transports.base import BigQueryReadTransport, DEFAULT_CLIENT_INFO

google/cloud/bigquery/storage_v1/services/big_query_read/client.py → google/cloud/bigquery_storage_v1/services/big_query_read/client.py

@@ -32,10 +32,10 @@
 from google.auth.exceptions import MutualTLSChannelError  # type: ignore
 from google.oauth2 import service_account  # type: ignore
 
-from google.cloud.bigquery.storage_v1.types import arrow
-from google.cloud.bigquery.storage_v1.types import avro
-from google.cloud.bigquery.storage_v1.types import storage
-from google.cloud.bigquery.storage_v1.types import stream
+from google.cloud.bigquery_storage_v1.types import arrow
+from google.cloud.bigquery_storage_v1.types import avro
+from google.cloud.bigquery_storage_v1.types import storage
+from google.cloud.bigquery_storage_v1.types import stream
 from google.protobuf import timestamp_pb2 as timestamp  # type: ignore
 
 from .transports.base import BigQueryReadTransport, DEFAULT_CLIENT_INFO

google/cloud/bigquery/storage_v1/services/big_query_read/transports/base.py → google/cloud/bigquery_storage_v1/services/big_query_read/transports/base.py

@@ -25,8 +25,8 @@
 from google.api_core import retry as retries  # type: ignore
 from google.auth import credentials  # type: ignore
 
-from google.cloud.bigquery.storage_v1.types import storage
-from google.cloud.bigquery.storage_v1.types import stream
+from google.cloud.bigquery_storage_v1.types import storage
+from google.cloud.bigquery_storage_v1.types import stream
 
 
 try:

google/cloud/bigquery/storage_v1/services/big_query_read/transports/grpc.py → google/cloud/bigquery_storage_v1/services/big_query_read/transports/grpc.py

@@ -26,8 +26,8 @@
 
 import grpc  # type: ignore
 
-from google.cloud.bigquery.storage_v1.types import storage
-from google.cloud.bigquery.storage_v1.types import stream
+from google.cloud.bigquery_storage_v1.types import storage
+from google.cloud.bigquery_storage_v1.types import stream
 
 from .base import BigQueryReadTransport, DEFAULT_CLIENT_INFO
 

google/cloud/bigquery/storage_v1/services/big_query_read/transports/grpc_asyncio.py → google/cloud/bigquery_storage_v1/services/big_query_read/transports/grpc_asyncio.py

@@ -27,8 +27,8 @@
 import grpc  # type: ignore
 from grpc.experimental import aio  # type: ignore
 
-from google.cloud.bigquery.storage_v1.types import storage
-from google.cloud.bigquery.storage_v1.types import stream
+from google.cloud.bigquery_storage_v1.types import storage
+from google.cloud.bigquery_storage_v1.types import stream
 
 from .base import BigQueryReadTransport, DEFAULT_CLIENT_INFO
 from .grpc import BigQueryReadGrpcTransport

google/cloud/bigquery/storage_v1/types/__init__.py → google/cloud/bigquery_storage_v1/types/__init__.py

@@ -24,6 +24,7 @@
     AvroRows,
 )
 from .stream import (
+    DataFormat,
     ReadSession,
     ReadStream,
 )
@@ -43,6 +44,7 @@
     "ArrowRecordBatch",
     "AvroSchema",
     "AvroRows",
+    "DataFormat",
     "ReadSession",
     "ReadStream",
     "CreateReadSessionRequest",

google/cloud/bigquery/storage_v1/types/storage.py → google/cloud/bigquery_storage_v1/types/storage.py

@@ -18,9 +18,9 @@
 import proto  # type: ignore
 
 
-from google.cloud.bigquery.storage_v1.types import arrow
-from google.cloud.bigquery.storage_v1.types import avro
-from google.cloud.bigquery.storage_v1.types import stream
+from google.cloud.bigquery_storage_v1.types import arrow
+from google.cloud.bigquery_storage_v1.types import avro
+from google.cloud.bigquery_storage_v1.types import stream
 
 
 __protobuf__ = proto.module(

google/cloud/bigquery/storage_v1/types/stream.py → google/cloud/bigquery_storage_v1/types/stream.py

@@ -18,8 +18,8 @@
 import proto  # type: ignore
 
 
-from google.cloud.bigquery.storage_v1.types import arrow
-from google.cloud.bigquery.storage_v1.types import avro
+from google.cloud.bigquery_storage_v1.types import arrow
+from google.cloud.bigquery_storage_v1.types import avro
 from google.protobuf import timestamp_pb2 as timestamp  # type: ignore
 
 

noxfile.py

@@ -79,9 +79,10 @@ def default(session):
     session.run(
         "py.test",
         "--quiet",
-        "--cov=google.cloud.bigquerystorage",
+        "--cov=google.cloud.bigquery_storage",
+        "--cov=google.cloud.bigquery_storage_v1",
         "--cov=google.cloud",
-        "--cov=tests.unit",
+        "--cov=tests/unit",
         "--cov-append",
         "--cov-config=.coveragerc",
         "--cov-report=",

samples/quickstart/quickstart.py

@@ -17,8 +17,8 @@
 
 def main(project_id="your-project-id", snapshot_millis=0):
     # [START bigquerystorage_quickstart]
-    from google.cloud.bigquery.storage import BigQueryReadClient
-    from google.cloud.bigquery.storage import types
+    from google.cloud.bigquery_storage import BigQueryReadClient
+    from google.cloud.bigquery_storage import types
 
     # TODO(developer): Set the project_id variable.
     # project_id = 'your-project-id'