Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly
Appearance settings

Commit 2e75c78

Browse filesBrowse files
sofislsofisl
authored
feat: update API sources and regenerate (#17431)
1 parent f59c2b2 commit 2e75c78
Copy full SHA for 2e75c78

70 files changed

+19,654-8,972Lines changed: 19654 additions & 8972 deletions

File tree

Expand file treeCollapse file tree
Open diff view settings
Filter options

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
Dismiss banner
Expand file treeCollapse file tree
Open diff view settings
Collapse file

‎librarian.yaml‎

Copy file name to clipboardExpand all lines: librarian.yaml
+2-2Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -16,8 +16,8 @@ version: v0.19.0
1616
repo: googleapis/google-cloud-python
1717
sources:
1818
googleapis:
19-
commit: d8daa97972d091191898915589335cef66fcdc8a
20-
sha256: 7dbdf2b1b667fe57128d41c77e530a2541767772cfe3487713f29b7b25d9f5ad
19+
commit: f93e046328794785ad89869f00c0358dfcff2c35
20+
sha256: 415249f584d57e5a2298c36ae9ff71563403112dee04ac961023a1b0098404d2
2121
default:
2222
output: packages
2323
tag_format: '{name}-v{version}'
Collapse file

‎packages/google-cloud-biglake/google/cloud/biglake_v1/services/iceberg_catalog_service/async_client.py‎

Copy file name to clipboardExpand all lines: packages/google-cloud-biglake/google/cloud/biglake_v1/services/iceberg_catalog_service/async_client.py
+46-33Lines changed: 46 additions & 33 deletions
Original file line numberDiff line numberDiff line change
@@ -65,34 +65,15 @@
6565

6666

6767
class IcebergCatalogServiceAsyncClient:
68-
"""Iceberg Catalog Service API: this implements the open-source Iceberg
69-
REST Catalog API. See the API definition here:
70-
https://github.com/apache/iceberg/blob/main/open-api/rest-catalog-open-api.yaml
71-
72-
The API is defined as OpenAPI 3.1.1 spec.
73-
74-
Currently we only support the following methods:
75-
76-
- GetConfig/GetIcebergCatalogConfig
77-
- ListIcebergNamespaces
78-
- CheckIcebergNamespaceExists
79-
- GetIcebergNamespace
80-
- CreateIcebergNamespace (only supports single level)
81-
- DeleteIcebergNamespace
82-
- UpdateIcebergNamespace properties
83-
- ListTableIdentifiers
84-
- CreateIcebergTable
85-
- DeleteIcebergTable
86-
- GetIcebergTable
87-
- UpdateIcebergTable (CommitTable)
88-
- LoadIcebergTableCredentials
89-
- RegisterTable
90-
91-
Users are required to provided the ``X-Goog-User-Project`` header
92-
with the project id or number which can be different from the bucket
93-
project id. That project will be charged for the API calls and the
94-
calling user must have access to that project. The caller must have
95-
``serviceusage.services.use`` permission on the project.
68+
"""Lakehouse runtime catalog supports the following catalog
69+
management methods:
70+
71+
- GetIcebergCatalog
72+
- ListIcebergCatalogs
73+
- DeleteIcebergCatalog
74+
- UpdateIcebergCatalog
75+
- CreateIcebergCatalog
76+
- FailoverIcebergCatalog
9677
"""
9778

9879
_client: IcebergCatalogServiceClient
@@ -106,6 +87,10 @@ class IcebergCatalogServiceAsyncClient:
10687

10788
catalog_path = staticmethod(IcebergCatalogServiceClient.catalog_path)
10889
parse_catalog_path = staticmethod(IcebergCatalogServiceClient.parse_catalog_path)
90+
secret_path = staticmethod(IcebergCatalogServiceClient.secret_path)
91+
parse_secret_path = staticmethod(IcebergCatalogServiceClient.parse_secret_path)
92+
service_path = staticmethod(IcebergCatalogServiceClient.service_path)
93+
parse_service_path = staticmethod(IcebergCatalogServiceClient.parse_service_path)
10994
common_billing_account_path = staticmethod(
11095
IcebergCatalogServiceClient.common_billing_account_path
11196
)
@@ -599,7 +584,7 @@ async def sample_update_iceberg_catalog():
599584
600585
# Initialize request argument(s)
601586
iceberg_catalog = biglake_v1.IcebergCatalog()
602-
iceberg_catalog.catalog_type = "CATALOG_TYPE_GCS_BUCKET"
587+
iceberg_catalog.catalog_type = "CATALOG_TYPE_FEDERATED"
603588
604589
request = biglake_v1.UpdateIcebergCatalogRequest(
605590
iceberg_catalog=iceberg_catalog,
@@ -701,12 +686,12 @@ async def create_iceberg_catalog(
701686
parent: Optional[str] = None,
702687
iceberg_catalog: Optional[iceberg_rest_catalog.IcebergCatalog] = None,
703688
iceberg_catalog_id: Optional[str] = None,
689+
primary_location: Optional[str] = None,
704690
retry: OptionalRetry = gapic_v1.method.DEFAULT,
705691
timeout: Union[float, object] = gapic_v1.method.DEFAULT,
706692
metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
707693
) -> iceberg_rest_catalog.IcebergCatalog:
708-
r"""Creates the Iceberg REST Catalog. Currently only supports Google
709-
Cloud Storage Bucket catalogs. Google Cloud Storage Bucket
694+
r"""Creates the Iceberg REST Catalog. Google Cloud Storage Bucket
710695
catalog id is the bucket for which the catalog is created (e.g.
711696
``my-catalog`` for ``gs://my-catalog``).
712697
@@ -730,7 +715,7 @@ async def sample_create_iceberg_catalog():
730715
731716
# Initialize request argument(s)
732717
iceberg_catalog = biglake_v1.IcebergCatalog()
733-
iceberg_catalog.catalog_type = "CATALOG_TYPE_GCS_BUCKET"
718+
iceberg_catalog.catalog_type = "CATALOG_TYPE_FEDERATED"
734719
735720
request = biglake_v1.CreateIcebergCatalogRequest(
736721
parent="parent_value",
@@ -770,6 +755,27 @@ async def sample_create_iceberg_catalog():
770755
This corresponds to the ``iceberg_catalog_id`` field
771756
on the ``request`` instance; if ``request`` is provided, this
772757
should not be set.
758+
primary_location (:class:`str`):
759+
Optional. The primary location where the catalog
760+
metadata will be stored.
761+
762+
For Google Cloud Storage bucket catalogs and BigLake
763+
catalogs, if this is not specified, then the region is
764+
inferred from the bucket's region (``default_location``
765+
bucket for BigLake catalogs). If specified, the region
766+
must be in jurisdiction (near the ``default_location``
767+
bucket's region and the ``restricted_locations``
768+
buckets' regions for BigLake catalogs).
769+
770+
For federated catalogs, this must be specified and be a
771+
Lakehouse-supported location
772+
(https://docs.cloud.google.com/lakehouse/docs/locations).
773+
It should be close to the remote catalog's location for
774+
the best performance and cost.
775+
776+
This corresponds to the ``primary_location`` field
777+
on the ``request`` instance; if ``request`` is provided, this
778+
should not be set.
773779
retry (google.api_core.retry_async.AsyncRetry): Designation of what errors, if any,
774780
should be retried.
775781
timeout (float): The timeout for this request.
@@ -785,7 +791,12 @@ async def sample_create_iceberg_catalog():
785791
# Create or coerce a protobuf request object.
786792
# - Quick check: If we got a request object, we should *not* have
787793
# gotten any keyword arguments that map to the request.
788-
flattened_params = [parent, iceberg_catalog, iceberg_catalog_id]
794+
flattened_params = [
795+
parent,
796+
iceberg_catalog,
797+
iceberg_catalog_id,
798+
primary_location,
799+
]
789800
has_flattened_params = (
790801
len([param for param in flattened_params if param is not None]) > 0
791802
)
@@ -808,6 +819,8 @@ async def sample_create_iceberg_catalog():
808819
request.iceberg_catalog = iceberg_catalog
809820
if iceberg_catalog_id is not None:
810821
request.iceberg_catalog_id = iceberg_catalog_id
822+
if primary_location is not None:
823+
request.primary_location = primary_location
811824

812825
# Wrap the RPC method; this adds retry and timeout information,
813826
# and friendly error handling.
Collapse file

‎packages/google-cloud-biglake/google/cloud/biglake_v1/services/iceberg_catalog_service/client.py‎

Copy file name to clipboardExpand all lines: packages/google-cloud-biglake/google/cloud/biglake_v1/services/iceberg_catalog_service/client.py
+83-33Lines changed: 83 additions & 33 deletions
Original file line numberDiff line numberDiff line change
@@ -109,34 +109,15 @@ def get_transport_class(
109109

110110

111111
class IcebergCatalogServiceClient(metaclass=IcebergCatalogServiceClientMeta):
112-
"""Iceberg Catalog Service API: this implements the open-source Iceberg
113-
REST Catalog API. See the API definition here:
114-
https://github.com/apache/iceberg/blob/main/open-api/rest-catalog-open-api.yaml
115-
116-
The API is defined as OpenAPI 3.1.1 spec.
117-
118-
Currently we only support the following methods:
119-
120-
- GetConfig/GetIcebergCatalogConfig
121-
- ListIcebergNamespaces
122-
- CheckIcebergNamespaceExists
123-
- GetIcebergNamespace
124-
- CreateIcebergNamespace (only supports single level)
125-
- DeleteIcebergNamespace
126-
- UpdateIcebergNamespace properties
127-
- ListTableIdentifiers
128-
- CreateIcebergTable
129-
- DeleteIcebergTable
130-
- GetIcebergTable
131-
- UpdateIcebergTable (CommitTable)
132-
- LoadIcebergTableCredentials
133-
- RegisterTable
134-
135-
Users are required to provided the ``X-Goog-User-Project`` header
136-
with the project id or number which can be different from the bucket
137-
project id. That project will be charged for the API calls and the
138-
calling user must have access to that project. The caller must have
139-
``serviceusage.services.use`` permission on the project.
112+
"""Lakehouse runtime catalog supports the following catalog
113+
management methods:
114+
115+
- GetIcebergCatalog
116+
- ListIcebergCatalogs
117+
- DeleteIcebergCatalog
118+
- UpdateIcebergCatalog
119+
- CreateIcebergCatalog
120+
- FailoverIcebergCatalog
140121
"""
141122

142123
@staticmethod
@@ -274,6 +255,47 @@ def parse_catalog_path(path: str) -> Dict[str, str]:
274255
m = re.match(r"^projects/(?P<project>.+?)/catalogs/(?P<catalog>.+?)$", path)
275256
return m.groupdict() if m else {}
276257

258+
@staticmethod
259+
def secret_path(
260+
project: str,
261+
secret: str,
262+
) -> str:
263+
"""Returns a fully-qualified secret string."""
264+
return "projects/{project}/secrets/{secret}".format(
265+
project=project,
266+
secret=secret,
267+
)
268+
269+
@staticmethod
270+
def parse_secret_path(path: str) -> Dict[str, str]:
271+
"""Parses a secret path into its component segments."""
272+
m = re.match(r"^projects/(?P<project>.+?)/secrets/(?P<secret>.+?)$", path)
273+
return m.groupdict() if m else {}
274+
275+
@staticmethod
276+
def service_path(
277+
project: str,
278+
location: str,
279+
namespace: str,
280+
service: str,
281+
) -> str:
282+
"""Returns a fully-qualified service string."""
283+
return "projects/{project}/locations/{location}/namespaces/{namespace}/services/{service}".format(
284+
project=project,
285+
location=location,
286+
namespace=namespace,
287+
service=service,
288+
)
289+
290+
@staticmethod
291+
def parse_service_path(path: str) -> Dict[str, str]:
292+
"""Parses a service path into its component segments."""
293+
m = re.match(
294+
r"^projects/(?P<project>.+?)/locations/(?P<location>.+?)/namespaces/(?P<namespace>.+?)/services/(?P<service>.+?)$",
295+
path,
296+
)
297+
return m.groupdict() if m else {}
298+
277299
@staticmethod
278300
def common_billing_account_path(
279301
billing_account: str,
@@ -1021,7 +1043,7 @@ def sample_update_iceberg_catalog():
10211043
10221044
# Initialize request argument(s)
10231045
iceberg_catalog = biglake_v1.IcebergCatalog()
1024-
iceberg_catalog.catalog_type = "CATALOG_TYPE_GCS_BUCKET"
1046+
iceberg_catalog.catalog_type = "CATALOG_TYPE_FEDERATED"
10251047
10261048
request = biglake_v1.UpdateIcebergCatalogRequest(
10271049
iceberg_catalog=iceberg_catalog,
@@ -1120,12 +1142,12 @@ def create_iceberg_catalog(
11201142
parent: Optional[str] = None,
11211143
iceberg_catalog: Optional[iceberg_rest_catalog.IcebergCatalog] = None,
11221144
iceberg_catalog_id: Optional[str] = None,
1145+
primary_location: Optional[str] = None,
11231146
retry: OptionalRetry = gapic_v1.method.DEFAULT,
11241147
timeout: Union[float, object] = gapic_v1.method.DEFAULT,
11251148
metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
11261149
) -> iceberg_rest_catalog.IcebergCatalog:
1127-
r"""Creates the Iceberg REST Catalog. Currently only supports Google
1128-
Cloud Storage Bucket catalogs. Google Cloud Storage Bucket
1150+
r"""Creates the Iceberg REST Catalog. Google Cloud Storage Bucket
11291151
catalog id is the bucket for which the catalog is created (e.g.
11301152
``my-catalog`` for ``gs://my-catalog``).
11311153
@@ -1149,7 +1171,7 @@ def sample_create_iceberg_catalog():
11491171
11501172
# Initialize request argument(s)
11511173
iceberg_catalog = biglake_v1.IcebergCatalog()
1152-
iceberg_catalog.catalog_type = "CATALOG_TYPE_GCS_BUCKET"
1174+
iceberg_catalog.catalog_type = "CATALOG_TYPE_FEDERATED"
11531175
11541176
request = biglake_v1.CreateIcebergCatalogRequest(
11551177
parent="parent_value",
@@ -1189,6 +1211,27 @@ def sample_create_iceberg_catalog():
11891211
This corresponds to the ``iceberg_catalog_id`` field
11901212
on the ``request`` instance; if ``request`` is provided, this
11911213
should not be set.
1214+
primary_location (str):
1215+
Optional. The primary location where the catalog
1216+
metadata will be stored.
1217+
1218+
For Google Cloud Storage bucket catalogs and BigLake
1219+
catalogs, if this is not specified, then the region is
1220+
inferred from the bucket's region (``default_location``
1221+
bucket for BigLake catalogs). If specified, the region
1222+
must be in jurisdiction (near the ``default_location``
1223+
bucket's region and the ``restricted_locations``
1224+
buckets' regions for BigLake catalogs).
1225+
1226+
For federated catalogs, this must be specified and be a
1227+
Lakehouse-supported location
1228+
(https://docs.cloud.google.com/lakehouse/docs/locations).
1229+
It should be close to the remote catalog's location for
1230+
the best performance and cost.
1231+
1232+
This corresponds to the ``primary_location`` field
1233+
on the ``request`` instance; if ``request`` is provided, this
1234+
should not be set.
11921235
retry (google.api_core.retry.Retry): Designation of what errors, if any,
11931236
should be retried.
11941237
timeout (float): The timeout for this request.
@@ -1204,7 +1247,12 @@ def sample_create_iceberg_catalog():
12041247
# Create or coerce a protobuf request object.
12051248
# - Quick check: If we got a request object, we should *not* have
12061249
# gotten any keyword arguments that map to the request.
1207-
flattened_params = [parent, iceberg_catalog, iceberg_catalog_id]
1250+
flattened_params = [
1251+
parent,
1252+
iceberg_catalog,
1253+
iceberg_catalog_id,
1254+
primary_location,
1255+
]
12081256
has_flattened_params = (
12091257
len([param for param in flattened_params if param is not None]) > 0
12101258
)
@@ -1226,6 +1274,8 @@ def sample_create_iceberg_catalog():
12261274
request.iceberg_catalog = iceberg_catalog
12271275
if iceberg_catalog_id is not None:
12281276
request.iceberg_catalog_id = iceberg_catalog_id
1277+
if primary_location is not None:
1278+
request.primary_location = primary_location
12291279

12301280
# Wrap the RPC method; this adds retry and timeout information,
12311281
# and friendly error handling.
Collapse file

‎packages/google-cloud-biglake/google/cloud/biglake_v1/services/iceberg_catalog_service/transports/grpc.py‎

Copy file name to clipboardExpand all lines: packages/google-cloud-biglake/google/cloud/biglake_v1/services/iceberg_catalog_service/transports/grpc.py
+10-30Lines changed: 10 additions & 30 deletions
Original file line numberDiff line numberDiff line change
@@ -110,34 +110,15 @@ def intercept_unary_unary(self, continuation, client_call_details, request):
110110
class IcebergCatalogServiceGrpcTransport(IcebergCatalogServiceTransport):
111111
"""gRPC backend transport for IcebergCatalogService.
112112
113-
Iceberg Catalog Service API: this implements the open-source Iceberg
114-
REST Catalog API. See the API definition here:
115-
https://github.com/apache/iceberg/blob/main/open-api/rest-catalog-open-api.yaml
116-
117-
The API is defined as OpenAPI 3.1.1 spec.
118-
119-
Currently we only support the following methods:
120-
121-
- GetConfig/GetIcebergCatalogConfig
122-
- ListIcebergNamespaces
123-
- CheckIcebergNamespaceExists
124-
- GetIcebergNamespace
125-
- CreateIcebergNamespace (only supports single level)
126-
- DeleteIcebergNamespace
127-
- UpdateIcebergNamespace properties
128-
- ListTableIdentifiers
129-
- CreateIcebergTable
130-
- DeleteIcebergTable
131-
- GetIcebergTable
132-
- UpdateIcebergTable (CommitTable)
133-
- LoadIcebergTableCredentials
134-
- RegisterTable
135-
136-
Users are required to provided the ``X-Goog-User-Project`` header
137-
with the project id or number which can be different from the bucket
138-
project id. That project will be charged for the API calls and the
139-
calling user must have access to that project. The caller must have
140-
``serviceusage.services.use`` permission on the project.
113+
Lakehouse runtime catalog supports the following catalog
114+
management methods:
115+
116+
- GetIcebergCatalog
117+
- ListIcebergCatalogs
118+
- DeleteIcebergCatalog
119+
- UpdateIcebergCatalog
120+
- CreateIcebergCatalog
121+
- FailoverIcebergCatalog
141122
142123
This class defines the same methods as the primary client, so the
143124
primary client can load the underlying transport implementation
@@ -450,8 +431,7 @@ def create_iceberg_catalog(
450431
]:
451432
r"""Return a callable for the create iceberg catalog method over gRPC.
452433
453-
Creates the Iceberg REST Catalog. Currently only supports Google
454-
Cloud Storage Bucket catalogs. Google Cloud Storage Bucket
434+
Creates the Iceberg REST Catalog. Google Cloud Storage Bucket
455435
catalog id is the bucket for which the catalog is created (e.g.
456436
``my-catalog`` for ``gs://my-catalog``).
457437

0 commit comments

Comments
0 (0)
Morty Proxy This is a proxified and sanitized view of the page, visit original site.