`projects/{project_number}/locations/{location_id}/services/{service_id}`.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final Service getService(ServiceName name) {
+ GetServiceRequest request =
+ GetServiceRequest.newBuilder().setName(name == null ? null : name.toString()).build();
+ return getService(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Gets the details of a single service.
+ *
+ *
`projects/{project_number}/locations/{location_id}/services/{service_id}`.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final Service getService(String name) {
+ GetServiceRequest request = GetServiceRequest.newBuilder().setName(name).build();
+ return getService(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Gets the details of a single service.
+ *
+ *
getServiceCallable() {
+ return stub.getServiceCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Creates a metastore service in a project and location.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+ * Service service = Service.newBuilder().build();
+ * String serviceId = "serviceId-194185552";
+ * Service response =
+ * dataprocMetastoreClient.createServiceAsync(parent, service, serviceId).get();
+ * }
+ * }
+ *
+ * @param parent Required. The relative resource name of the location in which to create a
+ * metastore service, in the following form:
+ * `projects/{project_number}/locations/{location_id}`.
+ * @param service Required. The Metastore service to create. The `name` field is ignored. The ID
+ * of the created metastore service must be provided in the request's `service_id` field.
+ * @param serviceId Required. The ID of the metastore service, which is used as the final
+ * component of the metastore service's name.
+ *
This value must be between 2 and 63 characters long inclusive, begin with a letter, end
+ * with a letter or number, and consist of alpha-numeric ASCII characters or hyphens.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final OperationFuture createServiceAsync(
+ LocationName parent, Service service, String serviceId) {
+ CreateServiceRequest request =
+ CreateServiceRequest.newBuilder()
+ .setParent(parent == null ? null : parent.toString())
+ .setService(service)
+ .setServiceId(serviceId)
+ .build();
+ return createServiceAsync(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Creates a metastore service in a project and location.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
+ * Service service = Service.newBuilder().build();
+ * String serviceId = "serviceId-194185552";
+ * Service response =
+ * dataprocMetastoreClient.createServiceAsync(parent, service, serviceId).get();
+ * }
+ * }
+ *
+ * @param parent Required. The relative resource name of the location in which to create a
+ * metastore service, in the following form:
+ * `projects/{project_number}/locations/{location_id}`.
+ * @param service Required. The Metastore service to create. The `name` field is ignored. The ID
+ * of the created metastore service must be provided in the request's `service_id` field.
+ * @param serviceId Required. The ID of the metastore service, which is used as the final
+ * component of the metastore service's name.
+ *
This value must be between 2 and 63 characters long inclusive, begin with a letter, end
+ * with a letter or number, and consist of alpha-numeric ASCII characters or hyphens.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final OperationFuture createServiceAsync(
+ String parent, Service service, String serviceId) {
+ CreateServiceRequest request =
+ CreateServiceRequest.newBuilder()
+ .setParent(parent)
+ .setService(service)
+ .setServiceId(serviceId)
+ .build();
+ return createServiceAsync(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Creates a metastore service in a project and location.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * CreateServiceRequest request =
+ * CreateServiceRequest.newBuilder()
+ * .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
+ * .setServiceId("serviceId-194185552")
+ * .setService(Service.newBuilder().build())
+ * .setRequestId("requestId693933066")
+ * .build();
+ * Service response = dataprocMetastoreClient.createServiceAsync(request).get();
+ * }
+ * }
+ *
+ * @param request The request object containing all of the parameters for the API call.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final OperationFuture createServiceAsync(
+ CreateServiceRequest request) {
+ return createServiceOperationCallable().futureCall(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Creates a metastore service in a project and location.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * CreateServiceRequest request =
+ * CreateServiceRequest.newBuilder()
+ * .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
+ * .setServiceId("serviceId-194185552")
+ * .setService(Service.newBuilder().build())
+ * .setRequestId("requestId693933066")
+ * .build();
+ * OperationFuture future =
+ * dataprocMetastoreClient.createServiceOperationCallable().futureCall(request);
+ * // Do something.
+ * Service response = future.get();
+ * }
+ * }
+ */
+ public final OperationCallable
+ createServiceOperationCallable() {
+ return stub.createServiceOperationCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Creates a metastore service in a project and location.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * CreateServiceRequest request =
+ * CreateServiceRequest.newBuilder()
+ * .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
+ * .setServiceId("serviceId-194185552")
+ * .setService(Service.newBuilder().build())
+ * .setRequestId("requestId693933066")
+ * .build();
+ * ApiFuture future =
+ * dataprocMetastoreClient.createServiceCallable().futureCall(request);
+ * // Do something.
+ * Operation response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable createServiceCallable() {
+ return stub.createServiceCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Updates the parameters of a single service.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * Service service = Service.newBuilder().build();
+ * FieldMask updateMask = FieldMask.newBuilder().build();
+ * Service response = dataprocMetastoreClient.updateServiceAsync(service, updateMask).get();
+ * }
+ * }
+ *
+ * @param service Required. The metastore service to update. The server only merges fields in the
+ * service if they are specified in `update_mask`.
+ * The metastore service's `name` field is used to identify the metastore service to be
+ * updated.
+ * @param updateMask Required. A field mask used to specify the fields to be overwritten in the
+ * metastore service resource by the update. Fields specified in the `update_mask` are
+ * relative to the resource (not to the full request). A field is overwritten if it is in the
+ * mask.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final OperationFuture updateServiceAsync(
+ Service service, FieldMask updateMask) {
+ UpdateServiceRequest request =
+ UpdateServiceRequest.newBuilder().setService(service).setUpdateMask(updateMask).build();
+ return updateServiceAsync(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Updates the parameters of a single service.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * UpdateServiceRequest request =
+ * UpdateServiceRequest.newBuilder()
+ * .setUpdateMask(FieldMask.newBuilder().build())
+ * .setService(Service.newBuilder().build())
+ * .setRequestId("requestId693933066")
+ * .build();
+ * Service response = dataprocMetastoreClient.updateServiceAsync(request).get();
+ * }
+ * }
+ *
+ * @param request The request object containing all of the parameters for the API call.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final OperationFuture updateServiceAsync(
+ UpdateServiceRequest request) {
+ return updateServiceOperationCallable().futureCall(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Updates the parameters of a single service.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * UpdateServiceRequest request =
+ * UpdateServiceRequest.newBuilder()
+ * .setUpdateMask(FieldMask.newBuilder().build())
+ * .setService(Service.newBuilder().build())
+ * .setRequestId("requestId693933066")
+ * .build();
+ * OperationFuture future =
+ * dataprocMetastoreClient.updateServiceOperationCallable().futureCall(request);
+ * // Do something.
+ * Service response = future.get();
+ * }
+ * }
+ */
+ public final OperationCallable
+ updateServiceOperationCallable() {
+ return stub.updateServiceOperationCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Updates the parameters of a single service.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * UpdateServiceRequest request =
+ * UpdateServiceRequest.newBuilder()
+ * .setUpdateMask(FieldMask.newBuilder().build())
+ * .setService(Service.newBuilder().build())
+ * .setRequestId("requestId693933066")
+ * .build();
+ * ApiFuture future =
+ * dataprocMetastoreClient.updateServiceCallable().futureCall(request);
+ * // Do something.
+ * Operation response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable updateServiceCallable() {
+ return stub.updateServiceCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Deletes a single service.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * ServiceName name = ServiceName.of("[PROJECT]", "[LOCATION]", "[SERVICE]");
+ * dataprocMetastoreClient.deleteServiceAsync(name).get();
+ * }
+ * }
+ *
+ * @param name Required. The relative resource name of the metastore service to delete, in the
+ * following form:
+ * `projects/{project_number}/locations/{location_id}/services/{service_id}`.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final OperationFuture deleteServiceAsync(ServiceName name) {
+ DeleteServiceRequest request =
+ DeleteServiceRequest.newBuilder().setName(name == null ? null : name.toString()).build();
+ return deleteServiceAsync(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Deletes a single service.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * String name = ServiceName.of("[PROJECT]", "[LOCATION]", "[SERVICE]").toString();
+ * dataprocMetastoreClient.deleteServiceAsync(name).get();
+ * }
+ * }
+ *
+ * @param name Required. The relative resource name of the metastore service to delete, in the
+ * following form:
+ * `projects/{project_number}/locations/{location_id}/services/{service_id}`.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final OperationFuture deleteServiceAsync(String name) {
+ DeleteServiceRequest request = DeleteServiceRequest.newBuilder().setName(name).build();
+ return deleteServiceAsync(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Deletes a single service.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * DeleteServiceRequest request =
+ * DeleteServiceRequest.newBuilder()
+ * .setName(ServiceName.of("[PROJECT]", "[LOCATION]", "[SERVICE]").toString())
+ * .setRequestId("requestId693933066")
+ * .build();
+ * dataprocMetastoreClient.deleteServiceAsync(request).get();
+ * }
+ * }
+ *
+ * @param request The request object containing all of the parameters for the API call.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final OperationFuture deleteServiceAsync(
+ DeleteServiceRequest request) {
+ return deleteServiceOperationCallable().futureCall(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Deletes a single service.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * DeleteServiceRequest request =
+ * DeleteServiceRequest.newBuilder()
+ * .setName(ServiceName.of("[PROJECT]", "[LOCATION]", "[SERVICE]").toString())
+ * .setRequestId("requestId693933066")
+ * .build();
+ * OperationFuture future =
+ * dataprocMetastoreClient.deleteServiceOperationCallable().futureCall(request);
+ * // Do something.
+ * future.get();
+ * }
+ * }
+ */
+ public final OperationCallable
+ deleteServiceOperationCallable() {
+ return stub.deleteServiceOperationCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Deletes a single service.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * DeleteServiceRequest request =
+ * DeleteServiceRequest.newBuilder()
+ * .setName(ServiceName.of("[PROJECT]", "[LOCATION]", "[SERVICE]").toString())
+ * .setRequestId("requestId693933066")
+ * .build();
+ * ApiFuture future =
+ * dataprocMetastoreClient.deleteServiceCallable().futureCall(request);
+ * // Do something.
+ * future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable deleteServiceCallable() {
+ return stub.deleteServiceCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists imports in a service.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * ServiceName parent = ServiceName.of("[PROJECT]", "[LOCATION]", "[SERVICE]");
+ * for (MetadataImport element :
+ * dataprocMetastoreClient.listMetadataImports(parent).iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ * }
+ *
+ * @param parent Required. The relative resource name of the service whose metadata imports to
+ * list, in the following form:
+ * `projects/{project_number}/locations/{location_id}/services/{service_id}/metadataImports`.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final ListMetadataImportsPagedResponse listMetadataImports(ServiceName parent) {
+ ListMetadataImportsRequest request =
+ ListMetadataImportsRequest.newBuilder()
+ .setParent(parent == null ? null : parent.toString())
+ .build();
+ return listMetadataImports(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists imports in a service.
+ *
+ *
Sample code:
+ *
+ *
{@code
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * String parent = ServiceName.of("[PROJECT]", "[LOCATION]", "[SERVICE]").toString();
+ * for (MetadataImport element :
+ * dataprocMetastoreClient.listMetadataImports(parent).iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ * }
+ *
+ * @param parent Required. The relative resource name of the service whose metadata imports to
+ * list, in the following form:
+ * `projects/{project_number}/locations/{location_id}/services/{service_id}/metadataImports`.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final ListMetadataImportsPagedResponse listMetadataImports(String parent) {
+ ListMetadataImportsRequest request =
+ ListMetadataImportsRequest.newBuilder().setParent(parent).build();
+ return listMetadataImports(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists imports in a service.
+ *
+ *
Sample code:
+ *
+ *
{@code
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * ListMetadataImportsRequest request =
+ * ListMetadataImportsRequest.newBuilder()
+ * .setParent(ServiceName.of("[PROJECT]", "[LOCATION]", "[SERVICE]").toString())
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .setFilter("filter-1274492040")
+ * .setOrderBy("orderBy-1207110587")
+ * .build();
+ * for (MetadataImport element :
+ * dataprocMetastoreClient.listMetadataImports(request).iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ * }
+ *
+ * @param request The request object containing all of the parameters for the API call.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final ListMetadataImportsPagedResponse listMetadataImports(
+ ListMetadataImportsRequest request) {
+ return listMetadataImportsPagedCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists imports in a service.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * ListMetadataImportsRequest request =
+ * ListMetadataImportsRequest.newBuilder()
+ * .setParent(ServiceName.of("[PROJECT]", "[LOCATION]", "[SERVICE]").toString())
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .setFilter("filter-1274492040")
+ * .setOrderBy("orderBy-1207110587")
+ * .build();
+ * ApiFuture future =
+ * dataprocMetastoreClient.listMetadataImportsPagedCallable().futureCall(request);
+ * // Do something.
+ * for (MetadataImport element : future.get().iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ * }
+ */
+ public final UnaryCallable
+ listMetadataImportsPagedCallable() {
+ return stub.listMetadataImportsPagedCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists imports in a service.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * ListMetadataImportsRequest request =
+ * ListMetadataImportsRequest.newBuilder()
+ * .setParent(ServiceName.of("[PROJECT]", "[LOCATION]", "[SERVICE]").toString())
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .setFilter("filter-1274492040")
+ * .setOrderBy("orderBy-1207110587")
+ * .build();
+ * while (true) {
+ * ListMetadataImportsResponse response =
+ * dataprocMetastoreClient.listMetadataImportsCallable().call(request);
+ * for (MetadataImport element : response.getResponsesList()) {
+ * // doThingsWith(element);
+ * }
+ * String nextPageToken = response.getNextPageToken();
+ * if (!Strings.isNullOrEmpty(nextPageToken)) {
+ * request = request.toBuilder().setPageToken(nextPageToken).build();
+ * } else {
+ * break;
+ * }
+ * }
+ * }
+ * }
+ */
+ public final UnaryCallable
+ listMetadataImportsCallable() {
+ return stub.listMetadataImportsCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Gets details of a single import.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * MetadataImportName name =
+ * MetadataImportName.of("[PROJECT]", "[LOCATION]", "[SERVICE]", "[METADATA_IMPORT]");
+ * MetadataImport response = dataprocMetastoreClient.getMetadataImport(name);
+ * }
+ * }
+ *
+ * @param name Required. The relative resource name of the metadata import to retrieve, in the
+ * following form:
+ * `projects/{project_number}/locations/{location_id}/services/{service_id}/metadataImports/{import_id}`.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final MetadataImport getMetadataImport(MetadataImportName name) {
+ GetMetadataImportRequest request =
+ GetMetadataImportRequest.newBuilder()
+ .setName(name == null ? null : name.toString())
+ .build();
+ return getMetadataImport(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Gets details of a single import.
+ *
+ *
Sample code:
+ *
+ *
{@code
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * String name =
+ * MetadataImportName.of("[PROJECT]", "[LOCATION]", "[SERVICE]", "[METADATA_IMPORT]")
+ * .toString();
+ * MetadataImport response = dataprocMetastoreClient.getMetadataImport(name);
+ * }
+ * }
+ *
+ * @param name Required. The relative resource name of the metadata import to retrieve, in the
+ * following form:
+ * `projects/{project_number}/locations/{location_id}/services/{service_id}/metadataImports/{import_id}`.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final MetadataImport getMetadataImport(String name) {
+ GetMetadataImportRequest request = GetMetadataImportRequest.newBuilder().setName(name).build();
+ return getMetadataImport(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Gets details of a single import.
+ *
+ *
Sample code:
+ *
+ *
{@code
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * GetMetadataImportRequest request =
+ * GetMetadataImportRequest.newBuilder()
+ * .setName(
+ * MetadataImportName.of("[PROJECT]", "[LOCATION]", "[SERVICE]", "[METADATA_IMPORT]")
+ * .toString())
+ * .build();
+ * MetadataImport response = dataprocMetastoreClient.getMetadataImport(request);
+ * }
+ * }
+ *
+ * @param request The request object containing all of the parameters for the API call.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final MetadataImport getMetadataImport(GetMetadataImportRequest request) {
+ return getMetadataImportCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Gets details of a single import.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * GetMetadataImportRequest request =
+ * GetMetadataImportRequest.newBuilder()
+ * .setName(
+ * MetadataImportName.of("[PROJECT]", "[LOCATION]", "[SERVICE]", "[METADATA_IMPORT]")
+ * .toString())
+ * .build();
+ * ApiFuture future =
+ * dataprocMetastoreClient.getMetadataImportCallable().futureCall(request);
+ * // Do something.
+ * MetadataImport response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable getMetadataImportCallable() {
+ return stub.getMetadataImportCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Creates a new MetadataImport in a given project and location.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * ServiceName parent = ServiceName.of("[PROJECT]", "[LOCATION]", "[SERVICE]");
+ * MetadataImport metadataImport = MetadataImport.newBuilder().build();
+ * String metadataImportId = "metadataImportId1824548847";
+ * MetadataImport response =
+ * dataprocMetastoreClient
+ * .createMetadataImportAsync(parent, metadataImport, metadataImportId)
+ * .get();
+ * }
+ * }
+ *
+ * @param parent Required. The relative resource name of the service in which to create a
+ * metastore import, in the following form:
+ * `projects/{project_number}/locations/{location_id}/services/{service_id}`.
+ * @param metadataImport Required. The metadata import to create. The `name` field is ignored. The
+ * ID of the created metadata import must be provided in the request's `metadata_import_id`
+ * field.
+ * @param metadataImportId Required. The ID of the metadata import, which is used as the final
+ * component of the metadata import's name.
+ *
This value must be between 1 and 64 characters long, begin with a letter, end with a
+ * letter or number, and consist of alpha-numeric ASCII characters or hyphens.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final OperationFuture createMetadataImportAsync(
+ ServiceName parent, MetadataImport metadataImport, String metadataImportId) {
+ CreateMetadataImportRequest request =
+ CreateMetadataImportRequest.newBuilder()
+ .setParent(parent == null ? null : parent.toString())
+ .setMetadataImport(metadataImport)
+ .setMetadataImportId(metadataImportId)
+ .build();
+ return createMetadataImportAsync(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Creates a new MetadataImport in a given project and location.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * String parent = ServiceName.of("[PROJECT]", "[LOCATION]", "[SERVICE]").toString();
+ * MetadataImport metadataImport = MetadataImport.newBuilder().build();
+ * String metadataImportId = "metadataImportId1824548847";
+ * MetadataImport response =
+ * dataprocMetastoreClient
+ * .createMetadataImportAsync(parent, metadataImport, metadataImportId)
+ * .get();
+ * }
+ * }
+ *
+ * @param parent Required. The relative resource name of the service in which to create a
+ * metastore import, in the following form:
+ * `projects/{project_number}/locations/{location_id}/services/{service_id}`.
+ * @param metadataImport Required. The metadata import to create. The `name` field is ignored. The
+ * ID of the created metadata import must be provided in the request's `metadata_import_id`
+ * field.
+ * @param metadataImportId Required. The ID of the metadata import, which is used as the final
+ * component of the metadata import's name.
+ *
This value must be between 1 and 64 characters long, begin with a letter, end with a
+ * letter or number, and consist of alpha-numeric ASCII characters or hyphens.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final OperationFuture createMetadataImportAsync(
+ String parent, MetadataImport metadataImport, String metadataImportId) {
+ CreateMetadataImportRequest request =
+ CreateMetadataImportRequest.newBuilder()
+ .setParent(parent)
+ .setMetadataImport(metadataImport)
+ .setMetadataImportId(metadataImportId)
+ .build();
+ return createMetadataImportAsync(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Creates a new MetadataImport in a given project and location.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * CreateMetadataImportRequest request =
+ * CreateMetadataImportRequest.newBuilder()
+ * .setParent(ServiceName.of("[PROJECT]", "[LOCATION]", "[SERVICE]").toString())
+ * .setMetadataImportId("metadataImportId1824548847")
+ * .setMetadataImport(MetadataImport.newBuilder().build())
+ * .setRequestId("requestId693933066")
+ * .build();
+ * MetadataImport response = dataprocMetastoreClient.createMetadataImportAsync(request).get();
+ * }
+ * }
+ *
+ * @param request The request object containing all of the parameters for the API call.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final OperationFuture createMetadataImportAsync(
+ CreateMetadataImportRequest request) {
+ return createMetadataImportOperationCallable().futureCall(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Creates a new MetadataImport in a given project and location.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * CreateMetadataImportRequest request =
+ * CreateMetadataImportRequest.newBuilder()
+ * .setParent(ServiceName.of("[PROJECT]", "[LOCATION]", "[SERVICE]").toString())
+ * .setMetadataImportId("metadataImportId1824548847")
+ * .setMetadataImport(MetadataImport.newBuilder().build())
+ * .setRequestId("requestId693933066")
+ * .build();
+ * OperationFuture future =
+ * dataprocMetastoreClient.createMetadataImportOperationCallable().futureCall(request);
+ * // Do something.
+ * MetadataImport response = future.get();
+ * }
+ * }
+ */
+ public final OperationCallable
+ createMetadataImportOperationCallable() {
+ return stub.createMetadataImportOperationCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Creates a new MetadataImport in a given project and location.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * CreateMetadataImportRequest request =
+ * CreateMetadataImportRequest.newBuilder()
+ * .setParent(ServiceName.of("[PROJECT]", "[LOCATION]", "[SERVICE]").toString())
+ * .setMetadataImportId("metadataImportId1824548847")
+ * .setMetadataImport(MetadataImport.newBuilder().build())
+ * .setRequestId("requestId693933066")
+ * .build();
+ * ApiFuture future =
+ * dataprocMetastoreClient.createMetadataImportCallable().futureCall(request);
+ * // Do something.
+ * Operation response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable
+ createMetadataImportCallable() {
+ return stub.createMetadataImportCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Updates a single import. Only the description field of MetadataImport is supported to be
+ * updated.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * MetadataImport metadataImport = MetadataImport.newBuilder().build();
+ * FieldMask updateMask = FieldMask.newBuilder().build();
+ * MetadataImport response =
+ * dataprocMetastoreClient.updateMetadataImportAsync(metadataImport, updateMask).get();
+ * }
+ * }
+ *
+ * @param metadataImport Required. The metadata import to update. The server only merges fields in
+ * the import if they are specified in `update_mask`.
+ * The metadata import's `name` field is used to identify the metastore import to be
+ * updated.
+ * @param updateMask Required. A field mask used to specify the fields to be overwritten in the
+ * metadata import resource by the update. Fields specified in the `update_mask` are relative
+ * to the resource (not to the full request). A field is overwritten if it is in the mask.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final OperationFuture updateMetadataImportAsync(
+ MetadataImport metadataImport, FieldMask updateMask) {
+ UpdateMetadataImportRequest request =
+ UpdateMetadataImportRequest.newBuilder()
+ .setMetadataImport(metadataImport)
+ .setUpdateMask(updateMask)
+ .build();
+ return updateMetadataImportAsync(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Updates a single import. Only the description field of MetadataImport is supported to be
+ * updated.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * UpdateMetadataImportRequest request =
+ * UpdateMetadataImportRequest.newBuilder()
+ * .setUpdateMask(FieldMask.newBuilder().build())
+ * .setMetadataImport(MetadataImport.newBuilder().build())
+ * .setRequestId("requestId693933066")
+ * .build();
+ * MetadataImport response = dataprocMetastoreClient.updateMetadataImportAsync(request).get();
+ * }
+ * }
+ *
+ * @param request The request object containing all of the parameters for the API call.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final OperationFuture updateMetadataImportAsync(
+ UpdateMetadataImportRequest request) {
+ return updateMetadataImportOperationCallable().futureCall(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Updates a single import. Only the description field of MetadataImport is supported to be
+ * updated.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * UpdateMetadataImportRequest request =
+ * UpdateMetadataImportRequest.newBuilder()
+ * .setUpdateMask(FieldMask.newBuilder().build())
+ * .setMetadataImport(MetadataImport.newBuilder().build())
+ * .setRequestId("requestId693933066")
+ * .build();
+ * OperationFuture future =
+ * dataprocMetastoreClient.updateMetadataImportOperationCallable().futureCall(request);
+ * // Do something.
+ * MetadataImport response = future.get();
+ * }
+ * }
+ */
+ public final OperationCallable
+ updateMetadataImportOperationCallable() {
+ return stub.updateMetadataImportOperationCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Updates a single import. Only the description field of MetadataImport is supported to be
+ * updated.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * UpdateMetadataImportRequest request =
+ * UpdateMetadataImportRequest.newBuilder()
+ * .setUpdateMask(FieldMask.newBuilder().build())
+ * .setMetadataImport(MetadataImport.newBuilder().build())
+ * .setRequestId("requestId693933066")
+ * .build();
+ * ApiFuture future =
+ * dataprocMetastoreClient.updateMetadataImportCallable().futureCall(request);
+ * // Do something.
+ * Operation response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable
+ updateMetadataImportCallable() {
+ return stub.updateMetadataImportCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Exports metadata from a service.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * ExportMetadataRequest request =
+ * ExportMetadataRequest.newBuilder()
+ * .setService(ServiceName.of("[PROJECT]", "[LOCATION]", "[SERVICE]").toString())
+ * .setRequestId("requestId693933066")
+ * .build();
+ * MetadataExport response = dataprocMetastoreClient.exportMetadataAsync(request).get();
+ * }
+ * }
+ *
+ * @param request The request object containing all of the parameters for the API call.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final OperationFuture exportMetadataAsync(
+ ExportMetadataRequest request) {
+ return exportMetadataOperationCallable().futureCall(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Exports metadata from a service.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * ExportMetadataRequest request =
+ * ExportMetadataRequest.newBuilder()
+ * .setService(ServiceName.of("[PROJECT]", "[LOCATION]", "[SERVICE]").toString())
+ * .setRequestId("requestId693933066")
+ * .build();
+ * OperationFuture future =
+ * dataprocMetastoreClient.exportMetadataOperationCallable().futureCall(request);
+ * // Do something.
+ * MetadataExport response = future.get();
+ * }
+ * }
+ */
+ public final OperationCallable
+ exportMetadataOperationCallable() {
+ return stub.exportMetadataOperationCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Exports metadata from a service.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * ExportMetadataRequest request =
+ * ExportMetadataRequest.newBuilder()
+ * .setService(ServiceName.of("[PROJECT]", "[LOCATION]", "[SERVICE]").toString())
+ * .setRequestId("requestId693933066")
+ * .build();
+ * ApiFuture future =
+ * dataprocMetastoreClient.exportMetadataCallable().futureCall(request);
+ * // Do something.
+ * Operation response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable exportMetadataCallable() {
+ return stub.exportMetadataCallable();
+ }
+
+ @Override
+ public final void close() {
+ stub.close();
+ }
+
+ @Override
+ public void shutdown() {
+ stub.shutdown();
+ }
+
+ @Override
+ public boolean isShutdown() {
+ return stub.isShutdown();
+ }
+
+ @Override
+ public boolean isTerminated() {
+ return stub.isTerminated();
+ }
+
+ @Override
+ public void shutdownNow() {
+ stub.shutdownNow();
+ }
+
+ @Override
+ public boolean awaitTermination(long duration, TimeUnit unit) throws InterruptedException {
+ return stub.awaitTermination(duration, unit);
+ }
+
+ public static class ListServicesPagedResponse
+ extends AbstractPagedListResponse<
+ ListServicesRequest,
+ ListServicesResponse,
+ Service,
+ ListServicesPage,
+ ListServicesFixedSizeCollection> {
+
+ public static ApiFuture createAsync(
+ PageContext context,
+ ApiFuture futureResponse) {
+ ApiFuture futurePage =
+ ListServicesPage.createEmptyPage().createPageAsync(context, futureResponse);
+ return ApiFutures.transform(
+ futurePage,
+ new ApiFunction() {
+ @Override
+ public ListServicesPagedResponse apply(ListServicesPage input) {
+ return new ListServicesPagedResponse(input);
+ }
+ },
+ MoreExecutors.directExecutor());
+ }
+
+ private ListServicesPagedResponse(ListServicesPage page) {
+ super(page, ListServicesFixedSizeCollection.createEmptyCollection());
+ }
+ }
+
+ public static class ListServicesPage
+ extends AbstractPage {
+
+ private ListServicesPage(
+ PageContext context,
+ ListServicesResponse response) {
+ super(context, response);
+ }
+
+ private static ListServicesPage createEmptyPage() {
+ return new ListServicesPage(null, null);
+ }
+
+ @Override
+ protected ListServicesPage createPage(
+ PageContext context,
+ ListServicesResponse response) {
+ return new ListServicesPage(context, response);
+ }
+
+ @Override
+ public ApiFuture createPageAsync(
+ PageContext context,
+ ApiFuture futureResponse) {
+ return super.createPageAsync(context, futureResponse);
+ }
+ }
+
+ public static class ListServicesFixedSizeCollection
+ extends AbstractFixedSizeCollection<
+ ListServicesRequest,
+ ListServicesResponse,
+ Service,
+ ListServicesPage,
+ ListServicesFixedSizeCollection> {
+
+ private ListServicesFixedSizeCollection(List pages, int collectionSize) {
+ super(pages, collectionSize);
+ }
+
+ private static ListServicesFixedSizeCollection createEmptyCollection() {
+ return new ListServicesFixedSizeCollection(null, 0);
+ }
+
+ @Override
+ protected ListServicesFixedSizeCollection createCollection(
+ List pages, int collectionSize) {
+ return new ListServicesFixedSizeCollection(pages, collectionSize);
+ }
+ }
+
+ public static class ListMetadataImportsPagedResponse
+ extends AbstractPagedListResponse<
+ ListMetadataImportsRequest,
+ ListMetadataImportsResponse,
+ MetadataImport,
+ ListMetadataImportsPage,
+ ListMetadataImportsFixedSizeCollection> {
+
+ public static ApiFuture createAsync(
+ PageContext
+ context,
+ ApiFuture futureResponse) {
+ ApiFuture futurePage =
+ ListMetadataImportsPage.createEmptyPage().createPageAsync(context, futureResponse);
+ return ApiFutures.transform(
+ futurePage,
+ new ApiFunction() {
+ @Override
+ public ListMetadataImportsPagedResponse apply(ListMetadataImportsPage input) {
+ return new ListMetadataImportsPagedResponse(input);
+ }
+ },
+ MoreExecutors.directExecutor());
+ }
+
+ private ListMetadataImportsPagedResponse(ListMetadataImportsPage page) {
+ super(page, ListMetadataImportsFixedSizeCollection.createEmptyCollection());
+ }
+ }
+
+ public static class ListMetadataImportsPage
+ extends AbstractPage<
+ ListMetadataImportsRequest,
+ ListMetadataImportsResponse,
+ MetadataImport,
+ ListMetadataImportsPage> {
+
+ private ListMetadataImportsPage(
+ PageContext
+ context,
+ ListMetadataImportsResponse response) {
+ super(context, response);
+ }
+
+ private static ListMetadataImportsPage createEmptyPage() {
+ return new ListMetadataImportsPage(null, null);
+ }
+
+ @Override
+ protected ListMetadataImportsPage createPage(
+ PageContext
+ context,
+ ListMetadataImportsResponse response) {
+ return new ListMetadataImportsPage(context, response);
+ }
+
+ @Override
+ public ApiFuture createPageAsync(
+ PageContext
+ context,
+ ApiFuture futureResponse) {
+ return super.createPageAsync(context, futureResponse);
+ }
+ }
+
+ public static class ListMetadataImportsFixedSizeCollection
+ extends AbstractFixedSizeCollection<
+ ListMetadataImportsRequest,
+ ListMetadataImportsResponse,
+ MetadataImport,
+ ListMetadataImportsPage,
+ ListMetadataImportsFixedSizeCollection> {
+
+ private ListMetadataImportsFixedSizeCollection(
+ List pages, int collectionSize) {
+ super(pages, collectionSize);
+ }
+
+ private static ListMetadataImportsFixedSizeCollection createEmptyCollection() {
+ return new ListMetadataImportsFixedSizeCollection(null, 0);
+ }
+
+ @Override
+ protected ListMetadataImportsFixedSizeCollection createCollection(
+ List pages, int collectionSize) {
+ return new ListMetadataImportsFixedSizeCollection(pages, collectionSize);
+ }
+ }
+}
diff --git a/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1/DataprocMetastoreSettings.java b/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1/DataprocMetastoreSettings.java
new file mode 100644
index 00000000..fdd959e0
--- /dev/null
+++ b/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1/DataprocMetastoreSettings.java
@@ -0,0 +1,367 @@
+/*
+ * Copyright 2021 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.google.cloud.metastore.v1;
+
+import static com.google.cloud.metastore.v1.DataprocMetastoreClient.ListMetadataImportsPagedResponse;
+import static com.google.cloud.metastore.v1.DataprocMetastoreClient.ListServicesPagedResponse;
+
+import com.google.api.core.ApiFunction;
+import com.google.api.core.BetaApi;
+import com.google.api.gax.core.GoogleCredentialsProvider;
+import com.google.api.gax.core.InstantiatingExecutorProvider;
+import com.google.api.gax.grpc.InstantiatingGrpcChannelProvider;
+import com.google.api.gax.rpc.ApiClientHeaderProvider;
+import com.google.api.gax.rpc.ClientContext;
+import com.google.api.gax.rpc.ClientSettings;
+import com.google.api.gax.rpc.OperationCallSettings;
+import com.google.api.gax.rpc.PagedCallSettings;
+import com.google.api.gax.rpc.TransportChannelProvider;
+import com.google.api.gax.rpc.UnaryCallSettings;
+import com.google.cloud.metastore.v1.stub.DataprocMetastoreStubSettings;
+import com.google.longrunning.Operation;
+import com.google.protobuf.Empty;
+import java.io.IOException;
+import java.util.List;
+import javax.annotation.Generated;
+
+// AUTO-GENERATED DOCUMENTATION AND CLASS.
+/**
+ * Settings class to configure an instance of {@link DataprocMetastoreClient}.
+ *
+ * The default instance has everything set to sensible defaults:
+ *
+ *
+ * - The default service address (metastore.googleapis.com) and default port (443) are used.
+ *
- Credentials are acquired automatically through Application Default Credentials.
+ *
- Retries are configured for idempotent methods but not for non-idempotent methods.
+ *
+ *
+ * The builder of this class is recursive, so contained classes are themselves builders. When
+ * build() is called, the tree of builders is called to create the complete settings object.
+ *
+ *
For example, to set the total timeout of getService to 30 seconds:
+ *
+ *
{@code
+ * DataprocMetastoreSettings.Builder dataprocMetastoreSettingsBuilder =
+ * DataprocMetastoreSettings.newBuilder();
+ * dataprocMetastoreSettingsBuilder
+ * .getServiceSettings()
+ * .setRetrySettings(
+ * dataprocMetastoreSettingsBuilder
+ * .getServiceSettings()
+ * .getRetrySettings()
+ * .toBuilder()
+ * .setTotalTimeout(Duration.ofSeconds(30))
+ * .build());
+ * DataprocMetastoreSettings dataprocMetastoreSettings = dataprocMetastoreSettingsBuilder.build();
+ * }
+ */
+@Generated("by gapic-generator-java")
+public class DataprocMetastoreSettings extends ClientSettings {
+
+ /** Returns the object with the settings used for calls to listServices. */
+ public PagedCallSettings
+ listServicesSettings() {
+ return ((DataprocMetastoreStubSettings) getStubSettings()).listServicesSettings();
+ }
+
+ /** Returns the object with the settings used for calls to getService. */
+ public UnaryCallSettings getServiceSettings() {
+ return ((DataprocMetastoreStubSettings) getStubSettings()).getServiceSettings();
+ }
+
+ /** Returns the object with the settings used for calls to createService. */
+ public UnaryCallSettings createServiceSettings() {
+ return ((DataprocMetastoreStubSettings) getStubSettings()).createServiceSettings();
+ }
+
+ /** Returns the object with the settings used for calls to createService. */
+ public OperationCallSettings
+ createServiceOperationSettings() {
+ return ((DataprocMetastoreStubSettings) getStubSettings()).createServiceOperationSettings();
+ }
+
+ /** Returns the object with the settings used for calls to updateService. */
+ public UnaryCallSettings updateServiceSettings() {
+ return ((DataprocMetastoreStubSettings) getStubSettings()).updateServiceSettings();
+ }
+
+ /** Returns the object with the settings used for calls to updateService. */
+ public OperationCallSettings
+ updateServiceOperationSettings() {
+ return ((DataprocMetastoreStubSettings) getStubSettings()).updateServiceOperationSettings();
+ }
+
+ /** Returns the object with the settings used for calls to deleteService. */
+ public UnaryCallSettings deleteServiceSettings() {
+ return ((DataprocMetastoreStubSettings) getStubSettings()).deleteServiceSettings();
+ }
+
+ /** Returns the object with the settings used for calls to deleteService. */
+ public OperationCallSettings
+ deleteServiceOperationSettings() {
+ return ((DataprocMetastoreStubSettings) getStubSettings()).deleteServiceOperationSettings();
+ }
+
+ /** Returns the object with the settings used for calls to listMetadataImports. */
+ public PagedCallSettings<
+ ListMetadataImportsRequest, ListMetadataImportsResponse, ListMetadataImportsPagedResponse>
+ listMetadataImportsSettings() {
+ return ((DataprocMetastoreStubSettings) getStubSettings()).listMetadataImportsSettings();
+ }
+
+ /** Returns the object with the settings used for calls to getMetadataImport. */
+ public UnaryCallSettings getMetadataImportSettings() {
+ return ((DataprocMetastoreStubSettings) getStubSettings()).getMetadataImportSettings();
+ }
+
+ /** Returns the object with the settings used for calls to createMetadataImport. */
+ public UnaryCallSettings createMetadataImportSettings() {
+ return ((DataprocMetastoreStubSettings) getStubSettings()).createMetadataImportSettings();
+ }
+
+ /** Returns the object with the settings used for calls to createMetadataImport. */
+ public OperationCallSettings
+ createMetadataImportOperationSettings() {
+ return ((DataprocMetastoreStubSettings) getStubSettings())
+ .createMetadataImportOperationSettings();
+ }
+
+ /** Returns the object with the settings used for calls to updateMetadataImport. */
+ public UnaryCallSettings updateMetadataImportSettings() {
+ return ((DataprocMetastoreStubSettings) getStubSettings()).updateMetadataImportSettings();
+ }
+
+ /** Returns the object with the settings used for calls to updateMetadataImport. */
+ public OperationCallSettings
+ updateMetadataImportOperationSettings() {
+ return ((DataprocMetastoreStubSettings) getStubSettings())
+ .updateMetadataImportOperationSettings();
+ }
+
+ /** Returns the object with the settings used for calls to exportMetadata. */
+ public UnaryCallSettings exportMetadataSettings() {
+ return ((DataprocMetastoreStubSettings) getStubSettings()).exportMetadataSettings();
+ }
+
+ /** Returns the object with the settings used for calls to exportMetadata. */
+ public OperationCallSettings
+ exportMetadataOperationSettings() {
+ return ((DataprocMetastoreStubSettings) getStubSettings()).exportMetadataOperationSettings();
+ }
+
+ public static final DataprocMetastoreSettings create(DataprocMetastoreStubSettings stub)
+ throws IOException {
+ return new DataprocMetastoreSettings.Builder(stub.toBuilder()).build();
+ }
+
+ /** Returns a builder for the default ExecutorProvider for this service. */
+ public static InstantiatingExecutorProvider.Builder defaultExecutorProviderBuilder() {
+ return DataprocMetastoreStubSettings.defaultExecutorProviderBuilder();
+ }
+
+ /** Returns the default service endpoint. */
+ public static String getDefaultEndpoint() {
+ return DataprocMetastoreStubSettings.getDefaultEndpoint();
+ }
+
+ /** Returns the default service scopes. */
+ public static List getDefaultServiceScopes() {
+ return DataprocMetastoreStubSettings.getDefaultServiceScopes();
+ }
+
+ /** Returns a builder for the default credentials for this service. */
+ public static GoogleCredentialsProvider.Builder defaultCredentialsProviderBuilder() {
+ return DataprocMetastoreStubSettings.defaultCredentialsProviderBuilder();
+ }
+
+ /** Returns a builder for the default ChannelProvider for this service. */
+ public static InstantiatingGrpcChannelProvider.Builder defaultGrpcTransportProviderBuilder() {
+ return DataprocMetastoreStubSettings.defaultGrpcTransportProviderBuilder();
+ }
+
+ public static TransportChannelProvider defaultTransportChannelProvider() {
+ return DataprocMetastoreStubSettings.defaultTransportChannelProvider();
+ }
+
+ @BetaApi("The surface for customizing headers is not stable yet and may change in the future.")
+ public static ApiClientHeaderProvider.Builder defaultApiClientHeaderProviderBuilder() {
+ return DataprocMetastoreStubSettings.defaultApiClientHeaderProviderBuilder();
+ }
+
+ /** Returns a new builder for this class. */
+ public static Builder newBuilder() {
+ return Builder.createDefault();
+ }
+
+ /** Returns a new builder for this class. */
+ public static Builder newBuilder(ClientContext clientContext) {
+ return new Builder(clientContext);
+ }
+
+ /** Returns a builder containing all the values of this settings class. */
+ public Builder toBuilder() {
+ return new Builder(this);
+ }
+
+ protected DataprocMetastoreSettings(Builder settingsBuilder) throws IOException {
+ super(settingsBuilder);
+ }
+
+ /** Builder for DataprocMetastoreSettings. */
+ public static class Builder extends ClientSettings.Builder {
+
+ protected Builder() throws IOException {
+ this(((ClientContext) null));
+ }
+
+ protected Builder(ClientContext clientContext) {
+ super(DataprocMetastoreStubSettings.newBuilder(clientContext));
+ }
+
+ protected Builder(DataprocMetastoreSettings settings) {
+ super(settings.getStubSettings().toBuilder());
+ }
+
+ protected Builder(DataprocMetastoreStubSettings.Builder stubSettings) {
+ super(stubSettings);
+ }
+
+ private static Builder createDefault() {
+ return new Builder(DataprocMetastoreStubSettings.newBuilder());
+ }
+
+ public DataprocMetastoreStubSettings.Builder getStubSettingsBuilder() {
+ return ((DataprocMetastoreStubSettings.Builder) getStubSettings());
+ }
+
+ // NEXT_MAJOR_VER: remove 'throws Exception'.
+ /**
+ * Applies the given settings updater function to all of the unary API methods in this service.
+ *
+ * Note: This method does not support applying settings to streaming methods.
+ */
+ public Builder applyToAllUnaryMethods(
+ ApiFunction, Void> settingsUpdater) throws Exception {
+ super.applyToAllUnaryMethods(
+ getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater);
+ return this;
+ }
+
+ /** Returns the builder for the settings used for calls to listServices. */
+ public PagedCallSettings.Builder<
+ ListServicesRequest, ListServicesResponse, ListServicesPagedResponse>
+ listServicesSettings() {
+ return getStubSettingsBuilder().listServicesSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to getService. */
+ public UnaryCallSettings.Builder getServiceSettings() {
+ return getStubSettingsBuilder().getServiceSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to createService. */
+ public UnaryCallSettings.Builder createServiceSettings() {
+ return getStubSettingsBuilder().createServiceSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to createService. */
+ public OperationCallSettings.Builder
+ createServiceOperationSettings() {
+ return getStubSettingsBuilder().createServiceOperationSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to updateService. */
+ public UnaryCallSettings.Builder updateServiceSettings() {
+ return getStubSettingsBuilder().updateServiceSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to updateService. */
+ public OperationCallSettings.Builder
+ updateServiceOperationSettings() {
+ return getStubSettingsBuilder().updateServiceOperationSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to deleteService. */
+ public UnaryCallSettings.Builder deleteServiceSettings() {
+ return getStubSettingsBuilder().deleteServiceSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to deleteService. */
+ public OperationCallSettings.Builder
+ deleteServiceOperationSettings() {
+ return getStubSettingsBuilder().deleteServiceOperationSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to listMetadataImports. */
+ public PagedCallSettings.Builder<
+ ListMetadataImportsRequest,
+ ListMetadataImportsResponse,
+ ListMetadataImportsPagedResponse>
+ listMetadataImportsSettings() {
+ return getStubSettingsBuilder().listMetadataImportsSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to getMetadataImport. */
+ public UnaryCallSettings.Builder
+ getMetadataImportSettings() {
+ return getStubSettingsBuilder().getMetadataImportSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to createMetadataImport. */
+ public UnaryCallSettings.Builder
+ createMetadataImportSettings() {
+ return getStubSettingsBuilder().createMetadataImportSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to createMetadataImport. */
+ public OperationCallSettings.Builder<
+ CreateMetadataImportRequest, MetadataImport, OperationMetadata>
+ createMetadataImportOperationSettings() {
+ return getStubSettingsBuilder().createMetadataImportOperationSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to updateMetadataImport. */
+ public UnaryCallSettings.Builder
+ updateMetadataImportSettings() {
+ return getStubSettingsBuilder().updateMetadataImportSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to updateMetadataImport. */
+ public OperationCallSettings.Builder<
+ UpdateMetadataImportRequest, MetadataImport, OperationMetadata>
+ updateMetadataImportOperationSettings() {
+ return getStubSettingsBuilder().updateMetadataImportOperationSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to exportMetadata. */
+ public UnaryCallSettings.Builder exportMetadataSettings() {
+ return getStubSettingsBuilder().exportMetadataSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to exportMetadata. */
+ public OperationCallSettings.Builder
+ exportMetadataOperationSettings() {
+ return getStubSettingsBuilder().exportMetadataOperationSettings();
+ }
+
+ @Override
+ public DataprocMetastoreSettings build() throws IOException {
+ return new DataprocMetastoreSettings(this);
+ }
+ }
+}
diff --git a/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1/gapic_metadata.json b/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1/gapic_metadata.json
new file mode 100644
index 00000000..05c63e5a
--- /dev/null
+++ b/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1/gapic_metadata.json
@@ -0,0 +1,48 @@
+{
+ "schema": "1.0",
+ "comment": "This file maps proto services/RPCs to the corresponding library clients/methods",
+ "language": "java",
+ "protoPackage": "google.cloud.metastore.v1",
+ "libraryPackage": "com.google.cloud.metastore.v1",
+ "services": {
+ "DataprocMetastore": {
+ "clients": {
+ "grpc": {
+ "libraryClient": "DataprocMetastoreClient",
+ "rpcs": {
+ "CreateMetadataImport": {
+ "methods": ["createMetadataImportAsync", "createMetadataImportAsync", "createMetadataImportAsync", "createMetadataImportOperationCallable", "createMetadataImportCallable"]
+ },
+ "CreateService": {
+ "methods": ["createServiceAsync", "createServiceAsync", "createServiceAsync", "createServiceOperationCallable", "createServiceCallable"]
+ },
+ "DeleteService": {
+ "methods": ["deleteServiceAsync", "deleteServiceAsync", "deleteServiceAsync", "deleteServiceOperationCallable", "deleteServiceCallable"]
+ },
+ "ExportMetadata": {
+ "methods": ["exportMetadataAsync", "exportMetadataOperationCallable", "exportMetadataCallable"]
+ },
+ "GetMetadataImport": {
+ "methods": ["getMetadataImport", "getMetadataImport", "getMetadataImport", "getMetadataImportCallable"]
+ },
+ "GetService": {
+ "methods": ["getService", "getService", "getService", "getServiceCallable"]
+ },
+ "ListMetadataImports": {
+ "methods": ["listMetadataImports", "listMetadataImports", "listMetadataImports", "listMetadataImportsPagedCallable", "listMetadataImportsCallable"]
+ },
+ "ListServices": {
+ "methods": ["listServices", "listServices", "listServices", "listServicesPagedCallable", "listServicesCallable"]
+ },
+ "UpdateMetadataImport": {
+ "methods": ["updateMetadataImportAsync", "updateMetadataImportAsync", "updateMetadataImportOperationCallable", "updateMetadataImportCallable"]
+ },
+ "UpdateService": {
+ "methods": ["updateServiceAsync", "updateServiceAsync", "updateServiceOperationCallable", "updateServiceCallable"]
+ }
+ }
+ }
+ }
+ }
+ }
+}
\ No newline at end of file
diff --git a/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1/package-info.java b/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1/package-info.java
new file mode 100644
index 00000000..a24a32bd
--- /dev/null
+++ b/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1/package-info.java
@@ -0,0 +1,52 @@
+/*
+ * Copyright 2021 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+/**
+ * The interfaces provided are listed below, along with usage samples.
+ *
+ * ======================= DataprocMetastoreClient =======================
+ *
+ *
Service Description: Configures and manages metastore services. Metastore services are fully
+ * managed, highly available, auto-scaled, auto-healing, OSS-native deployments of technical
+ * metadata management software. Each metastore service exposes a network endpoint through which
+ * metadata queries are served. Metadata queries can originate from a variety of sources, including
+ * Apache Hive, Apache Presto, and Apache Spark.
+ *
+ *
The Dataproc Metastore API defines the following resource model:
+ *
+ *
+ * - The service works with a collection of Google Cloud projects, named: `/projects/*`
+ *
- Each project has a collection of available locations, named: `/locations/*` (a location
+ * must refer to a Google Cloud `region`)
+ *
- Each location has a collection of services, named: `/services/*`
+ *
- Dataproc Metastore services are resources with names of the form:
+ *
+ *
+ * `/projects/{project_number}/locations/{location_id}/services/{service_id}`.
+ *
+ *
Sample for DataprocMetastoreClient:
+ *
+ *
{@code
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * ServiceName name = ServiceName.of("[PROJECT]", "[LOCATION]", "[SERVICE]");
+ * Service response = dataprocMetastoreClient.getService(name);
+ * }
+ * }
+ */
+@Generated("by gapic-generator-java")
+package com.google.cloud.metastore.v1;
+
+import javax.annotation.Generated;
diff --git a/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1/stub/DataprocMetastoreStub.java b/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1/stub/DataprocMetastoreStub.java
new file mode 100644
index 00000000..b5b06b77
--- /dev/null
+++ b/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1/stub/DataprocMetastoreStub.java
@@ -0,0 +1,143 @@
+/*
+ * Copyright 2021 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.google.cloud.metastore.v1.stub;
+
+import static com.google.cloud.metastore.v1.DataprocMetastoreClient.ListMetadataImportsPagedResponse;
+import static com.google.cloud.metastore.v1.DataprocMetastoreClient.ListServicesPagedResponse;
+
+import com.google.api.gax.core.BackgroundResource;
+import com.google.api.gax.rpc.OperationCallable;
+import com.google.api.gax.rpc.UnaryCallable;
+import com.google.cloud.metastore.v1.CreateMetadataImportRequest;
+import com.google.cloud.metastore.v1.CreateServiceRequest;
+import com.google.cloud.metastore.v1.DeleteServiceRequest;
+import com.google.cloud.metastore.v1.ExportMetadataRequest;
+import com.google.cloud.metastore.v1.GetMetadataImportRequest;
+import com.google.cloud.metastore.v1.GetServiceRequest;
+import com.google.cloud.metastore.v1.ListMetadataImportsRequest;
+import com.google.cloud.metastore.v1.ListMetadataImportsResponse;
+import com.google.cloud.metastore.v1.ListServicesRequest;
+import com.google.cloud.metastore.v1.ListServicesResponse;
+import com.google.cloud.metastore.v1.MetadataExport;
+import com.google.cloud.metastore.v1.MetadataImport;
+import com.google.cloud.metastore.v1.OperationMetadata;
+import com.google.cloud.metastore.v1.Service;
+import com.google.cloud.metastore.v1.UpdateMetadataImportRequest;
+import com.google.cloud.metastore.v1.UpdateServiceRequest;
+import com.google.longrunning.Operation;
+import com.google.longrunning.stub.OperationsStub;
+import com.google.protobuf.Empty;
+import javax.annotation.Generated;
+
+// AUTO-GENERATED DOCUMENTATION AND CLASS.
+/**
+ * Base stub class for the DataprocMetastore service API.
+ *
+ * This class is for advanced usage and reflects the underlying API directly.
+ */
+@Generated("by gapic-generator-java")
+public abstract class DataprocMetastoreStub implements BackgroundResource {
+
+ public OperationsStub getOperationsStub() {
+ throw new UnsupportedOperationException("Not implemented: getOperationsStub()");
+ }
+
+ public UnaryCallable listServicesPagedCallable() {
+ throw new UnsupportedOperationException("Not implemented: listServicesPagedCallable()");
+ }
+
+ public UnaryCallable listServicesCallable() {
+ throw new UnsupportedOperationException("Not implemented: listServicesCallable()");
+ }
+
+ public UnaryCallable getServiceCallable() {
+ throw new UnsupportedOperationException("Not implemented: getServiceCallable()");
+ }
+
+ public OperationCallable
+ createServiceOperationCallable() {
+ throw new UnsupportedOperationException("Not implemented: createServiceOperationCallable()");
+ }
+
+ public UnaryCallable createServiceCallable() {
+ throw new UnsupportedOperationException("Not implemented: createServiceCallable()");
+ }
+
+ public OperationCallable
+ updateServiceOperationCallable() {
+ throw new UnsupportedOperationException("Not implemented: updateServiceOperationCallable()");
+ }
+
+ public UnaryCallable updateServiceCallable() {
+ throw new UnsupportedOperationException("Not implemented: updateServiceCallable()");
+ }
+
+ public OperationCallable
+ deleteServiceOperationCallable() {
+ throw new UnsupportedOperationException("Not implemented: deleteServiceOperationCallable()");
+ }
+
+ public UnaryCallable deleteServiceCallable() {
+ throw new UnsupportedOperationException("Not implemented: deleteServiceCallable()");
+ }
+
+ public UnaryCallable
+ listMetadataImportsPagedCallable() {
+ throw new UnsupportedOperationException("Not implemented: listMetadataImportsPagedCallable()");
+ }
+
+ public UnaryCallable
+ listMetadataImportsCallable() {
+ throw new UnsupportedOperationException("Not implemented: listMetadataImportsCallable()");
+ }
+
+ public UnaryCallable getMetadataImportCallable() {
+ throw new UnsupportedOperationException("Not implemented: getMetadataImportCallable()");
+ }
+
+ public OperationCallable
+ createMetadataImportOperationCallable() {
+ throw new UnsupportedOperationException(
+ "Not implemented: createMetadataImportOperationCallable()");
+ }
+
+ public UnaryCallable createMetadataImportCallable() {
+ throw new UnsupportedOperationException("Not implemented: createMetadataImportCallable()");
+ }
+
+ public OperationCallable
+ updateMetadataImportOperationCallable() {
+ throw new UnsupportedOperationException(
+ "Not implemented: updateMetadataImportOperationCallable()");
+ }
+
+ public UnaryCallable updateMetadataImportCallable() {
+ throw new UnsupportedOperationException("Not implemented: updateMetadataImportCallable()");
+ }
+
+ public OperationCallable
+ exportMetadataOperationCallable() {
+ throw new UnsupportedOperationException("Not implemented: exportMetadataOperationCallable()");
+ }
+
+ public UnaryCallable exportMetadataCallable() {
+ throw new UnsupportedOperationException("Not implemented: exportMetadataCallable()");
+ }
+
+ @Override
+ public abstract void close();
+}
diff --git a/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1/stub/DataprocMetastoreStubSettings.java b/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1/stub/DataprocMetastoreStubSettings.java
new file mode 100644
index 00000000..8ea89344
--- /dev/null
+++ b/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1/stub/DataprocMetastoreStubSettings.java
@@ -0,0 +1,932 @@
+/*
+ * Copyright 2021 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.google.cloud.metastore.v1.stub;
+
+import static com.google.cloud.metastore.v1.DataprocMetastoreClient.ListMetadataImportsPagedResponse;
+import static com.google.cloud.metastore.v1.DataprocMetastoreClient.ListServicesPagedResponse;
+
+import com.google.api.core.ApiFunction;
+import com.google.api.core.ApiFuture;
+import com.google.api.core.BetaApi;
+import com.google.api.gax.core.GaxProperties;
+import com.google.api.gax.core.GoogleCredentialsProvider;
+import com.google.api.gax.core.InstantiatingExecutorProvider;
+import com.google.api.gax.grpc.GaxGrpcProperties;
+import com.google.api.gax.grpc.GrpcTransportChannel;
+import com.google.api.gax.grpc.InstantiatingGrpcChannelProvider;
+import com.google.api.gax.grpc.ProtoOperationTransformers;
+import com.google.api.gax.longrunning.OperationSnapshot;
+import com.google.api.gax.longrunning.OperationTimedPollAlgorithm;
+import com.google.api.gax.retrying.RetrySettings;
+import com.google.api.gax.rpc.ApiCallContext;
+import com.google.api.gax.rpc.ApiClientHeaderProvider;
+import com.google.api.gax.rpc.ClientContext;
+import com.google.api.gax.rpc.OperationCallSettings;
+import com.google.api.gax.rpc.PageContext;
+import com.google.api.gax.rpc.PagedCallSettings;
+import com.google.api.gax.rpc.PagedListDescriptor;
+import com.google.api.gax.rpc.PagedListResponseFactory;
+import com.google.api.gax.rpc.StatusCode;
+import com.google.api.gax.rpc.StubSettings;
+import com.google.api.gax.rpc.TransportChannelProvider;
+import com.google.api.gax.rpc.UnaryCallSettings;
+import com.google.api.gax.rpc.UnaryCallable;
+import com.google.cloud.metastore.v1.CreateMetadataImportRequest;
+import com.google.cloud.metastore.v1.CreateServiceRequest;
+import com.google.cloud.metastore.v1.DeleteServiceRequest;
+import com.google.cloud.metastore.v1.ExportMetadataRequest;
+import com.google.cloud.metastore.v1.GetMetadataImportRequest;
+import com.google.cloud.metastore.v1.GetServiceRequest;
+import com.google.cloud.metastore.v1.ListMetadataImportsRequest;
+import com.google.cloud.metastore.v1.ListMetadataImportsResponse;
+import com.google.cloud.metastore.v1.ListServicesRequest;
+import com.google.cloud.metastore.v1.ListServicesResponse;
+import com.google.cloud.metastore.v1.MetadataExport;
+import com.google.cloud.metastore.v1.MetadataImport;
+import com.google.cloud.metastore.v1.OperationMetadata;
+import com.google.cloud.metastore.v1.Service;
+import com.google.cloud.metastore.v1.UpdateMetadataImportRequest;
+import com.google.cloud.metastore.v1.UpdateServiceRequest;
+import com.google.common.collect.ImmutableList;
+import com.google.common.collect.ImmutableMap;
+import com.google.common.collect.ImmutableSet;
+import com.google.common.collect.Lists;
+import com.google.longrunning.Operation;
+import com.google.protobuf.Empty;
+import java.io.IOException;
+import java.util.List;
+import javax.annotation.Generated;
+import org.threeten.bp.Duration;
+
+// AUTO-GENERATED DOCUMENTATION AND CLASS.
+/**
+ * Settings class to configure an instance of {@link DataprocMetastoreStub}.
+ *
+ * The default instance has everything set to sensible defaults:
+ *
+ *
+ * - The default service address (metastore.googleapis.com) and default port (443) are used.
+ *
- Credentials are acquired automatically through Application Default Credentials.
+ *
- Retries are configured for idempotent methods but not for non-idempotent methods.
+ *
+ *
+ * The builder of this class is recursive, so contained classes are themselves builders. When
+ * build() is called, the tree of builders is called to create the complete settings object.
+ *
+ *
For example, to set the total timeout of getService to 30 seconds:
+ *
+ *
{@code
+ * DataprocMetastoreStubSettings.Builder dataprocMetastoreSettingsBuilder =
+ * DataprocMetastoreStubSettings.newBuilder();
+ * dataprocMetastoreSettingsBuilder
+ * .getServiceSettings()
+ * .setRetrySettings(
+ * dataprocMetastoreSettingsBuilder
+ * .getServiceSettings()
+ * .getRetrySettings()
+ * .toBuilder()
+ * .setTotalTimeout(Duration.ofSeconds(30))
+ * .build());
+ * DataprocMetastoreStubSettings dataprocMetastoreSettings =
+ * dataprocMetastoreSettingsBuilder.build();
+ * }
+ */
+@Generated("by gapic-generator-java")
+public class DataprocMetastoreStubSettings extends StubSettings {
+ /** The default scopes of the service. */
+ private static final ImmutableList DEFAULT_SERVICE_SCOPES =
+ ImmutableList.builder().add("https://www.googleapis.com/auth/cloud-platform").build();
+
+ private final PagedCallSettings<
+ ListServicesRequest, ListServicesResponse, ListServicesPagedResponse>
+ listServicesSettings;
+ private final UnaryCallSettings getServiceSettings;
+ private final UnaryCallSettings createServiceSettings;
+ private final OperationCallSettings
+ createServiceOperationSettings;
+ private final UnaryCallSettings updateServiceSettings;
+ private final OperationCallSettings
+ updateServiceOperationSettings;
+ private final UnaryCallSettings deleteServiceSettings;
+ private final OperationCallSettings
+ deleteServiceOperationSettings;
+ private final PagedCallSettings<
+ ListMetadataImportsRequest, ListMetadataImportsResponse, ListMetadataImportsPagedResponse>
+ listMetadataImportsSettings;
+ private final UnaryCallSettings
+ getMetadataImportSettings;
+ private final UnaryCallSettings
+ createMetadataImportSettings;
+ private final OperationCallSettings<
+ CreateMetadataImportRequest, MetadataImport, OperationMetadata>
+ createMetadataImportOperationSettings;
+ private final UnaryCallSettings
+ updateMetadataImportSettings;
+ private final OperationCallSettings<
+ UpdateMetadataImportRequest, MetadataImport, OperationMetadata>
+ updateMetadataImportOperationSettings;
+ private final UnaryCallSettings exportMetadataSettings;
+ private final OperationCallSettings
+ exportMetadataOperationSettings;
+
+ private static final PagedListDescriptor
+ LIST_SERVICES_PAGE_STR_DESC =
+ new PagedListDescriptor() {
+ @Override
+ public String emptyToken() {
+ return "";
+ }
+
+ @Override
+ public ListServicesRequest injectToken(ListServicesRequest payload, String token) {
+ return ListServicesRequest.newBuilder(payload).setPageToken(token).build();
+ }
+
+ @Override
+ public ListServicesRequest injectPageSize(ListServicesRequest payload, int pageSize) {
+ return ListServicesRequest.newBuilder(payload).setPageSize(pageSize).build();
+ }
+
+ @Override
+ public Integer extractPageSize(ListServicesRequest payload) {
+ return payload.getPageSize();
+ }
+
+ @Override
+ public String extractNextToken(ListServicesResponse payload) {
+ return payload.getNextPageToken();
+ }
+
+ @Override
+ public Iterable extractResources(ListServicesResponse payload) {
+ return payload.getServicesList() == null
+ ? ImmutableList.of()
+ : payload.getServicesList();
+ }
+ };
+
+ private static final PagedListDescriptor<
+ ListMetadataImportsRequest, ListMetadataImportsResponse, MetadataImport>
+ LIST_METADATA_IMPORTS_PAGE_STR_DESC =
+ new PagedListDescriptor<
+ ListMetadataImportsRequest, ListMetadataImportsResponse, MetadataImport>() {
+ @Override
+ public String emptyToken() {
+ return "";
+ }
+
+ @Override
+ public ListMetadataImportsRequest injectToken(
+ ListMetadataImportsRequest payload, String token) {
+ return ListMetadataImportsRequest.newBuilder(payload).setPageToken(token).build();
+ }
+
+ @Override
+ public ListMetadataImportsRequest injectPageSize(
+ ListMetadataImportsRequest payload, int pageSize) {
+ return ListMetadataImportsRequest.newBuilder(payload).setPageSize(pageSize).build();
+ }
+
+ @Override
+ public Integer extractPageSize(ListMetadataImportsRequest payload) {
+ return payload.getPageSize();
+ }
+
+ @Override
+ public String extractNextToken(ListMetadataImportsResponse payload) {
+ return payload.getNextPageToken();
+ }
+
+ @Override
+ public Iterable extractResources(ListMetadataImportsResponse payload) {
+ return payload.getMetadataImportsList() == null
+ ? ImmutableList.of()
+ : payload.getMetadataImportsList();
+ }
+ };
+
+ private static final PagedListResponseFactory<
+ ListServicesRequest, ListServicesResponse, ListServicesPagedResponse>
+ LIST_SERVICES_PAGE_STR_FACT =
+ new PagedListResponseFactory<
+ ListServicesRequest, ListServicesResponse, ListServicesPagedResponse>() {
+ @Override
+ public ApiFuture getFuturePagedResponse(
+ UnaryCallable callable,
+ ListServicesRequest request,
+ ApiCallContext context,
+ ApiFuture futureResponse) {
+ PageContext pageContext =
+ PageContext.create(callable, LIST_SERVICES_PAGE_STR_DESC, request, context);
+ return ListServicesPagedResponse.createAsync(pageContext, futureResponse);
+ }
+ };
+
+ private static final PagedListResponseFactory<
+ ListMetadataImportsRequest, ListMetadataImportsResponse, ListMetadataImportsPagedResponse>
+ LIST_METADATA_IMPORTS_PAGE_STR_FACT =
+ new PagedListResponseFactory<
+ ListMetadataImportsRequest,
+ ListMetadataImportsResponse,
+ ListMetadataImportsPagedResponse>() {
+ @Override
+ public ApiFuture getFuturePagedResponse(
+ UnaryCallable callable,
+ ListMetadataImportsRequest request,
+ ApiCallContext context,
+ ApiFuture futureResponse) {
+ PageContext
+ pageContext =
+ PageContext.create(
+ callable, LIST_METADATA_IMPORTS_PAGE_STR_DESC, request, context);
+ return ListMetadataImportsPagedResponse.createAsync(pageContext, futureResponse);
+ }
+ };
+
+ /** Returns the object with the settings used for calls to listServices. */
+ public PagedCallSettings
+ listServicesSettings() {
+ return listServicesSettings;
+ }
+
+ /** Returns the object with the settings used for calls to getService. */
+ public UnaryCallSettings getServiceSettings() {
+ return getServiceSettings;
+ }
+
+ /** Returns the object with the settings used for calls to createService. */
+ public UnaryCallSettings createServiceSettings() {
+ return createServiceSettings;
+ }
+
+ /** Returns the object with the settings used for calls to createService. */
+ public OperationCallSettings
+ createServiceOperationSettings() {
+ return createServiceOperationSettings;
+ }
+
+ /** Returns the object with the settings used for calls to updateService. */
+ public UnaryCallSettings updateServiceSettings() {
+ return updateServiceSettings;
+ }
+
+ /** Returns the object with the settings used for calls to updateService. */
+ public OperationCallSettings
+ updateServiceOperationSettings() {
+ return updateServiceOperationSettings;
+ }
+
+ /** Returns the object with the settings used for calls to deleteService. */
+ public UnaryCallSettings deleteServiceSettings() {
+ return deleteServiceSettings;
+ }
+
+ /** Returns the object with the settings used for calls to deleteService. */
+ public OperationCallSettings
+ deleteServiceOperationSettings() {
+ return deleteServiceOperationSettings;
+ }
+
+ /** Returns the object with the settings used for calls to listMetadataImports. */
+ public PagedCallSettings<
+ ListMetadataImportsRequest, ListMetadataImportsResponse, ListMetadataImportsPagedResponse>
+ listMetadataImportsSettings() {
+ return listMetadataImportsSettings;
+ }
+
+ /** Returns the object with the settings used for calls to getMetadataImport. */
+ public UnaryCallSettings getMetadataImportSettings() {
+ return getMetadataImportSettings;
+ }
+
+ /** Returns the object with the settings used for calls to createMetadataImport. */
+ public UnaryCallSettings createMetadataImportSettings() {
+ return createMetadataImportSettings;
+ }
+
+ /** Returns the object with the settings used for calls to createMetadataImport. */
+ public OperationCallSettings
+ createMetadataImportOperationSettings() {
+ return createMetadataImportOperationSettings;
+ }
+
+ /** Returns the object with the settings used for calls to updateMetadataImport. */
+ public UnaryCallSettings updateMetadataImportSettings() {
+ return updateMetadataImportSettings;
+ }
+
+ /** Returns the object with the settings used for calls to updateMetadataImport. */
+ public OperationCallSettings
+ updateMetadataImportOperationSettings() {
+ return updateMetadataImportOperationSettings;
+ }
+
+ /** Returns the object with the settings used for calls to exportMetadata. */
+ public UnaryCallSettings exportMetadataSettings() {
+ return exportMetadataSettings;
+ }
+
+ /** Returns the object with the settings used for calls to exportMetadata. */
+ public OperationCallSettings
+ exportMetadataOperationSettings() {
+ return exportMetadataOperationSettings;
+ }
+
+ @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
+ public DataprocMetastoreStub createStub() throws IOException {
+ if (getTransportChannelProvider()
+ .getTransportName()
+ .equals(GrpcTransportChannel.getGrpcTransportName())) {
+ return GrpcDataprocMetastoreStub.create(this);
+ }
+ throw new UnsupportedOperationException(
+ String.format(
+ "Transport not supported: %s", getTransportChannelProvider().getTransportName()));
+ }
+
+ /** Returns a builder for the default ExecutorProvider for this service. */
+ public static InstantiatingExecutorProvider.Builder defaultExecutorProviderBuilder() {
+ return InstantiatingExecutorProvider.newBuilder();
+ }
+
+ /** Returns the default service endpoint. */
+ public static String getDefaultEndpoint() {
+ return "metastore.googleapis.com:443";
+ }
+
+ /** Returns the default service scopes. */
+ public static List getDefaultServiceScopes() {
+ return DEFAULT_SERVICE_SCOPES;
+ }
+
+ /** Returns a builder for the default credentials for this service. */
+ public static GoogleCredentialsProvider.Builder defaultCredentialsProviderBuilder() {
+ return GoogleCredentialsProvider.newBuilder().setScopesToApply(DEFAULT_SERVICE_SCOPES);
+ }
+
+ /** Returns a builder for the default ChannelProvider for this service. */
+ public static InstantiatingGrpcChannelProvider.Builder defaultGrpcTransportProviderBuilder() {
+ return InstantiatingGrpcChannelProvider.newBuilder()
+ .setMaxInboundMessageSize(Integer.MAX_VALUE);
+ }
+
+ public static TransportChannelProvider defaultTransportChannelProvider() {
+ return defaultGrpcTransportProviderBuilder().build();
+ }
+
+ @BetaApi("The surface for customizing headers is not stable yet and may change in the future.")
+ public static ApiClientHeaderProvider.Builder defaultApiClientHeaderProviderBuilder() {
+ return ApiClientHeaderProvider.newBuilder()
+ .setGeneratedLibToken(
+ "gapic", GaxProperties.getLibraryVersion(DataprocMetastoreStubSettings.class))
+ .setTransportToken(
+ GaxGrpcProperties.getGrpcTokenName(), GaxGrpcProperties.getGrpcVersion());
+ }
+
+ /** Returns a new builder for this class. */
+ public static Builder newBuilder() {
+ return Builder.createDefault();
+ }
+
+ /** Returns a new builder for this class. */
+ public static Builder newBuilder(ClientContext clientContext) {
+ return new Builder(clientContext);
+ }
+
+ /** Returns a builder containing all the values of this settings class. */
+ public Builder toBuilder() {
+ return new Builder(this);
+ }
+
+ protected DataprocMetastoreStubSettings(Builder settingsBuilder) throws IOException {
+ super(settingsBuilder);
+
+ listServicesSettings = settingsBuilder.listServicesSettings().build();
+ getServiceSettings = settingsBuilder.getServiceSettings().build();
+ createServiceSettings = settingsBuilder.createServiceSettings().build();
+ createServiceOperationSettings = settingsBuilder.createServiceOperationSettings().build();
+ updateServiceSettings = settingsBuilder.updateServiceSettings().build();
+ updateServiceOperationSettings = settingsBuilder.updateServiceOperationSettings().build();
+ deleteServiceSettings = settingsBuilder.deleteServiceSettings().build();
+ deleteServiceOperationSettings = settingsBuilder.deleteServiceOperationSettings().build();
+ listMetadataImportsSettings = settingsBuilder.listMetadataImportsSettings().build();
+ getMetadataImportSettings = settingsBuilder.getMetadataImportSettings().build();
+ createMetadataImportSettings = settingsBuilder.createMetadataImportSettings().build();
+ createMetadataImportOperationSettings =
+ settingsBuilder.createMetadataImportOperationSettings().build();
+ updateMetadataImportSettings = settingsBuilder.updateMetadataImportSettings().build();
+ updateMetadataImportOperationSettings =
+ settingsBuilder.updateMetadataImportOperationSettings().build();
+ exportMetadataSettings = settingsBuilder.exportMetadataSettings().build();
+ exportMetadataOperationSettings = settingsBuilder.exportMetadataOperationSettings().build();
+ }
+
+ /** Builder for DataprocMetastoreStubSettings. */
+ public static class Builder extends StubSettings.Builder {
+ private final ImmutableList> unaryMethodSettingsBuilders;
+ private final PagedCallSettings.Builder<
+ ListServicesRequest, ListServicesResponse, ListServicesPagedResponse>
+ listServicesSettings;
+ private final UnaryCallSettings.Builder getServiceSettings;
+ private final UnaryCallSettings.Builder createServiceSettings;
+ private final OperationCallSettings.Builder
+ createServiceOperationSettings;
+ private final UnaryCallSettings.Builder updateServiceSettings;
+ private final OperationCallSettings.Builder
+ updateServiceOperationSettings;
+ private final UnaryCallSettings.Builder deleteServiceSettings;
+ private final OperationCallSettings.Builder
+ deleteServiceOperationSettings;
+ private final PagedCallSettings.Builder<
+ ListMetadataImportsRequest,
+ ListMetadataImportsResponse,
+ ListMetadataImportsPagedResponse>
+ listMetadataImportsSettings;
+ private final UnaryCallSettings.Builder
+ getMetadataImportSettings;
+ private final UnaryCallSettings.Builder
+ createMetadataImportSettings;
+ private final OperationCallSettings.Builder<
+ CreateMetadataImportRequest, MetadataImport, OperationMetadata>
+ createMetadataImportOperationSettings;
+ private final UnaryCallSettings.Builder
+ updateMetadataImportSettings;
+ private final OperationCallSettings.Builder<
+ UpdateMetadataImportRequest, MetadataImport, OperationMetadata>
+ updateMetadataImportOperationSettings;
+ private final UnaryCallSettings.Builder
+ exportMetadataSettings;
+ private final OperationCallSettings.Builder<
+ ExportMetadataRequest, MetadataExport, OperationMetadata>
+ exportMetadataOperationSettings;
+ private static final ImmutableMap>
+ RETRYABLE_CODE_DEFINITIONS;
+
+ static {
+ ImmutableMap.Builder> definitions =
+ ImmutableMap.builder();
+ definitions.put(
+ "retry_policy_0_codes",
+ ImmutableSet.copyOf(Lists.newArrayList(StatusCode.Code.UNAVAILABLE)));
+ definitions.put(
+ "no_retry_1_codes", ImmutableSet.copyOf(Lists.newArrayList()));
+ RETRYABLE_CODE_DEFINITIONS = definitions.build();
+ }
+
+ private static final ImmutableMap RETRY_PARAM_DEFINITIONS;
+
+ static {
+ ImmutableMap.Builder definitions = ImmutableMap.builder();
+ RetrySettings settings = null;
+ settings =
+ RetrySettings.newBuilder()
+ .setInitialRetryDelay(Duration.ofMillis(1000L))
+ .setRetryDelayMultiplier(1.3)
+ .setMaxRetryDelay(Duration.ofMillis(10000L))
+ .setInitialRpcTimeout(Duration.ofMillis(60000L))
+ .setRpcTimeoutMultiplier(1.0)
+ .setMaxRpcTimeout(Duration.ofMillis(60000L))
+ .setTotalTimeout(Duration.ofMillis(60000L))
+ .build();
+ definitions.put("retry_policy_0_params", settings);
+ settings =
+ RetrySettings.newBuilder()
+ .setInitialRpcTimeout(Duration.ofMillis(60000L))
+ .setRpcTimeoutMultiplier(1.0)
+ .setMaxRpcTimeout(Duration.ofMillis(60000L))
+ .setTotalTimeout(Duration.ofMillis(60000L))
+ .build();
+ definitions.put("no_retry_1_params", settings);
+ RETRY_PARAM_DEFINITIONS = definitions.build();
+ }
+
+ protected Builder() {
+ this(((ClientContext) null));
+ }
+
+ protected Builder(ClientContext clientContext) {
+ super(clientContext);
+
+ listServicesSettings = PagedCallSettings.newBuilder(LIST_SERVICES_PAGE_STR_FACT);
+ getServiceSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ createServiceSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ createServiceOperationSettings = OperationCallSettings.newBuilder();
+ updateServiceSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ updateServiceOperationSettings = OperationCallSettings.newBuilder();
+ deleteServiceSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ deleteServiceOperationSettings = OperationCallSettings.newBuilder();
+ listMetadataImportsSettings =
+ PagedCallSettings.newBuilder(LIST_METADATA_IMPORTS_PAGE_STR_FACT);
+ getMetadataImportSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ createMetadataImportSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ createMetadataImportOperationSettings = OperationCallSettings.newBuilder();
+ updateMetadataImportSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ updateMetadataImportOperationSettings = OperationCallSettings.newBuilder();
+ exportMetadataSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ exportMetadataOperationSettings = OperationCallSettings.newBuilder();
+
+ unaryMethodSettingsBuilders =
+ ImmutableList.>of(
+ listServicesSettings,
+ getServiceSettings,
+ createServiceSettings,
+ updateServiceSettings,
+ deleteServiceSettings,
+ listMetadataImportsSettings,
+ getMetadataImportSettings,
+ createMetadataImportSettings,
+ updateMetadataImportSettings,
+ exportMetadataSettings);
+ initDefaults(this);
+ }
+
+ protected Builder(DataprocMetastoreStubSettings settings) {
+ super(settings);
+
+ listServicesSettings = settings.listServicesSettings.toBuilder();
+ getServiceSettings = settings.getServiceSettings.toBuilder();
+ createServiceSettings = settings.createServiceSettings.toBuilder();
+ createServiceOperationSettings = settings.createServiceOperationSettings.toBuilder();
+ updateServiceSettings = settings.updateServiceSettings.toBuilder();
+ updateServiceOperationSettings = settings.updateServiceOperationSettings.toBuilder();
+ deleteServiceSettings = settings.deleteServiceSettings.toBuilder();
+ deleteServiceOperationSettings = settings.deleteServiceOperationSettings.toBuilder();
+ listMetadataImportsSettings = settings.listMetadataImportsSettings.toBuilder();
+ getMetadataImportSettings = settings.getMetadataImportSettings.toBuilder();
+ createMetadataImportSettings = settings.createMetadataImportSettings.toBuilder();
+ createMetadataImportOperationSettings =
+ settings.createMetadataImportOperationSettings.toBuilder();
+ updateMetadataImportSettings = settings.updateMetadataImportSettings.toBuilder();
+ updateMetadataImportOperationSettings =
+ settings.updateMetadataImportOperationSettings.toBuilder();
+ exportMetadataSettings = settings.exportMetadataSettings.toBuilder();
+ exportMetadataOperationSettings = settings.exportMetadataOperationSettings.toBuilder();
+
+ unaryMethodSettingsBuilders =
+ ImmutableList.>of(
+ listServicesSettings,
+ getServiceSettings,
+ createServiceSettings,
+ updateServiceSettings,
+ deleteServiceSettings,
+ listMetadataImportsSettings,
+ getMetadataImportSettings,
+ createMetadataImportSettings,
+ updateMetadataImportSettings,
+ exportMetadataSettings);
+ }
+
+ private static Builder createDefault() {
+ Builder builder = new Builder(((ClientContext) null));
+
+ builder.setTransportChannelProvider(defaultTransportChannelProvider());
+ builder.setCredentialsProvider(defaultCredentialsProviderBuilder().build());
+ builder.setInternalHeaderProvider(defaultApiClientHeaderProviderBuilder().build());
+ builder.setEndpoint(getDefaultEndpoint());
+
+ return initDefaults(builder);
+ }
+
+ private static Builder initDefaults(Builder builder) {
+ builder
+ .listServicesSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_0_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_0_params"));
+
+ builder
+ .getServiceSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_0_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_0_params"));
+
+ builder
+ .createServiceSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params"));
+
+ builder
+ .updateServiceSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params"));
+
+ builder
+ .deleteServiceSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params"));
+
+ builder
+ .listMetadataImportsSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_0_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_0_params"));
+
+ builder
+ .getMetadataImportSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_0_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_0_params"));
+
+ builder
+ .createMetadataImportSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params"));
+
+ builder
+ .updateMetadataImportSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params"));
+
+ builder
+ .exportMetadataSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params"));
+
+ builder
+ .createServiceOperationSettings()
+ .setInitialCallSettings(
+ UnaryCallSettings
+ .newUnaryCallSettingsBuilder()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params"))
+ .build())
+ .setResponseTransformer(
+ ProtoOperationTransformers.ResponseTransformer.create(Service.class))
+ .setMetadataTransformer(
+ ProtoOperationTransformers.MetadataTransformer.create(OperationMetadata.class))
+ .setPollingAlgorithm(
+ OperationTimedPollAlgorithm.create(
+ RetrySettings.newBuilder()
+ .setInitialRetryDelay(Duration.ofMillis(5000L))
+ .setRetryDelayMultiplier(1.5)
+ .setMaxRetryDelay(Duration.ofMillis(45000L))
+ .setInitialRpcTimeout(Duration.ZERO)
+ .setRpcTimeoutMultiplier(1.0)
+ .setMaxRpcTimeout(Duration.ZERO)
+ .setTotalTimeout(Duration.ofMillis(300000L))
+ .build()));
+
+ builder
+ .updateServiceOperationSettings()
+ .setInitialCallSettings(
+ UnaryCallSettings
+ .newUnaryCallSettingsBuilder()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params"))
+ .build())
+ .setResponseTransformer(
+ ProtoOperationTransformers.ResponseTransformer.create(Service.class))
+ .setMetadataTransformer(
+ ProtoOperationTransformers.MetadataTransformer.create(OperationMetadata.class))
+ .setPollingAlgorithm(
+ OperationTimedPollAlgorithm.create(
+ RetrySettings.newBuilder()
+ .setInitialRetryDelay(Duration.ofMillis(5000L))
+ .setRetryDelayMultiplier(1.5)
+ .setMaxRetryDelay(Duration.ofMillis(45000L))
+ .setInitialRpcTimeout(Duration.ZERO)
+ .setRpcTimeoutMultiplier(1.0)
+ .setMaxRpcTimeout(Duration.ZERO)
+ .setTotalTimeout(Duration.ofMillis(300000L))
+ .build()));
+
+ builder
+ .deleteServiceOperationSettings()
+ .setInitialCallSettings(
+ UnaryCallSettings
+ .newUnaryCallSettingsBuilder()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params"))
+ .build())
+ .setResponseTransformer(
+ ProtoOperationTransformers.ResponseTransformer.create(Empty.class))
+ .setMetadataTransformer(
+ ProtoOperationTransformers.MetadataTransformer.create(OperationMetadata.class))
+ .setPollingAlgorithm(
+ OperationTimedPollAlgorithm.create(
+ RetrySettings.newBuilder()
+ .setInitialRetryDelay(Duration.ofMillis(5000L))
+ .setRetryDelayMultiplier(1.5)
+ .setMaxRetryDelay(Duration.ofMillis(45000L))
+ .setInitialRpcTimeout(Duration.ZERO)
+ .setRpcTimeoutMultiplier(1.0)
+ .setMaxRpcTimeout(Duration.ZERO)
+ .setTotalTimeout(Duration.ofMillis(300000L))
+ .build()));
+
+ builder
+ .createMetadataImportOperationSettings()
+ .setInitialCallSettings(
+ UnaryCallSettings
+ .newUnaryCallSettingsBuilder()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params"))
+ .build())
+ .setResponseTransformer(
+ ProtoOperationTransformers.ResponseTransformer.create(MetadataImport.class))
+ .setMetadataTransformer(
+ ProtoOperationTransformers.MetadataTransformer.create(OperationMetadata.class))
+ .setPollingAlgorithm(
+ OperationTimedPollAlgorithm.create(
+ RetrySettings.newBuilder()
+ .setInitialRetryDelay(Duration.ofMillis(5000L))
+ .setRetryDelayMultiplier(1.5)
+ .setMaxRetryDelay(Duration.ofMillis(45000L))
+ .setInitialRpcTimeout(Duration.ZERO)
+ .setRpcTimeoutMultiplier(1.0)
+ .setMaxRpcTimeout(Duration.ZERO)
+ .setTotalTimeout(Duration.ofMillis(300000L))
+ .build()));
+
+ builder
+ .updateMetadataImportOperationSettings()
+ .setInitialCallSettings(
+ UnaryCallSettings
+ .newUnaryCallSettingsBuilder()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params"))
+ .build())
+ .setResponseTransformer(
+ ProtoOperationTransformers.ResponseTransformer.create(MetadataImport.class))
+ .setMetadataTransformer(
+ ProtoOperationTransformers.MetadataTransformer.create(OperationMetadata.class))
+ .setPollingAlgorithm(
+ OperationTimedPollAlgorithm.create(
+ RetrySettings.newBuilder()
+ .setInitialRetryDelay(Duration.ofMillis(5000L))
+ .setRetryDelayMultiplier(1.5)
+ .setMaxRetryDelay(Duration.ofMillis(45000L))
+ .setInitialRpcTimeout(Duration.ZERO)
+ .setRpcTimeoutMultiplier(1.0)
+ .setMaxRpcTimeout(Duration.ZERO)
+ .setTotalTimeout(Duration.ofMillis(300000L))
+ .build()));
+
+ builder
+ .exportMetadataOperationSettings()
+ .setInitialCallSettings(
+ UnaryCallSettings
+ .newUnaryCallSettingsBuilder()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params"))
+ .build())
+ .setResponseTransformer(
+ ProtoOperationTransformers.ResponseTransformer.create(MetadataExport.class))
+ .setMetadataTransformer(
+ ProtoOperationTransformers.MetadataTransformer.create(OperationMetadata.class))
+ .setPollingAlgorithm(
+ OperationTimedPollAlgorithm.create(
+ RetrySettings.newBuilder()
+ .setInitialRetryDelay(Duration.ofMillis(5000L))
+ .setRetryDelayMultiplier(1.5)
+ .setMaxRetryDelay(Duration.ofMillis(45000L))
+ .setInitialRpcTimeout(Duration.ZERO)
+ .setRpcTimeoutMultiplier(1.0)
+ .setMaxRpcTimeout(Duration.ZERO)
+ .setTotalTimeout(Duration.ofMillis(300000L))
+ .build()));
+
+ return builder;
+ }
+
+ // NEXT_MAJOR_VER: remove 'throws Exception'.
+ /**
+ * Applies the given settings updater function to all of the unary API methods in this service.
+ *
+ * Note: This method does not support applying settings to streaming methods.
+ */
+ public Builder applyToAllUnaryMethods(
+ ApiFunction, Void> settingsUpdater) throws Exception {
+ super.applyToAllUnaryMethods(unaryMethodSettingsBuilders, settingsUpdater);
+ return this;
+ }
+
+ public ImmutableList> unaryMethodSettingsBuilders() {
+ return unaryMethodSettingsBuilders;
+ }
+
+ /** Returns the builder for the settings used for calls to listServices. */
+ public PagedCallSettings.Builder<
+ ListServicesRequest, ListServicesResponse, ListServicesPagedResponse>
+ listServicesSettings() {
+ return listServicesSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to getService. */
+ public UnaryCallSettings.Builder getServiceSettings() {
+ return getServiceSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to createService. */
+ public UnaryCallSettings.Builder createServiceSettings() {
+ return createServiceSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to createService. */
+ @BetaApi(
+ "The surface for use by generated code is not stable yet and may change in the future.")
+ public OperationCallSettings.Builder
+ createServiceOperationSettings() {
+ return createServiceOperationSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to updateService. */
+ public UnaryCallSettings.Builder updateServiceSettings() {
+ return updateServiceSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to updateService. */
+ @BetaApi(
+ "The surface for use by generated code is not stable yet and may change in the future.")
+ public OperationCallSettings.Builder
+ updateServiceOperationSettings() {
+ return updateServiceOperationSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to deleteService. */
+ public UnaryCallSettings.Builder deleteServiceSettings() {
+ return deleteServiceSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to deleteService. */
+ @BetaApi(
+ "The surface for use by generated code is not stable yet and may change in the future.")
+ public OperationCallSettings.Builder
+ deleteServiceOperationSettings() {
+ return deleteServiceOperationSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to listMetadataImports. */
+ public PagedCallSettings.Builder<
+ ListMetadataImportsRequest,
+ ListMetadataImportsResponse,
+ ListMetadataImportsPagedResponse>
+ listMetadataImportsSettings() {
+ return listMetadataImportsSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to getMetadataImport. */
+ public UnaryCallSettings.Builder
+ getMetadataImportSettings() {
+ return getMetadataImportSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to createMetadataImport. */
+ public UnaryCallSettings.Builder
+ createMetadataImportSettings() {
+ return createMetadataImportSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to createMetadataImport. */
+ @BetaApi(
+ "The surface for use by generated code is not stable yet and may change in the future.")
+ public OperationCallSettings.Builder<
+ CreateMetadataImportRequest, MetadataImport, OperationMetadata>
+ createMetadataImportOperationSettings() {
+ return createMetadataImportOperationSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to updateMetadataImport. */
+ public UnaryCallSettings.Builder
+ updateMetadataImportSettings() {
+ return updateMetadataImportSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to updateMetadataImport. */
+ @BetaApi(
+ "The surface for use by generated code is not stable yet and may change in the future.")
+ public OperationCallSettings.Builder<
+ UpdateMetadataImportRequest, MetadataImport, OperationMetadata>
+ updateMetadataImportOperationSettings() {
+ return updateMetadataImportOperationSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to exportMetadata. */
+ public UnaryCallSettings.Builder exportMetadataSettings() {
+ return exportMetadataSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to exportMetadata. */
+ @BetaApi(
+ "The surface for use by generated code is not stable yet and may change in the future.")
+ public OperationCallSettings.Builder
+ exportMetadataOperationSettings() {
+ return exportMetadataOperationSettings;
+ }
+
+ @Override
+ public DataprocMetastoreStubSettings build() throws IOException {
+ return new DataprocMetastoreStubSettings(this);
+ }
+ }
+}
diff --git a/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1/stub/GrpcDataprocMetastoreCallableFactory.java b/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1/stub/GrpcDataprocMetastoreCallableFactory.java
new file mode 100644
index 00000000..6469bfd6
--- /dev/null
+++ b/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1/stub/GrpcDataprocMetastoreCallableFactory.java
@@ -0,0 +1,113 @@
+/*
+ * Copyright 2021 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.google.cloud.metastore.v1.stub;
+
+import com.google.api.gax.grpc.GrpcCallSettings;
+import com.google.api.gax.grpc.GrpcCallableFactory;
+import com.google.api.gax.grpc.GrpcStubCallableFactory;
+import com.google.api.gax.rpc.BatchingCallSettings;
+import com.google.api.gax.rpc.BidiStreamingCallable;
+import com.google.api.gax.rpc.ClientContext;
+import com.google.api.gax.rpc.ClientStreamingCallable;
+import com.google.api.gax.rpc.OperationCallSettings;
+import com.google.api.gax.rpc.OperationCallable;
+import com.google.api.gax.rpc.PagedCallSettings;
+import com.google.api.gax.rpc.ServerStreamingCallSettings;
+import com.google.api.gax.rpc.ServerStreamingCallable;
+import com.google.api.gax.rpc.StreamingCallSettings;
+import com.google.api.gax.rpc.UnaryCallSettings;
+import com.google.api.gax.rpc.UnaryCallable;
+import com.google.longrunning.Operation;
+import com.google.longrunning.stub.OperationsStub;
+import javax.annotation.Generated;
+
+// AUTO-GENERATED DOCUMENTATION AND CLASS.
+/**
+ * gRPC callable factory implementation for the DataprocMetastore service API.
+ *
+ * This class is for advanced usage.
+ */
+@Generated("by gapic-generator-java")
+public class GrpcDataprocMetastoreCallableFactory implements GrpcStubCallableFactory {
+
+ @Override
+ public UnaryCallable createUnaryCallable(
+ GrpcCallSettings grpcCallSettings,
+ UnaryCallSettings callSettings,
+ ClientContext clientContext) {
+ return GrpcCallableFactory.createUnaryCallable(grpcCallSettings, callSettings, clientContext);
+ }
+
+ @Override
+ public
+ UnaryCallable createPagedCallable(
+ GrpcCallSettings grpcCallSettings,
+ PagedCallSettings callSettings,
+ ClientContext clientContext) {
+ return GrpcCallableFactory.createPagedCallable(grpcCallSettings, callSettings, clientContext);
+ }
+
+ @Override
+ public UnaryCallable createBatchingCallable(
+ GrpcCallSettings grpcCallSettings,
+ BatchingCallSettings callSettings,
+ ClientContext clientContext) {
+ return GrpcCallableFactory.createBatchingCallable(
+ grpcCallSettings, callSettings, clientContext);
+ }
+
+ @Override
+ public
+ OperationCallable createOperationCallable(
+ GrpcCallSettings grpcCallSettings,
+ OperationCallSettings callSettings,
+ ClientContext clientContext,
+ OperationsStub operationsStub) {
+ return GrpcCallableFactory.createOperationCallable(
+ grpcCallSettings, callSettings, clientContext, operationsStub);
+ }
+
+ @Override
+ public
+ BidiStreamingCallable createBidiStreamingCallable(
+ GrpcCallSettings grpcCallSettings,
+ StreamingCallSettings callSettings,
+ ClientContext clientContext) {
+ return GrpcCallableFactory.createBidiStreamingCallable(
+ grpcCallSettings, callSettings, clientContext);
+ }
+
+ @Override
+ public
+ ServerStreamingCallable createServerStreamingCallable(
+ GrpcCallSettings grpcCallSettings,
+ ServerStreamingCallSettings callSettings,
+ ClientContext clientContext) {
+ return GrpcCallableFactory.createServerStreamingCallable(
+ grpcCallSettings, callSettings, clientContext);
+ }
+
+ @Override
+ public
+ ClientStreamingCallable createClientStreamingCallable(
+ GrpcCallSettings grpcCallSettings,
+ StreamingCallSettings callSettings,
+ ClientContext clientContext) {
+ return GrpcCallableFactory.createClientStreamingCallable(
+ grpcCallSettings, callSettings, clientContext);
+ }
+}
diff --git a/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1/stub/GrpcDataprocMetastoreStub.java b/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1/stub/GrpcDataprocMetastoreStub.java
new file mode 100644
index 00000000..638e76f6
--- /dev/null
+++ b/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1/stub/GrpcDataprocMetastoreStub.java
@@ -0,0 +1,588 @@
+/*
+ * Copyright 2021 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.google.cloud.metastore.v1.stub;
+
+import static com.google.cloud.metastore.v1.DataprocMetastoreClient.ListMetadataImportsPagedResponse;
+import static com.google.cloud.metastore.v1.DataprocMetastoreClient.ListServicesPagedResponse;
+
+import com.google.api.gax.core.BackgroundResource;
+import com.google.api.gax.core.BackgroundResourceAggregation;
+import com.google.api.gax.grpc.GrpcCallSettings;
+import com.google.api.gax.grpc.GrpcStubCallableFactory;
+import com.google.api.gax.rpc.ClientContext;
+import com.google.api.gax.rpc.OperationCallable;
+import com.google.api.gax.rpc.RequestParamsExtractor;
+import com.google.api.gax.rpc.UnaryCallable;
+import com.google.cloud.metastore.v1.CreateMetadataImportRequest;
+import com.google.cloud.metastore.v1.CreateServiceRequest;
+import com.google.cloud.metastore.v1.DeleteServiceRequest;
+import com.google.cloud.metastore.v1.ExportMetadataRequest;
+import com.google.cloud.metastore.v1.GetMetadataImportRequest;
+import com.google.cloud.metastore.v1.GetServiceRequest;
+import com.google.cloud.metastore.v1.ListMetadataImportsRequest;
+import com.google.cloud.metastore.v1.ListMetadataImportsResponse;
+import com.google.cloud.metastore.v1.ListServicesRequest;
+import com.google.cloud.metastore.v1.ListServicesResponse;
+import com.google.cloud.metastore.v1.MetadataExport;
+import com.google.cloud.metastore.v1.MetadataImport;
+import com.google.cloud.metastore.v1.OperationMetadata;
+import com.google.cloud.metastore.v1.Service;
+import com.google.cloud.metastore.v1.UpdateMetadataImportRequest;
+import com.google.cloud.metastore.v1.UpdateServiceRequest;
+import com.google.common.collect.ImmutableMap;
+import com.google.longrunning.Operation;
+import com.google.longrunning.stub.GrpcOperationsStub;
+import com.google.protobuf.Empty;
+import io.grpc.MethodDescriptor;
+import io.grpc.protobuf.ProtoUtils;
+import java.io.IOException;
+import java.util.Map;
+import java.util.concurrent.TimeUnit;
+import javax.annotation.Generated;
+
+// AUTO-GENERATED DOCUMENTATION AND CLASS.
+/**
+ * gRPC stub implementation for the DataprocMetastore service API.
+ *
+ * This class is for advanced usage and reflects the underlying API directly.
+ */
+@Generated("by gapic-generator-java")
+public class GrpcDataprocMetastoreStub extends DataprocMetastoreStub {
+ private static final MethodDescriptor
+ listServicesMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName("google.cloud.metastore.v1.DataprocMetastore/ListServices")
+ .setRequestMarshaller(ProtoUtils.marshaller(ListServicesRequest.getDefaultInstance()))
+ .setResponseMarshaller(
+ ProtoUtils.marshaller(ListServicesResponse.getDefaultInstance()))
+ .build();
+
+ private static final MethodDescriptor getServiceMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName("google.cloud.metastore.v1.DataprocMetastore/GetService")
+ .setRequestMarshaller(ProtoUtils.marshaller(GetServiceRequest.getDefaultInstance()))
+ .setResponseMarshaller(ProtoUtils.marshaller(Service.getDefaultInstance()))
+ .build();
+
+ private static final MethodDescriptor
+ createServiceMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName("google.cloud.metastore.v1.DataprocMetastore/CreateService")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(CreateServiceRequest.getDefaultInstance()))
+ .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance()))
+ .build();
+
+ private static final MethodDescriptor
+ updateServiceMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName("google.cloud.metastore.v1.DataprocMetastore/UpdateService")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(UpdateServiceRequest.getDefaultInstance()))
+ .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance()))
+ .build();
+
+ private static final MethodDescriptor
+ deleteServiceMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName("google.cloud.metastore.v1.DataprocMetastore/DeleteService")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(DeleteServiceRequest.getDefaultInstance()))
+ .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance()))
+ .build();
+
+ private static final MethodDescriptor
+ listMetadataImportsMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName("google.cloud.metastore.v1.DataprocMetastore/ListMetadataImports")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(ListMetadataImportsRequest.getDefaultInstance()))
+ .setResponseMarshaller(
+ ProtoUtils.marshaller(ListMetadataImportsResponse.getDefaultInstance()))
+ .build();
+
+ private static final MethodDescriptor
+ getMetadataImportMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName("google.cloud.metastore.v1.DataprocMetastore/GetMetadataImport")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(GetMetadataImportRequest.getDefaultInstance()))
+ .setResponseMarshaller(ProtoUtils.marshaller(MetadataImport.getDefaultInstance()))
+ .build();
+
+ private static final MethodDescriptor
+ createMetadataImportMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName("google.cloud.metastore.v1.DataprocMetastore/CreateMetadataImport")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(CreateMetadataImportRequest.getDefaultInstance()))
+ .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance()))
+ .build();
+
+ private static final MethodDescriptor
+ updateMetadataImportMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName("google.cloud.metastore.v1.DataprocMetastore/UpdateMetadataImport")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(UpdateMetadataImportRequest.getDefaultInstance()))
+ .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance()))
+ .build();
+
+ private static final MethodDescriptor
+ exportMetadataMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName("google.cloud.metastore.v1.DataprocMetastore/ExportMetadata")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(ExportMetadataRequest.getDefaultInstance()))
+ .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance()))
+ .build();
+
+ private final UnaryCallable