deleteBackupCallable(
return stub.deleteBackupCallable();
}
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Removes the attached IAM policies for a resource
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * RemoveIamPolicyRequest request =
+ * RemoveIamPolicyRequest.newBuilder()
+ * .setResource(
+ * BackupName.of("[PROJECT]", "[LOCATION]", "[SERVICE]", "[BACKUP]").toString())
+ * .setAsynchronous(true)
+ * .build();
+ * RemoveIamPolicyResponse response = dataprocMetastoreClient.removeIamPolicy(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 RemoveIamPolicyResponse removeIamPolicy(RemoveIamPolicyRequest request) {
+ return removeIamPolicyCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Removes the attached IAM policies for a resource
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * RemoveIamPolicyRequest request =
+ * RemoveIamPolicyRequest.newBuilder()
+ * .setResource(
+ * BackupName.of("[PROJECT]", "[LOCATION]", "[SERVICE]", "[BACKUP]").toString())
+ * .setAsynchronous(true)
+ * .build();
+ * ApiFuture future =
+ * dataprocMetastoreClient.removeIamPolicyCallable().futureCall(request);
+ * // Do something.
+ * RemoveIamPolicyResponse response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable
+ removeIamPolicyCallable() {
+ return stub.removeIamPolicyCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Query DPMS metadata.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * QueryMetadataRequest request =
+ * QueryMetadataRequest.newBuilder()
+ * .setService(ServiceName.of("[PROJECT]", "[LOCATION]", "[SERVICE]").toString())
+ * .setQuery("query107944136")
+ * .build();
+ * QueryMetadataResponse response = dataprocMetastoreClient.queryMetadataAsync(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 queryMetadataAsync(
+ QueryMetadataRequest request) {
+ return queryMetadataOperationCallable().futureCall(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Query DPMS metadata.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * QueryMetadataRequest request =
+ * QueryMetadataRequest.newBuilder()
+ * .setService(ServiceName.of("[PROJECT]", "[LOCATION]", "[SERVICE]").toString())
+ * .setQuery("query107944136")
+ * .build();
+ * OperationFuture future =
+ * dataprocMetastoreClient.queryMetadataOperationCallable().futureCall(request);
+ * // Do something.
+ * QueryMetadataResponse response = future.get();
+ * }
+ * }
+ */
+ public final OperationCallable
+ queryMetadataOperationCallable() {
+ return stub.queryMetadataOperationCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Query DPMS metadata.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * QueryMetadataRequest request =
+ * QueryMetadataRequest.newBuilder()
+ * .setService(ServiceName.of("[PROJECT]", "[LOCATION]", "[SERVICE]").toString())
+ * .setQuery("query107944136")
+ * .build();
+ * ApiFuture future =
+ * dataprocMetastoreClient.queryMetadataCallable().futureCall(request);
+ * // Do something.
+ * Operation response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable queryMetadataCallable() {
+ return stub.queryMetadataCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Move a table to another database.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * MoveTableToDatabaseRequest request =
+ * MoveTableToDatabaseRequest.newBuilder()
+ * .setService(ServiceName.of("[PROJECT]", "[LOCATION]", "[SERVICE]").toString())
+ * .setTableName("tableName-1988717703")
+ * .setDbName("dbName-1339126743")
+ * .setDestinationDbName("destinationDbName-2077361705")
+ * .build();
+ * MoveTableToDatabaseResponse response =
+ * dataprocMetastoreClient.moveTableToDatabaseAsync(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
+ moveTableToDatabaseAsync(MoveTableToDatabaseRequest request) {
+ return moveTableToDatabaseOperationCallable().futureCall(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Move a table to another database.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * MoveTableToDatabaseRequest request =
+ * MoveTableToDatabaseRequest.newBuilder()
+ * .setService(ServiceName.of("[PROJECT]", "[LOCATION]", "[SERVICE]").toString())
+ * .setTableName("tableName-1988717703")
+ * .setDbName("dbName-1339126743")
+ * .setDestinationDbName("destinationDbName-2077361705")
+ * .build();
+ * OperationFuture future =
+ * dataprocMetastoreClient.moveTableToDatabaseOperationCallable().futureCall(request);
+ * // Do something.
+ * MoveTableToDatabaseResponse response = future.get();
+ * }
+ * }
+ */
+ public final OperationCallable<
+ MoveTableToDatabaseRequest, MoveTableToDatabaseResponse, OperationMetadata>
+ moveTableToDatabaseOperationCallable() {
+ return stub.moveTableToDatabaseOperationCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Move a table to another database.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * MoveTableToDatabaseRequest request =
+ * MoveTableToDatabaseRequest.newBuilder()
+ * .setService(ServiceName.of("[PROJECT]", "[LOCATION]", "[SERVICE]").toString())
+ * .setTableName("tableName-1988717703")
+ * .setDbName("dbName-1339126743")
+ * .setDestinationDbName("destinationDbName-2077361705")
+ * .build();
+ * ApiFuture future =
+ * dataprocMetastoreClient.moveTableToDatabaseCallable().futureCall(request);
+ * // Do something.
+ * Operation response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable moveTableToDatabaseCallable() {
+ return stub.moveTableToDatabaseCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Alter metadata resource location. The metadata resource can be a database, table, or partition.
+ * This functionality only updates the parent directory for the respective metadata resource and
+ * does not transfer any existing data to the new location.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * AlterMetadataResourceLocationRequest request =
+ * AlterMetadataResourceLocationRequest.newBuilder()
+ * .setService(ServiceName.of("[PROJECT]", "[LOCATION]", "[SERVICE]").toString())
+ * .setResourceName("resourceName-384566343")
+ * .setLocationUri("locationUri552310135")
+ * .build();
+ * AlterMetadataResourceLocationResponse response =
+ * dataprocMetastoreClient.alterMetadataResourceLocationAsync(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
+ alterMetadataResourceLocationAsync(AlterMetadataResourceLocationRequest request) {
+ return alterMetadataResourceLocationOperationCallable().futureCall(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Alter metadata resource location. The metadata resource can be a database, table, or partition.
+ * This functionality only updates the parent directory for the respective metadata resource and
+ * does not transfer any existing data to the new location.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * AlterMetadataResourceLocationRequest request =
+ * AlterMetadataResourceLocationRequest.newBuilder()
+ * .setService(ServiceName.of("[PROJECT]", "[LOCATION]", "[SERVICE]").toString())
+ * .setResourceName("resourceName-384566343")
+ * .setLocationUri("locationUri552310135")
+ * .build();
+ * OperationFuture future =
+ * dataprocMetastoreClient
+ * .alterMetadataResourceLocationOperationCallable()
+ * .futureCall(request);
+ * // Do something.
+ * AlterMetadataResourceLocationResponse response = future.get();
+ * }
+ * }
+ */
+ public final OperationCallable<
+ AlterMetadataResourceLocationRequest,
+ AlterMetadataResourceLocationResponse,
+ OperationMetadata>
+ alterMetadataResourceLocationOperationCallable() {
+ return stub.alterMetadataResourceLocationOperationCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Alter metadata resource location. The metadata resource can be a database, table, or partition.
+ * This functionality only updates the parent directory for the respective metadata resource and
+ * does not transfer any existing data to the new location.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * AlterMetadataResourceLocationRequest request =
+ * AlterMetadataResourceLocationRequest.newBuilder()
+ * .setService(ServiceName.of("[PROJECT]", "[LOCATION]", "[SERVICE]").toString())
+ * .setResourceName("resourceName-384566343")
+ * .setLocationUri("locationUri552310135")
+ * .build();
+ * ApiFuture future =
+ * dataprocMetastoreClient.alterMetadataResourceLocationCallable().futureCall(request);
+ * // Do something.
+ * Operation response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable
+ alterMetadataResourceLocationCallable() {
+ return stub.alterMetadataResourceLocationCallable();
+ }
+
@Override
public final void close() {
stub.close();
diff --git a/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1alpha/DataprocMetastoreSettings.java b/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1alpha/DataprocMetastoreSettings.java
index 8fcc505c7e05..52ae9642800c 100644
--- a/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1alpha/DataprocMetastoreSettings.java
+++ b/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1alpha/DataprocMetastoreSettings.java
@@ -213,6 +213,53 @@ public UnaryCallSettings deleteBackupSettings()
return ((DataprocMetastoreStubSettings) getStubSettings()).deleteBackupOperationSettings();
}
+ /** Returns the object with the settings used for calls to removeIamPolicy. */
+ public UnaryCallSettings
+ removeIamPolicySettings() {
+ return ((DataprocMetastoreStubSettings) getStubSettings()).removeIamPolicySettings();
+ }
+
+ /** Returns the object with the settings used for calls to queryMetadata. */
+ public UnaryCallSettings queryMetadataSettings() {
+ return ((DataprocMetastoreStubSettings) getStubSettings()).queryMetadataSettings();
+ }
+
+ /** Returns the object with the settings used for calls to queryMetadata. */
+ public OperationCallSettings
+ queryMetadataOperationSettings() {
+ return ((DataprocMetastoreStubSettings) getStubSettings()).queryMetadataOperationSettings();
+ }
+
+ /** Returns the object with the settings used for calls to moveTableToDatabase. */
+ public UnaryCallSettings moveTableToDatabaseSettings() {
+ return ((DataprocMetastoreStubSettings) getStubSettings()).moveTableToDatabaseSettings();
+ }
+
+ /** Returns the object with the settings used for calls to moveTableToDatabase. */
+ public OperationCallSettings<
+ MoveTableToDatabaseRequest, MoveTableToDatabaseResponse, OperationMetadata>
+ moveTableToDatabaseOperationSettings() {
+ return ((DataprocMetastoreStubSettings) getStubSettings())
+ .moveTableToDatabaseOperationSettings();
+ }
+
+ /** Returns the object with the settings used for calls to alterMetadataResourceLocation. */
+ public UnaryCallSettings
+ alterMetadataResourceLocationSettings() {
+ return ((DataprocMetastoreStubSettings) getStubSettings())
+ .alterMetadataResourceLocationSettings();
+ }
+
+ /** Returns the object with the settings used for calls to alterMetadataResourceLocation. */
+ public OperationCallSettings<
+ AlterMetadataResourceLocationRequest,
+ AlterMetadataResourceLocationResponse,
+ OperationMetadata>
+ alterMetadataResourceLocationOperationSettings() {
+ return ((DataprocMetastoreStubSettings) getStubSettings())
+ .alterMetadataResourceLocationOperationSettings();
+ }
+
public static final DataprocMetastoreSettings create(DataprocMetastoreStubSettings stub)
throws IOException {
return new DataprocMetastoreSettings.Builder(stub.toBuilder()).build();
@@ -470,6 +517,52 @@ public UnaryCallSettings.Builder deleteBackupSet
return getStubSettingsBuilder().deleteBackupOperationSettings();
}
+ /** Returns the builder for the settings used for calls to removeIamPolicy. */
+ public UnaryCallSettings.Builder
+ removeIamPolicySettings() {
+ return getStubSettingsBuilder().removeIamPolicySettings();
+ }
+
+ /** Returns the builder for the settings used for calls to queryMetadata. */
+ public UnaryCallSettings.Builder queryMetadataSettings() {
+ return getStubSettingsBuilder().queryMetadataSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to queryMetadata. */
+ public OperationCallSettings.Builder<
+ QueryMetadataRequest, QueryMetadataResponse, OperationMetadata>
+ queryMetadataOperationSettings() {
+ return getStubSettingsBuilder().queryMetadataOperationSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to moveTableToDatabase. */
+ public UnaryCallSettings.Builder
+ moveTableToDatabaseSettings() {
+ return getStubSettingsBuilder().moveTableToDatabaseSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to moveTableToDatabase. */
+ public OperationCallSettings.Builder<
+ MoveTableToDatabaseRequest, MoveTableToDatabaseResponse, OperationMetadata>
+ moveTableToDatabaseOperationSettings() {
+ return getStubSettingsBuilder().moveTableToDatabaseOperationSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to alterMetadataResourceLocation. */
+ public UnaryCallSettings.Builder
+ alterMetadataResourceLocationSettings() {
+ return getStubSettingsBuilder().alterMetadataResourceLocationSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to alterMetadataResourceLocation. */
+ public OperationCallSettings.Builder<
+ AlterMetadataResourceLocationRequest,
+ AlterMetadataResourceLocationResponse,
+ OperationMetadata>
+ alterMetadataResourceLocationOperationSettings() {
+ return getStubSettingsBuilder().alterMetadataResourceLocationOperationSettings();
+ }
+
@Override
public DataprocMetastoreSettings build() throws IOException {
return new DataprocMetastoreSettings(this);
diff --git a/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1alpha/gapic_metadata.json b/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1alpha/gapic_metadata.json
index 49dba75e53dd..c3ba4c266caf 100644
--- a/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1alpha/gapic_metadata.json
+++ b/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1alpha/gapic_metadata.json
@@ -10,6 +10,9 @@
"grpc": {
"libraryClient": "DataprocMetastoreClient",
"rpcs": {
+ "AlterMetadataResourceLocation": {
+ "methods": ["alterMetadataResourceLocationAsync", "alterMetadataResourceLocationOperationCallable", "alterMetadataResourceLocationCallable"]
+ },
"CreateBackup": {
"methods": ["createBackupAsync", "createBackupAsync", "createBackupAsync", "createBackupOperationCallable", "createBackupCallable"]
},
@@ -46,6 +49,15 @@
"ListServices": {
"methods": ["listServices", "listServices", "listServices", "listServicesPagedCallable", "listServicesCallable"]
},
+ "MoveTableToDatabase": {
+ "methods": ["moveTableToDatabaseAsync", "moveTableToDatabaseOperationCallable", "moveTableToDatabaseCallable"]
+ },
+ "QueryMetadata": {
+ "methods": ["queryMetadataAsync", "queryMetadataOperationCallable", "queryMetadataCallable"]
+ },
+ "RemoveIamPolicy": {
+ "methods": ["removeIamPolicy", "removeIamPolicyCallable"]
+ },
"RestoreService": {
"methods": ["restoreServiceAsync", "restoreServiceAsync", "restoreServiceAsync", "restoreServiceAsync", "restoreServiceAsync", "restoreServiceOperationCallable", "restoreServiceCallable"]
},
diff --git a/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1alpha/stub/DataprocMetastoreStub.java b/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1alpha/stub/DataprocMetastoreStub.java
index 3eceac0d7f02..12466e0c0935 100644
--- a/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1alpha/stub/DataprocMetastoreStub.java
+++ b/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1alpha/stub/DataprocMetastoreStub.java
@@ -24,6 +24,8 @@
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.v1alpha.AlterMetadataResourceLocationRequest;
+import com.google.cloud.metastore.v1alpha.AlterMetadataResourceLocationResponse;
import com.google.cloud.metastore.v1alpha.Backup;
import com.google.cloud.metastore.v1alpha.CreateBackupRequest;
import com.google.cloud.metastore.v1alpha.CreateMetadataImportRequest;
@@ -42,7 +44,13 @@
import com.google.cloud.metastore.v1alpha.ListServicesResponse;
import com.google.cloud.metastore.v1alpha.MetadataExport;
import com.google.cloud.metastore.v1alpha.MetadataImport;
+import com.google.cloud.metastore.v1alpha.MoveTableToDatabaseRequest;
+import com.google.cloud.metastore.v1alpha.MoveTableToDatabaseResponse;
import com.google.cloud.metastore.v1alpha.OperationMetadata;
+import com.google.cloud.metastore.v1alpha.QueryMetadataRequest;
+import com.google.cloud.metastore.v1alpha.QueryMetadataResponse;
+import com.google.cloud.metastore.v1alpha.RemoveIamPolicyRequest;
+import com.google.cloud.metastore.v1alpha.RemoveIamPolicyResponse;
import com.google.cloud.metastore.v1alpha.Restore;
import com.google.cloud.metastore.v1alpha.RestoreServiceRequest;
import com.google.cloud.metastore.v1alpha.Service;
@@ -192,6 +200,45 @@ public UnaryCallable deleteBackupCallable() {
throw new UnsupportedOperationException("Not implemented: deleteBackupCallable()");
}
+ public UnaryCallable removeIamPolicyCallable() {
+ throw new UnsupportedOperationException("Not implemented: removeIamPolicyCallable()");
+ }
+
+ public OperationCallable
+ queryMetadataOperationCallable() {
+ throw new UnsupportedOperationException("Not implemented: queryMetadataOperationCallable()");
+ }
+
+ public UnaryCallable queryMetadataCallable() {
+ throw new UnsupportedOperationException("Not implemented: queryMetadataCallable()");
+ }
+
+ public OperationCallable<
+ MoveTableToDatabaseRequest, MoveTableToDatabaseResponse, OperationMetadata>
+ moveTableToDatabaseOperationCallable() {
+ throw new UnsupportedOperationException(
+ "Not implemented: moveTableToDatabaseOperationCallable()");
+ }
+
+ public UnaryCallable moveTableToDatabaseCallable() {
+ throw new UnsupportedOperationException("Not implemented: moveTableToDatabaseCallable()");
+ }
+
+ public OperationCallable<
+ AlterMetadataResourceLocationRequest,
+ AlterMetadataResourceLocationResponse,
+ OperationMetadata>
+ alterMetadataResourceLocationOperationCallable() {
+ throw new UnsupportedOperationException(
+ "Not implemented: alterMetadataResourceLocationOperationCallable()");
+ }
+
+ public UnaryCallable
+ alterMetadataResourceLocationCallable() {
+ throw new UnsupportedOperationException(
+ "Not implemented: alterMetadataResourceLocationCallable()");
+ }
+
@Override
public abstract void close();
}
diff --git a/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1alpha/stub/DataprocMetastoreStubSettings.java b/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1alpha/stub/DataprocMetastoreStubSettings.java
index cedea51bae46..a5ef219997f0 100644
--- a/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1alpha/stub/DataprocMetastoreStubSettings.java
+++ b/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1alpha/stub/DataprocMetastoreStubSettings.java
@@ -49,6 +49,8 @@
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.v1alpha.AlterMetadataResourceLocationRequest;
+import com.google.cloud.metastore.v1alpha.AlterMetadataResourceLocationResponse;
import com.google.cloud.metastore.v1alpha.Backup;
import com.google.cloud.metastore.v1alpha.CreateBackupRequest;
import com.google.cloud.metastore.v1alpha.CreateMetadataImportRequest;
@@ -67,7 +69,13 @@
import com.google.cloud.metastore.v1alpha.ListServicesResponse;
import com.google.cloud.metastore.v1alpha.MetadataExport;
import com.google.cloud.metastore.v1alpha.MetadataImport;
+import com.google.cloud.metastore.v1alpha.MoveTableToDatabaseRequest;
+import com.google.cloud.metastore.v1alpha.MoveTableToDatabaseResponse;
import com.google.cloud.metastore.v1alpha.OperationMetadata;
+import com.google.cloud.metastore.v1alpha.QueryMetadataRequest;
+import com.google.cloud.metastore.v1alpha.QueryMetadataResponse;
+import com.google.cloud.metastore.v1alpha.RemoveIamPolicyRequest;
+import com.google.cloud.metastore.v1alpha.RemoveIamPolicyResponse;
import com.google.cloud.metastore.v1alpha.Restore;
import com.google.cloud.metastore.v1alpha.RestoreServiceRequest;
import com.google.cloud.metastore.v1alpha.Service;
@@ -169,6 +177,24 @@ public class DataprocMetastoreStubSettings extends StubSettings deleteBackupSettings;
private final OperationCallSettings
deleteBackupOperationSettings;
+ private final UnaryCallSettings
+ removeIamPolicySettings;
+ private final UnaryCallSettings queryMetadataSettings;
+ private final OperationCallSettings<
+ QueryMetadataRequest, QueryMetadataResponse, OperationMetadata>
+ queryMetadataOperationSettings;
+ private final UnaryCallSettings
+ moveTableToDatabaseSettings;
+ private final OperationCallSettings<
+ MoveTableToDatabaseRequest, MoveTableToDatabaseResponse, OperationMetadata>
+ moveTableToDatabaseOperationSettings;
+ private final UnaryCallSettings
+ alterMetadataResourceLocationSettings;
+ private final OperationCallSettings<
+ AlterMetadataResourceLocationRequest,
+ AlterMetadataResourceLocationResponse,
+ OperationMetadata>
+ alterMetadataResourceLocationOperationSettings;
private static final PagedListDescriptor
LIST_SERVICES_PAGE_STR_DESC =
@@ -470,6 +496,50 @@ public UnaryCallSettings deleteBackupSettings()
return deleteBackupOperationSettings;
}
+ /** Returns the object with the settings used for calls to removeIamPolicy. */
+ public UnaryCallSettings
+ removeIamPolicySettings() {
+ return removeIamPolicySettings;
+ }
+
+ /** Returns the object with the settings used for calls to queryMetadata. */
+ public UnaryCallSettings queryMetadataSettings() {
+ return queryMetadataSettings;
+ }
+
+ /** Returns the object with the settings used for calls to queryMetadata. */
+ public OperationCallSettings
+ queryMetadataOperationSettings() {
+ return queryMetadataOperationSettings;
+ }
+
+ /** Returns the object with the settings used for calls to moveTableToDatabase. */
+ public UnaryCallSettings moveTableToDatabaseSettings() {
+ return moveTableToDatabaseSettings;
+ }
+
+ /** Returns the object with the settings used for calls to moveTableToDatabase. */
+ public OperationCallSettings<
+ MoveTableToDatabaseRequest, MoveTableToDatabaseResponse, OperationMetadata>
+ moveTableToDatabaseOperationSettings() {
+ return moveTableToDatabaseOperationSettings;
+ }
+
+ /** Returns the object with the settings used for calls to alterMetadataResourceLocation. */
+ public UnaryCallSettings
+ alterMetadataResourceLocationSettings() {
+ return alterMetadataResourceLocationSettings;
+ }
+
+ /** Returns the object with the settings used for calls to alterMetadataResourceLocation. */
+ public OperationCallSettings<
+ AlterMetadataResourceLocationRequest,
+ AlterMetadataResourceLocationResponse,
+ OperationMetadata>
+ alterMetadataResourceLocationOperationSettings() {
+ return alterMetadataResourceLocationOperationSettings;
+ }
+
public DataprocMetastoreStub createStub() throws IOException {
if (getTransportChannelProvider()
.getTransportName()
@@ -602,6 +672,16 @@ protected DataprocMetastoreStubSettings(Builder settingsBuilder) throws IOExcept
createBackupOperationSettings = settingsBuilder.createBackupOperationSettings().build();
deleteBackupSettings = settingsBuilder.deleteBackupSettings().build();
deleteBackupOperationSettings = settingsBuilder.deleteBackupOperationSettings().build();
+ removeIamPolicySettings = settingsBuilder.removeIamPolicySettings().build();
+ queryMetadataSettings = settingsBuilder.queryMetadataSettings().build();
+ queryMetadataOperationSettings = settingsBuilder.queryMetadataOperationSettings().build();
+ moveTableToDatabaseSettings = settingsBuilder.moveTableToDatabaseSettings().build();
+ moveTableToDatabaseOperationSettings =
+ settingsBuilder.moveTableToDatabaseOperationSettings().build();
+ alterMetadataResourceLocationSettings =
+ settingsBuilder.alterMetadataResourceLocationSettings().build();
+ alterMetadataResourceLocationOperationSettings =
+ settingsBuilder.alterMetadataResourceLocationOperationSettings().build();
}
/** Builder for DataprocMetastoreStubSettings. */
@@ -656,6 +736,24 @@ public static class Builder extends StubSettings.Builder deleteBackupSettings;
private final OperationCallSettings.Builder
deleteBackupOperationSettings;
+ private final UnaryCallSettings.Builder
+ removeIamPolicySettings;
+ private final UnaryCallSettings.Builder queryMetadataSettings;
+ private final OperationCallSettings.Builder<
+ QueryMetadataRequest, QueryMetadataResponse, OperationMetadata>
+ queryMetadataOperationSettings;
+ private final UnaryCallSettings.Builder
+ moveTableToDatabaseSettings;
+ private final OperationCallSettings.Builder<
+ MoveTableToDatabaseRequest, MoveTableToDatabaseResponse, OperationMetadata>
+ moveTableToDatabaseOperationSettings;
+ private final UnaryCallSettings.Builder
+ alterMetadataResourceLocationSettings;
+ private final OperationCallSettings.Builder<
+ AlterMetadataResourceLocationRequest,
+ AlterMetadataResourceLocationResponse,
+ OperationMetadata>
+ alterMetadataResourceLocationOperationSettings;
private static final ImmutableMap>
RETRYABLE_CODE_DEFINITIONS;
@@ -729,6 +827,13 @@ protected Builder(ClientContext clientContext) {
createBackupOperationSettings = OperationCallSettings.newBuilder();
deleteBackupSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
deleteBackupOperationSettings = OperationCallSettings.newBuilder();
+ removeIamPolicySettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ queryMetadataSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ queryMetadataOperationSettings = OperationCallSettings.newBuilder();
+ moveTableToDatabaseSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ moveTableToDatabaseOperationSettings = OperationCallSettings.newBuilder();
+ alterMetadataResourceLocationSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ alterMetadataResourceLocationOperationSettings = OperationCallSettings.newBuilder();
unaryMethodSettingsBuilders =
ImmutableList.>of(
@@ -746,7 +851,11 @@ protected Builder(ClientContext clientContext) {
listBackupsSettings,
getBackupSettings,
createBackupSettings,
- deleteBackupSettings);
+ deleteBackupSettings,
+ removeIamPolicySettings,
+ queryMetadataSettings,
+ moveTableToDatabaseSettings,
+ alterMetadataResourceLocationSettings);
initDefaults(this);
}
@@ -779,6 +888,16 @@ protected Builder(DataprocMetastoreStubSettings settings) {
createBackupOperationSettings = settings.createBackupOperationSettings.toBuilder();
deleteBackupSettings = settings.deleteBackupSettings.toBuilder();
deleteBackupOperationSettings = settings.deleteBackupOperationSettings.toBuilder();
+ removeIamPolicySettings = settings.removeIamPolicySettings.toBuilder();
+ queryMetadataSettings = settings.queryMetadataSettings.toBuilder();
+ queryMetadataOperationSettings = settings.queryMetadataOperationSettings.toBuilder();
+ moveTableToDatabaseSettings = settings.moveTableToDatabaseSettings.toBuilder();
+ moveTableToDatabaseOperationSettings =
+ settings.moveTableToDatabaseOperationSettings.toBuilder();
+ alterMetadataResourceLocationSettings =
+ settings.alterMetadataResourceLocationSettings.toBuilder();
+ alterMetadataResourceLocationOperationSettings =
+ settings.alterMetadataResourceLocationOperationSettings.toBuilder();
unaryMethodSettingsBuilders =
ImmutableList.>of(
@@ -796,7 +915,11 @@ protected Builder(DataprocMetastoreStubSettings settings) {
listBackupsSettings,
getBackupSettings,
createBackupSettings,
- deleteBackupSettings);
+ deleteBackupSettings,
+ removeIamPolicySettings,
+ queryMetadataSettings,
+ moveTableToDatabaseSettings,
+ alterMetadataResourceLocationSettings);
}
private static Builder createDefault() {
@@ -901,6 +1024,26 @@ private static Builder initDefaults(Builder builder) {
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes"))
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params"));
+ builder
+ .removeIamPolicySettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_0_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_0_params"));
+
+ builder
+ .queryMetadataSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_0_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_0_params"));
+
+ builder
+ .moveTableToDatabaseSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_0_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_0_params"));
+
+ builder
+ .alterMetadataResourceLocationSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_0_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_0_params"));
+
builder
.createServiceOperationSettings()
.setInitialCallSettings(
@@ -1117,6 +1260,81 @@ private static Builder initDefaults(Builder builder) {
.setTotalTimeout(Duration.ofMillis(1500000L))
.build()));
+ builder
+ .queryMetadataOperationSettings()
+ .setInitialCallSettings(
+ UnaryCallSettings
+ .newUnaryCallSettingsBuilder()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_0_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_0_params"))
+ .build())
+ .setResponseTransformer(
+ ProtoOperationTransformers.ResponseTransformer.create(QueryMetadataResponse.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
+ .moveTableToDatabaseOperationSettings()
+ .setInitialCallSettings(
+ UnaryCallSettings
+ .newUnaryCallSettingsBuilder()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_0_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_0_params"))
+ .build())
+ .setResponseTransformer(
+ ProtoOperationTransformers.ResponseTransformer.create(
+ MoveTableToDatabaseResponse.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
+ .alterMetadataResourceLocationOperationSettings()
+ .setInitialCallSettings(
+ UnaryCallSettings
+ .
+ newUnaryCallSettingsBuilder()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_0_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_0_params"))
+ .build())
+ .setResponseTransformer(
+ ProtoOperationTransformers.ResponseTransformer.create(
+ AlterMetadataResourceLocationResponse.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;
}
@@ -1295,6 +1513,58 @@ public UnaryCallSettings.Builder deleteBackupSet
return deleteBackupOperationSettings;
}
+ /** Returns the builder for the settings used for calls to removeIamPolicy. */
+ public UnaryCallSettings.Builder
+ removeIamPolicySettings() {
+ return removeIamPolicySettings;
+ }
+
+ /** Returns the builder for the settings used for calls to queryMetadata. */
+ public UnaryCallSettings.Builder queryMetadataSettings() {
+ return queryMetadataSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to queryMetadata. */
+ @BetaApi(
+ "The surface for use by generated code is not stable yet and may change in the future.")
+ public OperationCallSettings.Builder<
+ QueryMetadataRequest, QueryMetadataResponse, OperationMetadata>
+ queryMetadataOperationSettings() {
+ return queryMetadataOperationSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to moveTableToDatabase. */
+ public UnaryCallSettings.Builder
+ moveTableToDatabaseSettings() {
+ return moveTableToDatabaseSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to moveTableToDatabase. */
+ @BetaApi(
+ "The surface for use by generated code is not stable yet and may change in the future.")
+ public OperationCallSettings.Builder<
+ MoveTableToDatabaseRequest, MoveTableToDatabaseResponse, OperationMetadata>
+ moveTableToDatabaseOperationSettings() {
+ return moveTableToDatabaseOperationSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to alterMetadataResourceLocation. */
+ public UnaryCallSettings.Builder
+ alterMetadataResourceLocationSettings() {
+ return alterMetadataResourceLocationSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to alterMetadataResourceLocation. */
+ @BetaApi(
+ "The surface for use by generated code is not stable yet and may change in the future.")
+ public OperationCallSettings.Builder<
+ AlterMetadataResourceLocationRequest,
+ AlterMetadataResourceLocationResponse,
+ OperationMetadata>
+ alterMetadataResourceLocationOperationSettings() {
+ return alterMetadataResourceLocationOperationSettings;
+ }
+
@Override
public DataprocMetastoreStubSettings build() throws IOException {
return new DataprocMetastoreStubSettings(this);
diff --git a/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1alpha/stub/GrpcDataprocMetastoreStub.java b/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1alpha/stub/GrpcDataprocMetastoreStub.java
index 2bf47774b3c8..51cef1e023d0 100644
--- a/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1alpha/stub/GrpcDataprocMetastoreStub.java
+++ b/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1alpha/stub/GrpcDataprocMetastoreStub.java
@@ -28,6 +28,8 @@
import com.google.api.gax.rpc.ClientContext;
import com.google.api.gax.rpc.OperationCallable;
import com.google.api.gax.rpc.UnaryCallable;
+import com.google.cloud.metastore.v1alpha.AlterMetadataResourceLocationRequest;
+import com.google.cloud.metastore.v1alpha.AlterMetadataResourceLocationResponse;
import com.google.cloud.metastore.v1alpha.Backup;
import com.google.cloud.metastore.v1alpha.CreateBackupRequest;
import com.google.cloud.metastore.v1alpha.CreateMetadataImportRequest;
@@ -46,7 +48,13 @@
import com.google.cloud.metastore.v1alpha.ListServicesResponse;
import com.google.cloud.metastore.v1alpha.MetadataExport;
import com.google.cloud.metastore.v1alpha.MetadataImport;
+import com.google.cloud.metastore.v1alpha.MoveTableToDatabaseRequest;
+import com.google.cloud.metastore.v1alpha.MoveTableToDatabaseResponse;
import com.google.cloud.metastore.v1alpha.OperationMetadata;
+import com.google.cloud.metastore.v1alpha.QueryMetadataRequest;
+import com.google.cloud.metastore.v1alpha.QueryMetadataResponse;
+import com.google.cloud.metastore.v1alpha.RemoveIamPolicyRequest;
+import com.google.cloud.metastore.v1alpha.RemoveIamPolicyResponse;
import com.google.cloud.metastore.v1alpha.Restore;
import com.google.cloud.metastore.v1alpha.RestoreServiceRequest;
import com.google.cloud.metastore.v1alpha.Service;
@@ -220,6 +228,49 @@ public class GrpcDataprocMetastoreStub extends DataprocMetastoreStub {
.setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance()))
.build();
+ private static final MethodDescriptor
+ removeIamPolicyMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName("google.cloud.metastore.v1alpha.DataprocMetastore/RemoveIamPolicy")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(RemoveIamPolicyRequest.getDefaultInstance()))
+ .setResponseMarshaller(
+ ProtoUtils.marshaller(RemoveIamPolicyResponse.getDefaultInstance()))
+ .build();
+
+ private static final MethodDescriptor
+ queryMetadataMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName("google.cloud.metastore.v1alpha.DataprocMetastore/QueryMetadata")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(QueryMetadataRequest.getDefaultInstance()))
+ .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance()))
+ .build();
+
+ private static final MethodDescriptor
+ moveTableToDatabaseMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(
+ "google.cloud.metastore.v1alpha.DataprocMetastore/MoveTableToDatabase")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(MoveTableToDatabaseRequest.getDefaultInstance()))
+ .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance()))
+ .build();
+
+ private static final MethodDescriptor
+ alterMetadataResourceLocationMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(
+ "google.cloud.metastore.v1alpha.DataprocMetastore/AlterMetadataResourceLocation")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(AlterMetadataResourceLocationRequest.getDefaultInstance()))
+ .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance()))
+ .build();
+
private final UnaryCallable listServicesCallable;
private final UnaryCallable
listServicesPagedCallable;
@@ -260,6 +311,22 @@ public class GrpcDataprocMetastoreStub extends DataprocMetastoreStub {
private final UnaryCallable deleteBackupCallable;
private final OperationCallable
deleteBackupOperationCallable;
+ private final UnaryCallable
+ removeIamPolicyCallable;
+ private final UnaryCallable queryMetadataCallable;
+ private final OperationCallable
+ queryMetadataOperationCallable;
+ private final UnaryCallable moveTableToDatabaseCallable;
+ private final OperationCallable<
+ MoveTableToDatabaseRequest, MoveTableToDatabaseResponse, OperationMetadata>
+ moveTableToDatabaseOperationCallable;
+ private final UnaryCallable
+ alterMetadataResourceLocationCallable;
+ private final OperationCallable<
+ AlterMetadataResourceLocationRequest,
+ AlterMetadataResourceLocationResponse,
+ OperationMetadata>
+ alterMetadataResourceLocationOperationCallable;
private final BackgroundResource backgroundResources;
private final GrpcOperationsStub operationsStub;
@@ -458,6 +525,48 @@ protected GrpcDataprocMetastoreStub(
return params.build();
})
.build();
+ GrpcCallSettings
+ removeIamPolicyTransportSettings =
+ GrpcCallSettings.newBuilder()
+ .setMethodDescriptor(removeIamPolicyMethodDescriptor)
+ .setParamsExtractor(
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("resource", String.valueOf(request.getResource()));
+ return params.build();
+ })
+ .build();
+ GrpcCallSettings queryMetadataTransportSettings =
+ GrpcCallSettings.newBuilder()
+ .setMethodDescriptor(queryMetadataMethodDescriptor)
+ .setParamsExtractor(
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("service", String.valueOf(request.getService()));
+ return params.build();
+ })
+ .build();
+ GrpcCallSettings moveTableToDatabaseTransportSettings =
+ GrpcCallSettings.newBuilder()
+ .setMethodDescriptor(moveTableToDatabaseMethodDescriptor)
+ .setParamsExtractor(
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("service", String.valueOf(request.getService()));
+ return params.build();
+ })
+ .build();
+ GrpcCallSettings
+ alterMetadataResourceLocationTransportSettings =
+ GrpcCallSettings.newBuilder()
+ .setMethodDescriptor(alterMetadataResourceLocationMethodDescriptor)
+ .setParamsExtractor(
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("service", String.valueOf(request.getService()));
+ return params.build();
+ })
+ .build();
this.listServicesCallable =
callableFactory.createUnaryCallable(
@@ -577,6 +686,40 @@ protected GrpcDataprocMetastoreStub(
settings.deleteBackupOperationSettings(),
clientContext,
operationsStub);
+ this.removeIamPolicyCallable =
+ callableFactory.createUnaryCallable(
+ removeIamPolicyTransportSettings, settings.removeIamPolicySettings(), clientContext);
+ this.queryMetadataCallable =
+ callableFactory.createUnaryCallable(
+ queryMetadataTransportSettings, settings.queryMetadataSettings(), clientContext);
+ this.queryMetadataOperationCallable =
+ callableFactory.createOperationCallable(
+ queryMetadataTransportSettings,
+ settings.queryMetadataOperationSettings(),
+ clientContext,
+ operationsStub);
+ this.moveTableToDatabaseCallable =
+ callableFactory.createUnaryCallable(
+ moveTableToDatabaseTransportSettings,
+ settings.moveTableToDatabaseSettings(),
+ clientContext);
+ this.moveTableToDatabaseOperationCallable =
+ callableFactory.createOperationCallable(
+ moveTableToDatabaseTransportSettings,
+ settings.moveTableToDatabaseOperationSettings(),
+ clientContext,
+ operationsStub);
+ this.alterMetadataResourceLocationCallable =
+ callableFactory.createUnaryCallable(
+ alterMetadataResourceLocationTransportSettings,
+ settings.alterMetadataResourceLocationSettings(),
+ clientContext);
+ this.alterMetadataResourceLocationOperationCallable =
+ callableFactory.createOperationCallable(
+ alterMetadataResourceLocationTransportSettings,
+ settings.alterMetadataResourceLocationOperationSettings(),
+ clientContext,
+ operationsStub);
this.backgroundResources =
new BackgroundResourceAggregation(clientContext.getBackgroundResources());
@@ -732,6 +875,49 @@ public UnaryCallable deleteBackupCallable() {
return deleteBackupOperationCallable;
}
+ @Override
+ public UnaryCallable removeIamPolicyCallable() {
+ return removeIamPolicyCallable;
+ }
+
+ @Override
+ public UnaryCallable queryMetadataCallable() {
+ return queryMetadataCallable;
+ }
+
+ @Override
+ public OperationCallable
+ queryMetadataOperationCallable() {
+ return queryMetadataOperationCallable;
+ }
+
+ @Override
+ public UnaryCallable moveTableToDatabaseCallable() {
+ return moveTableToDatabaseCallable;
+ }
+
+ @Override
+ public OperationCallable<
+ MoveTableToDatabaseRequest, MoveTableToDatabaseResponse, OperationMetadata>
+ moveTableToDatabaseOperationCallable() {
+ return moveTableToDatabaseOperationCallable;
+ }
+
+ @Override
+ public UnaryCallable
+ alterMetadataResourceLocationCallable() {
+ return alterMetadataResourceLocationCallable;
+ }
+
+ @Override
+ public OperationCallable<
+ AlterMetadataResourceLocationRequest,
+ AlterMetadataResourceLocationResponse,
+ OperationMetadata>
+ alterMetadataResourceLocationOperationCallable() {
+ return alterMetadataResourceLocationOperationCallable;
+ }
+
@Override
public final void close() {
try {
diff --git a/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1alpha/stub/HttpJsonDataprocMetastoreStub.java b/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1alpha/stub/HttpJsonDataprocMetastoreStub.java
index a3843e4be020..c6a4f2d432b4 100644
--- a/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1alpha/stub/HttpJsonDataprocMetastoreStub.java
+++ b/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1alpha/stub/HttpJsonDataprocMetastoreStub.java
@@ -35,6 +35,8 @@
import com.google.api.gax.rpc.ClientContext;
import com.google.api.gax.rpc.OperationCallable;
import com.google.api.gax.rpc.UnaryCallable;
+import com.google.cloud.metastore.v1alpha.AlterMetadataResourceLocationRequest;
+import com.google.cloud.metastore.v1alpha.AlterMetadataResourceLocationResponse;
import com.google.cloud.metastore.v1alpha.Backup;
import com.google.cloud.metastore.v1alpha.CreateBackupRequest;
import com.google.cloud.metastore.v1alpha.CreateMetadataImportRequest;
@@ -53,7 +55,13 @@
import com.google.cloud.metastore.v1alpha.ListServicesResponse;
import com.google.cloud.metastore.v1alpha.MetadataExport;
import com.google.cloud.metastore.v1alpha.MetadataImport;
+import com.google.cloud.metastore.v1alpha.MoveTableToDatabaseRequest;
+import com.google.cloud.metastore.v1alpha.MoveTableToDatabaseResponse;
import com.google.cloud.metastore.v1alpha.OperationMetadata;
+import com.google.cloud.metastore.v1alpha.QueryMetadataRequest;
+import com.google.cloud.metastore.v1alpha.QueryMetadataResponse;
+import com.google.cloud.metastore.v1alpha.RemoveIamPolicyRequest;
+import com.google.cloud.metastore.v1alpha.RemoveIamPolicyResponse;
import com.google.cloud.metastore.v1alpha.Restore;
import com.google.cloud.metastore.v1alpha.RestoreServiceRequest;
import com.google.cloud.metastore.v1alpha.Service;
@@ -83,11 +91,14 @@ public class HttpJsonDataprocMetastoreStub extends DataprocMetastoreStub {
TypeRegistry.newBuilder()
.add(Service.getDescriptor())
.add(Empty.getDescriptor())
+ .add(AlterMetadataResourceLocationResponse.getDescriptor())
.add(MetadataImport.getDescriptor())
+ .add(MoveTableToDatabaseResponse.getDescriptor())
.add(OperationMetadata.getDescriptor())
.add(Backup.getDescriptor())
.add(MetadataExport.getDescriptor())
.add(Restore.getDescriptor())
+ .add(QueryMetadataResponse.getDescriptor())
.build();
private static final ApiMethodDescriptor
@@ -679,6 +690,165 @@ public class HttpJsonDataprocMetastoreStub extends DataprocMetastoreStub {
HttpJsonOperationSnapshot.create(response))
.build();
+ private static final ApiMethodDescriptor
+ removeIamPolicyMethodDescriptor =
+ ApiMethodDescriptor.newBuilder()
+ .setFullMethodName("google.cloud.metastore.v1alpha.DataprocMetastore/RemoveIamPolicy")
+ .setHttpMethod("POST")
+ .setType(ApiMethodDescriptor.MethodType.UNARY)
+ .setRequestFormatter(
+ ProtoMessageRequestFormatter.newBuilder()
+ .setPath(
+ "/v1alpha/{resource=projects/*/locations/*/services/*/**}:removeIamPolicy",
+ request -> {
+ Map fields = new HashMap<>();
+ ProtoRestSerializer serializer =
+ ProtoRestSerializer.create();
+ serializer.putPathParam(fields, "resource", request.getResource());
+ return fields;
+ })
+ .setQueryParamsExtractor(
+ request -> {
+ Map> fields = new HashMap<>();
+ ProtoRestSerializer serializer =
+ ProtoRestSerializer.create();
+ serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int");
+ return fields;
+ })
+ .setRequestBodyExtractor(
+ request ->
+ ProtoRestSerializer.create()
+ .toBody("*", request.toBuilder().clearResource().build(), true))
+ .build())
+ .setResponseParser(
+ ProtoMessageResponseParser.newBuilder()
+ .setDefaultInstance(RemoveIamPolicyResponse.getDefaultInstance())
+ .setDefaultTypeRegistry(typeRegistry)
+ .build())
+ .build();
+
+ private static final ApiMethodDescriptor
+ queryMetadataMethodDescriptor =
+ ApiMethodDescriptor.newBuilder()
+ .setFullMethodName("google.cloud.metastore.v1alpha.DataprocMetastore/QueryMetadata")
+ .setHttpMethod("POST")
+ .setType(ApiMethodDescriptor.MethodType.UNARY)
+ .setRequestFormatter(
+ ProtoMessageRequestFormatter.newBuilder()
+ .setPath(
+ "/v1alpha/{service=projects/*/locations/*/services/*}:queryMetadata",
+ request -> {
+ Map fields = new HashMap<>();
+ ProtoRestSerializer serializer =
+ ProtoRestSerializer.create();
+ serializer.putPathParam(fields, "service", request.getService());
+ return fields;
+ })
+ .setQueryParamsExtractor(
+ request -> {
+ Map> fields = new HashMap<>();
+ ProtoRestSerializer serializer =
+ ProtoRestSerializer.create();
+ serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int");
+ return fields;
+ })
+ .setRequestBodyExtractor(
+ request ->
+ ProtoRestSerializer.create()
+ .toBody("*", request.toBuilder().clearService().build(), true))
+ .build())
+ .setResponseParser(
+ ProtoMessageResponseParser.newBuilder()
+ .setDefaultInstance(Operation.getDefaultInstance())
+ .setDefaultTypeRegistry(typeRegistry)
+ .build())
+ .setOperationSnapshotFactory(
+ (QueryMetadataRequest request, Operation response) ->
+ HttpJsonOperationSnapshot.create(response))
+ .build();
+
+ private static final ApiMethodDescriptor
+ moveTableToDatabaseMethodDescriptor =
+ ApiMethodDescriptor.newBuilder()
+ .setFullMethodName(
+ "google.cloud.metastore.v1alpha.DataprocMetastore/MoveTableToDatabase")
+ .setHttpMethod("POST")
+ .setType(ApiMethodDescriptor.MethodType.UNARY)
+ .setRequestFormatter(
+ ProtoMessageRequestFormatter.newBuilder()
+ .setPath(
+ "/v1alpha/{service=projects/*/locations/*/services/*}:moveTableToDatabase",
+ request -> {
+ Map fields = new HashMap<>();
+ ProtoRestSerializer serializer =
+ ProtoRestSerializer.create();
+ serializer.putPathParam(fields, "service", request.getService());
+ return fields;
+ })
+ .setQueryParamsExtractor(
+ request -> {
+ Map> fields = new HashMap<>();
+ ProtoRestSerializer serializer =
+ ProtoRestSerializer.create();
+ serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int");
+ return fields;
+ })
+ .setRequestBodyExtractor(
+ request ->
+ ProtoRestSerializer.create()
+ .toBody("*", request.toBuilder().clearService().build(), true))
+ .build())
+ .setResponseParser(
+ ProtoMessageResponseParser.newBuilder()
+ .setDefaultInstance(Operation.getDefaultInstance())
+ .setDefaultTypeRegistry(typeRegistry)
+ .build())
+ .setOperationSnapshotFactory(
+ (MoveTableToDatabaseRequest request, Operation response) ->
+ HttpJsonOperationSnapshot.create(response))
+ .build();
+
+ private static final ApiMethodDescriptor
+ alterMetadataResourceLocationMethodDescriptor =
+ ApiMethodDescriptor.newBuilder()
+ .setFullMethodName(
+ "google.cloud.metastore.v1alpha.DataprocMetastore/AlterMetadataResourceLocation")
+ .setHttpMethod("POST")
+ .setType(ApiMethodDescriptor.MethodType.UNARY)
+ .setRequestFormatter(
+ ProtoMessageRequestFormatter.newBuilder()
+ .setPath(
+ "/v1alpha/{service=projects/*/locations/*/services/*}:alterLocation",
+ request -> {
+ Map fields = new HashMap<>();
+ ProtoRestSerializer serializer =
+ ProtoRestSerializer.create();
+ serializer.putPathParam(fields, "service", request.getService());
+ return fields;
+ })
+ .setQueryParamsExtractor(
+ request -> {
+ Map> fields = new HashMap<>();
+ ProtoRestSerializer serializer =
+ ProtoRestSerializer.create();
+ serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int");
+ return fields;
+ })
+ .setRequestBodyExtractor(
+ request ->
+ ProtoRestSerializer.create()
+ .toBody("*", request.toBuilder().clearService().build(), true))
+ .build())
+ .setResponseParser(
+ ProtoMessageResponseParser.newBuilder()
+ .setDefaultInstance(Operation.getDefaultInstance())
+ .setDefaultTypeRegistry(typeRegistry)
+ .build())
+ .setOperationSnapshotFactory(
+ (AlterMetadataResourceLocationRequest request, Operation response) ->
+ HttpJsonOperationSnapshot.create(response))
+ .build();
+
private final UnaryCallable listServicesCallable;
private final UnaryCallable
listServicesPagedCallable;
@@ -719,6 +889,22 @@ public class HttpJsonDataprocMetastoreStub extends DataprocMetastoreStub {
private final UnaryCallable deleteBackupCallable;
private final OperationCallable
deleteBackupOperationCallable;
+ private final UnaryCallable
+ removeIamPolicyCallable;
+ private final UnaryCallable queryMetadataCallable;
+ private final OperationCallable
+ queryMetadataOperationCallable;
+ private final UnaryCallable moveTableToDatabaseCallable;
+ private final OperationCallable<
+ MoveTableToDatabaseRequest, MoveTableToDatabaseResponse, OperationMetadata>
+ moveTableToDatabaseOperationCallable;
+ private final UnaryCallable
+ alterMetadataResourceLocationCallable;
+ private final OperationCallable<
+ AlterMetadataResourceLocationRequest,
+ AlterMetadataResourceLocationResponse,
+ OperationMetadata>
+ alterMetadataResourceLocationOperationCallable;
private final BackgroundResource backgroundResources;
private final HttpJsonOperationsStub httpJsonOperationsStub;
@@ -845,6 +1031,29 @@ protected HttpJsonDataprocMetastoreStub(
.setMethodDescriptor(deleteBackupMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
+ HttpJsonCallSettings
+ removeIamPolicyTransportSettings =
+ HttpJsonCallSettings.newBuilder()
+ .setMethodDescriptor(removeIamPolicyMethodDescriptor)
+ .setTypeRegistry(typeRegistry)
+ .build();
+ HttpJsonCallSettings queryMetadataTransportSettings =
+ HttpJsonCallSettings.newBuilder()
+ .setMethodDescriptor(queryMetadataMethodDescriptor)
+ .setTypeRegistry(typeRegistry)
+ .build();
+ HttpJsonCallSettings
+ moveTableToDatabaseTransportSettings =
+ HttpJsonCallSettings.newBuilder()
+ .setMethodDescriptor(moveTableToDatabaseMethodDescriptor)
+ .setTypeRegistry(typeRegistry)
+ .build();
+ HttpJsonCallSettings
+ alterMetadataResourceLocationTransportSettings =
+ HttpJsonCallSettings.newBuilder()
+ .setMethodDescriptor(alterMetadataResourceLocationMethodDescriptor)
+ .setTypeRegistry(typeRegistry)
+ .build();
this.listServicesCallable =
callableFactory.createUnaryCallable(
@@ -964,6 +1173,40 @@ protected HttpJsonDataprocMetastoreStub(
settings.deleteBackupOperationSettings(),
clientContext,
httpJsonOperationsStub);
+ this.removeIamPolicyCallable =
+ callableFactory.createUnaryCallable(
+ removeIamPolicyTransportSettings, settings.removeIamPolicySettings(), clientContext);
+ this.queryMetadataCallable =
+ callableFactory.createUnaryCallable(
+ queryMetadataTransportSettings, settings.queryMetadataSettings(), clientContext);
+ this.queryMetadataOperationCallable =
+ callableFactory.createOperationCallable(
+ queryMetadataTransportSettings,
+ settings.queryMetadataOperationSettings(),
+ clientContext,
+ httpJsonOperationsStub);
+ this.moveTableToDatabaseCallable =
+ callableFactory.createUnaryCallable(
+ moveTableToDatabaseTransportSettings,
+ settings.moveTableToDatabaseSettings(),
+ clientContext);
+ this.moveTableToDatabaseOperationCallable =
+ callableFactory.createOperationCallable(
+ moveTableToDatabaseTransportSettings,
+ settings.moveTableToDatabaseOperationSettings(),
+ clientContext,
+ httpJsonOperationsStub);
+ this.alterMetadataResourceLocationCallable =
+ callableFactory.createUnaryCallable(
+ alterMetadataResourceLocationTransportSettings,
+ settings.alterMetadataResourceLocationSettings(),
+ clientContext);
+ this.alterMetadataResourceLocationOperationCallable =
+ callableFactory.createOperationCallable(
+ alterMetadataResourceLocationTransportSettings,
+ settings.alterMetadataResourceLocationOperationSettings(),
+ clientContext,
+ httpJsonOperationsStub);
this.backgroundResources =
new BackgroundResourceAggregation(clientContext.getBackgroundResources());
@@ -987,6 +1230,10 @@ public static List getMethodDescriptors() {
methodDescriptors.add(getBackupMethodDescriptor);
methodDescriptors.add(createBackupMethodDescriptor);
methodDescriptors.add(deleteBackupMethodDescriptor);
+ methodDescriptors.add(removeIamPolicyMethodDescriptor);
+ methodDescriptors.add(queryMetadataMethodDescriptor);
+ methodDescriptors.add(moveTableToDatabaseMethodDescriptor);
+ methodDescriptors.add(alterMetadataResourceLocationMethodDescriptor);
return methodDescriptors;
}
@@ -1140,6 +1387,49 @@ public UnaryCallable deleteBackupCallable() {
return deleteBackupOperationCallable;
}
+ @Override
+ public UnaryCallable removeIamPolicyCallable() {
+ return removeIamPolicyCallable;
+ }
+
+ @Override
+ public UnaryCallable queryMetadataCallable() {
+ return queryMetadataCallable;
+ }
+
+ @Override
+ public OperationCallable
+ queryMetadataOperationCallable() {
+ return queryMetadataOperationCallable;
+ }
+
+ @Override
+ public UnaryCallable moveTableToDatabaseCallable() {
+ return moveTableToDatabaseCallable;
+ }
+
+ @Override
+ public OperationCallable<
+ MoveTableToDatabaseRequest, MoveTableToDatabaseResponse, OperationMetadata>
+ moveTableToDatabaseOperationCallable() {
+ return moveTableToDatabaseOperationCallable;
+ }
+
+ @Override
+ public UnaryCallable
+ alterMetadataResourceLocationCallable() {
+ return alterMetadataResourceLocationCallable;
+ }
+
+ @Override
+ public OperationCallable<
+ AlterMetadataResourceLocationRequest,
+ AlterMetadataResourceLocationResponse,
+ OperationMetadata>
+ alterMetadataResourceLocationOperationCallable() {
+ return alterMetadataResourceLocationOperationCallable;
+ }
+
@Override
public final void close() {
try {
diff --git a/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1beta/DataprocMetastoreClient.java b/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1beta/DataprocMetastoreClient.java
index 7e8454ba17a2..becf982a4d53 100644
--- a/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1beta/DataprocMetastoreClient.java
+++ b/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1beta/DataprocMetastoreClient.java
@@ -2527,6 +2527,358 @@ public final UnaryCallable deleteBackupCallable(
return stub.deleteBackupCallable();
}
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Removes the attached IAM policies for a resource
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * RemoveIamPolicyRequest request =
+ * RemoveIamPolicyRequest.newBuilder()
+ * .setResource(
+ * BackupName.of("[PROJECT]", "[LOCATION]", "[SERVICE]", "[BACKUP]").toString())
+ * .setAsynchronous(true)
+ * .build();
+ * RemoveIamPolicyResponse response = dataprocMetastoreClient.removeIamPolicy(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 RemoveIamPolicyResponse removeIamPolicy(RemoveIamPolicyRequest request) {
+ return removeIamPolicyCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Removes the attached IAM policies for a resource
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * RemoveIamPolicyRequest request =
+ * RemoveIamPolicyRequest.newBuilder()
+ * .setResource(
+ * BackupName.of("[PROJECT]", "[LOCATION]", "[SERVICE]", "[BACKUP]").toString())
+ * .setAsynchronous(true)
+ * .build();
+ * ApiFuture future =
+ * dataprocMetastoreClient.removeIamPolicyCallable().futureCall(request);
+ * // Do something.
+ * RemoveIamPolicyResponse response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable
+ removeIamPolicyCallable() {
+ return stub.removeIamPolicyCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Query DPMS metadata.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * QueryMetadataRequest request =
+ * QueryMetadataRequest.newBuilder()
+ * .setService(ServiceName.of("[PROJECT]", "[LOCATION]", "[SERVICE]").toString())
+ * .setQuery("query107944136")
+ * .build();
+ * QueryMetadataResponse response = dataprocMetastoreClient.queryMetadataAsync(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 queryMetadataAsync(
+ QueryMetadataRequest request) {
+ return queryMetadataOperationCallable().futureCall(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Query DPMS metadata.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * QueryMetadataRequest request =
+ * QueryMetadataRequest.newBuilder()
+ * .setService(ServiceName.of("[PROJECT]", "[LOCATION]", "[SERVICE]").toString())
+ * .setQuery("query107944136")
+ * .build();
+ * OperationFuture future =
+ * dataprocMetastoreClient.queryMetadataOperationCallable().futureCall(request);
+ * // Do something.
+ * QueryMetadataResponse response = future.get();
+ * }
+ * }
+ */
+ public final OperationCallable
+ queryMetadataOperationCallable() {
+ return stub.queryMetadataOperationCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Query DPMS metadata.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * QueryMetadataRequest request =
+ * QueryMetadataRequest.newBuilder()
+ * .setService(ServiceName.of("[PROJECT]", "[LOCATION]", "[SERVICE]").toString())
+ * .setQuery("query107944136")
+ * .build();
+ * ApiFuture future =
+ * dataprocMetastoreClient.queryMetadataCallable().futureCall(request);
+ * // Do something.
+ * Operation response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable queryMetadataCallable() {
+ return stub.queryMetadataCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Move a table to another database.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * MoveTableToDatabaseRequest request =
+ * MoveTableToDatabaseRequest.newBuilder()
+ * .setService(ServiceName.of("[PROJECT]", "[LOCATION]", "[SERVICE]").toString())
+ * .setTableName("tableName-1988717703")
+ * .setDbName("dbName-1339126743")
+ * .setDestinationDbName("destinationDbName-2077361705")
+ * .build();
+ * MoveTableToDatabaseResponse response =
+ * dataprocMetastoreClient.moveTableToDatabaseAsync(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
+ moveTableToDatabaseAsync(MoveTableToDatabaseRequest request) {
+ return moveTableToDatabaseOperationCallable().futureCall(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Move a table to another database.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * MoveTableToDatabaseRequest request =
+ * MoveTableToDatabaseRequest.newBuilder()
+ * .setService(ServiceName.of("[PROJECT]", "[LOCATION]", "[SERVICE]").toString())
+ * .setTableName("tableName-1988717703")
+ * .setDbName("dbName-1339126743")
+ * .setDestinationDbName("destinationDbName-2077361705")
+ * .build();
+ * OperationFuture future =
+ * dataprocMetastoreClient.moveTableToDatabaseOperationCallable().futureCall(request);
+ * // Do something.
+ * MoveTableToDatabaseResponse response = future.get();
+ * }
+ * }
+ */
+ public final OperationCallable<
+ MoveTableToDatabaseRequest, MoveTableToDatabaseResponse, OperationMetadata>
+ moveTableToDatabaseOperationCallable() {
+ return stub.moveTableToDatabaseOperationCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Move a table to another database.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * MoveTableToDatabaseRequest request =
+ * MoveTableToDatabaseRequest.newBuilder()
+ * .setService(ServiceName.of("[PROJECT]", "[LOCATION]", "[SERVICE]").toString())
+ * .setTableName("tableName-1988717703")
+ * .setDbName("dbName-1339126743")
+ * .setDestinationDbName("destinationDbName-2077361705")
+ * .build();
+ * ApiFuture future =
+ * dataprocMetastoreClient.moveTableToDatabaseCallable().futureCall(request);
+ * // Do something.
+ * Operation response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable moveTableToDatabaseCallable() {
+ return stub.moveTableToDatabaseCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Alter metadata resource location. The metadata resource can be a database, table, or partition.
+ * This functionality only updates the parent directory for the respective metadata resource and
+ * does not transfer any existing data to the new location.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * AlterMetadataResourceLocationRequest request =
+ * AlterMetadataResourceLocationRequest.newBuilder()
+ * .setService(ServiceName.of("[PROJECT]", "[LOCATION]", "[SERVICE]").toString())
+ * .setResourceName("resourceName-384566343")
+ * .setLocationUri("locationUri552310135")
+ * .build();
+ * AlterMetadataResourceLocationResponse response =
+ * dataprocMetastoreClient.alterMetadataResourceLocationAsync(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
+ alterMetadataResourceLocationAsync(AlterMetadataResourceLocationRequest request) {
+ return alterMetadataResourceLocationOperationCallable().futureCall(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Alter metadata resource location. The metadata resource can be a database, table, or partition.
+ * This functionality only updates the parent directory for the respective metadata resource and
+ * does not transfer any existing data to the new location.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * AlterMetadataResourceLocationRequest request =
+ * AlterMetadataResourceLocationRequest.newBuilder()
+ * .setService(ServiceName.of("[PROJECT]", "[LOCATION]", "[SERVICE]").toString())
+ * .setResourceName("resourceName-384566343")
+ * .setLocationUri("locationUri552310135")
+ * .build();
+ * OperationFuture future =
+ * dataprocMetastoreClient
+ * .alterMetadataResourceLocationOperationCallable()
+ * .futureCall(request);
+ * // Do something.
+ * AlterMetadataResourceLocationResponse response = future.get();
+ * }
+ * }
+ */
+ public final OperationCallable<
+ AlterMetadataResourceLocationRequest,
+ AlterMetadataResourceLocationResponse,
+ OperationMetadata>
+ alterMetadataResourceLocationOperationCallable() {
+ return stub.alterMetadataResourceLocationOperationCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Alter metadata resource location. The metadata resource can be a database, table, or partition.
+ * This functionality only updates the parent directory for the respective metadata resource and
+ * does not transfer any existing data to the new location.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (DataprocMetastoreClient dataprocMetastoreClient = DataprocMetastoreClient.create()) {
+ * AlterMetadataResourceLocationRequest request =
+ * AlterMetadataResourceLocationRequest.newBuilder()
+ * .setService(ServiceName.of("[PROJECT]", "[LOCATION]", "[SERVICE]").toString())
+ * .setResourceName("resourceName-384566343")
+ * .setLocationUri("locationUri552310135")
+ * .build();
+ * ApiFuture future =
+ * dataprocMetastoreClient.alterMetadataResourceLocationCallable().futureCall(request);
+ * // Do something.
+ * Operation response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable
+ alterMetadataResourceLocationCallable() {
+ return stub.alterMetadataResourceLocationCallable();
+ }
+
@Override
public final void close() {
stub.close();
diff --git a/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1beta/DataprocMetastoreSettings.java b/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1beta/DataprocMetastoreSettings.java
index d14def4d8b16..4221a77c92aa 100644
--- a/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1beta/DataprocMetastoreSettings.java
+++ b/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1beta/DataprocMetastoreSettings.java
@@ -213,6 +213,53 @@ public UnaryCallSettings deleteBackupSettings()
return ((DataprocMetastoreStubSettings) getStubSettings()).deleteBackupOperationSettings();
}
+ /** Returns the object with the settings used for calls to removeIamPolicy. */
+ public UnaryCallSettings
+ removeIamPolicySettings() {
+ return ((DataprocMetastoreStubSettings) getStubSettings()).removeIamPolicySettings();
+ }
+
+ /** Returns the object with the settings used for calls to queryMetadata. */
+ public UnaryCallSettings queryMetadataSettings() {
+ return ((DataprocMetastoreStubSettings) getStubSettings()).queryMetadataSettings();
+ }
+
+ /** Returns the object with the settings used for calls to queryMetadata. */
+ public OperationCallSettings
+ queryMetadataOperationSettings() {
+ return ((DataprocMetastoreStubSettings) getStubSettings()).queryMetadataOperationSettings();
+ }
+
+ /** Returns the object with the settings used for calls to moveTableToDatabase. */
+ public UnaryCallSettings moveTableToDatabaseSettings() {
+ return ((DataprocMetastoreStubSettings) getStubSettings()).moveTableToDatabaseSettings();
+ }
+
+ /** Returns the object with the settings used for calls to moveTableToDatabase. */
+ public OperationCallSettings<
+ MoveTableToDatabaseRequest, MoveTableToDatabaseResponse, OperationMetadata>
+ moveTableToDatabaseOperationSettings() {
+ return ((DataprocMetastoreStubSettings) getStubSettings())
+ .moveTableToDatabaseOperationSettings();
+ }
+
+ /** Returns the object with the settings used for calls to alterMetadataResourceLocation. */
+ public UnaryCallSettings
+ alterMetadataResourceLocationSettings() {
+ return ((DataprocMetastoreStubSettings) getStubSettings())
+ .alterMetadataResourceLocationSettings();
+ }
+
+ /** Returns the object with the settings used for calls to alterMetadataResourceLocation. */
+ public OperationCallSettings<
+ AlterMetadataResourceLocationRequest,
+ AlterMetadataResourceLocationResponse,
+ OperationMetadata>
+ alterMetadataResourceLocationOperationSettings() {
+ return ((DataprocMetastoreStubSettings) getStubSettings())
+ .alterMetadataResourceLocationOperationSettings();
+ }
+
public static final DataprocMetastoreSettings create(DataprocMetastoreStubSettings stub)
throws IOException {
return new DataprocMetastoreSettings.Builder(stub.toBuilder()).build();
@@ -470,6 +517,52 @@ public UnaryCallSettings.Builder deleteBackupSet
return getStubSettingsBuilder().deleteBackupOperationSettings();
}
+ /** Returns the builder for the settings used for calls to removeIamPolicy. */
+ public UnaryCallSettings.Builder
+ removeIamPolicySettings() {
+ return getStubSettingsBuilder().removeIamPolicySettings();
+ }
+
+ /** Returns the builder for the settings used for calls to queryMetadata. */
+ public UnaryCallSettings.Builder queryMetadataSettings() {
+ return getStubSettingsBuilder().queryMetadataSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to queryMetadata. */
+ public OperationCallSettings.Builder<
+ QueryMetadataRequest, QueryMetadataResponse, OperationMetadata>
+ queryMetadataOperationSettings() {
+ return getStubSettingsBuilder().queryMetadataOperationSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to moveTableToDatabase. */
+ public UnaryCallSettings.Builder
+ moveTableToDatabaseSettings() {
+ return getStubSettingsBuilder().moveTableToDatabaseSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to moveTableToDatabase. */
+ public OperationCallSettings.Builder<
+ MoveTableToDatabaseRequest, MoveTableToDatabaseResponse, OperationMetadata>
+ moveTableToDatabaseOperationSettings() {
+ return getStubSettingsBuilder().moveTableToDatabaseOperationSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to alterMetadataResourceLocation. */
+ public UnaryCallSettings.Builder
+ alterMetadataResourceLocationSettings() {
+ return getStubSettingsBuilder().alterMetadataResourceLocationSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to alterMetadataResourceLocation. */
+ public OperationCallSettings.Builder<
+ AlterMetadataResourceLocationRequest,
+ AlterMetadataResourceLocationResponse,
+ OperationMetadata>
+ alterMetadataResourceLocationOperationSettings() {
+ return getStubSettingsBuilder().alterMetadataResourceLocationOperationSettings();
+ }
+
@Override
public DataprocMetastoreSettings build() throws IOException {
return new DataprocMetastoreSettings(this);
diff --git a/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1beta/gapic_metadata.json b/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1beta/gapic_metadata.json
index 65163f1c6dcf..9a99c98e2b68 100644
--- a/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1beta/gapic_metadata.json
+++ b/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1beta/gapic_metadata.json
@@ -10,6 +10,9 @@
"grpc": {
"libraryClient": "DataprocMetastoreClient",
"rpcs": {
+ "AlterMetadataResourceLocation": {
+ "methods": ["alterMetadataResourceLocationAsync", "alterMetadataResourceLocationOperationCallable", "alterMetadataResourceLocationCallable"]
+ },
"CreateBackup": {
"methods": ["createBackupAsync", "createBackupAsync", "createBackupAsync", "createBackupOperationCallable", "createBackupCallable"]
},
@@ -46,6 +49,15 @@
"ListServices": {
"methods": ["listServices", "listServices", "listServices", "listServicesPagedCallable", "listServicesCallable"]
},
+ "MoveTableToDatabase": {
+ "methods": ["moveTableToDatabaseAsync", "moveTableToDatabaseOperationCallable", "moveTableToDatabaseCallable"]
+ },
+ "QueryMetadata": {
+ "methods": ["queryMetadataAsync", "queryMetadataOperationCallable", "queryMetadataCallable"]
+ },
+ "RemoveIamPolicy": {
+ "methods": ["removeIamPolicy", "removeIamPolicyCallable"]
+ },
"RestoreService": {
"methods": ["restoreServiceAsync", "restoreServiceAsync", "restoreServiceAsync", "restoreServiceAsync", "restoreServiceAsync", "restoreServiceOperationCallable", "restoreServiceCallable"]
},
diff --git a/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1beta/stub/DataprocMetastoreStub.java b/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1beta/stub/DataprocMetastoreStub.java
index d6b6b7bea912..c034d5167a90 100644
--- a/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1beta/stub/DataprocMetastoreStub.java
+++ b/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1beta/stub/DataprocMetastoreStub.java
@@ -24,6 +24,8 @@
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.v1beta.AlterMetadataResourceLocationRequest;
+import com.google.cloud.metastore.v1beta.AlterMetadataResourceLocationResponse;
import com.google.cloud.metastore.v1beta.Backup;
import com.google.cloud.metastore.v1beta.CreateBackupRequest;
import com.google.cloud.metastore.v1beta.CreateMetadataImportRequest;
@@ -42,7 +44,13 @@
import com.google.cloud.metastore.v1beta.ListServicesResponse;
import com.google.cloud.metastore.v1beta.MetadataExport;
import com.google.cloud.metastore.v1beta.MetadataImport;
+import com.google.cloud.metastore.v1beta.MoveTableToDatabaseRequest;
+import com.google.cloud.metastore.v1beta.MoveTableToDatabaseResponse;
import com.google.cloud.metastore.v1beta.OperationMetadata;
+import com.google.cloud.metastore.v1beta.QueryMetadataRequest;
+import com.google.cloud.metastore.v1beta.QueryMetadataResponse;
+import com.google.cloud.metastore.v1beta.RemoveIamPolicyRequest;
+import com.google.cloud.metastore.v1beta.RemoveIamPolicyResponse;
import com.google.cloud.metastore.v1beta.Restore;
import com.google.cloud.metastore.v1beta.RestoreServiceRequest;
import com.google.cloud.metastore.v1beta.Service;
@@ -192,6 +200,45 @@ public UnaryCallable deleteBackupCallable() {
throw new UnsupportedOperationException("Not implemented: deleteBackupCallable()");
}
+ public UnaryCallable removeIamPolicyCallable() {
+ throw new UnsupportedOperationException("Not implemented: removeIamPolicyCallable()");
+ }
+
+ public OperationCallable
+ queryMetadataOperationCallable() {
+ throw new UnsupportedOperationException("Not implemented: queryMetadataOperationCallable()");
+ }
+
+ public UnaryCallable queryMetadataCallable() {
+ throw new UnsupportedOperationException("Not implemented: queryMetadataCallable()");
+ }
+
+ public OperationCallable<
+ MoveTableToDatabaseRequest, MoveTableToDatabaseResponse, OperationMetadata>
+ moveTableToDatabaseOperationCallable() {
+ throw new UnsupportedOperationException(
+ "Not implemented: moveTableToDatabaseOperationCallable()");
+ }
+
+ public UnaryCallable moveTableToDatabaseCallable() {
+ throw new UnsupportedOperationException("Not implemented: moveTableToDatabaseCallable()");
+ }
+
+ public OperationCallable<
+ AlterMetadataResourceLocationRequest,
+ AlterMetadataResourceLocationResponse,
+ OperationMetadata>
+ alterMetadataResourceLocationOperationCallable() {
+ throw new UnsupportedOperationException(
+ "Not implemented: alterMetadataResourceLocationOperationCallable()");
+ }
+
+ public UnaryCallable
+ alterMetadataResourceLocationCallable() {
+ throw new UnsupportedOperationException(
+ "Not implemented: alterMetadataResourceLocationCallable()");
+ }
+
@Override
public abstract void close();
}
diff --git a/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1beta/stub/DataprocMetastoreStubSettings.java b/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1beta/stub/DataprocMetastoreStubSettings.java
index fd1e7f64009f..b840e6b744c5 100644
--- a/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1beta/stub/DataprocMetastoreStubSettings.java
+++ b/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1beta/stub/DataprocMetastoreStubSettings.java
@@ -49,6 +49,8 @@
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.v1beta.AlterMetadataResourceLocationRequest;
+import com.google.cloud.metastore.v1beta.AlterMetadataResourceLocationResponse;
import com.google.cloud.metastore.v1beta.Backup;
import com.google.cloud.metastore.v1beta.CreateBackupRequest;
import com.google.cloud.metastore.v1beta.CreateMetadataImportRequest;
@@ -67,7 +69,13 @@
import com.google.cloud.metastore.v1beta.ListServicesResponse;
import com.google.cloud.metastore.v1beta.MetadataExport;
import com.google.cloud.metastore.v1beta.MetadataImport;
+import com.google.cloud.metastore.v1beta.MoveTableToDatabaseRequest;
+import com.google.cloud.metastore.v1beta.MoveTableToDatabaseResponse;
import com.google.cloud.metastore.v1beta.OperationMetadata;
+import com.google.cloud.metastore.v1beta.QueryMetadataRequest;
+import com.google.cloud.metastore.v1beta.QueryMetadataResponse;
+import com.google.cloud.metastore.v1beta.RemoveIamPolicyRequest;
+import com.google.cloud.metastore.v1beta.RemoveIamPolicyResponse;
import com.google.cloud.metastore.v1beta.Restore;
import com.google.cloud.metastore.v1beta.RestoreServiceRequest;
import com.google.cloud.metastore.v1beta.Service;
@@ -169,6 +177,24 @@ public class DataprocMetastoreStubSettings extends StubSettings deleteBackupSettings;
private final OperationCallSettings
deleteBackupOperationSettings;
+ private final UnaryCallSettings
+ removeIamPolicySettings;
+ private final UnaryCallSettings queryMetadataSettings;
+ private final OperationCallSettings<
+ QueryMetadataRequest, QueryMetadataResponse, OperationMetadata>
+ queryMetadataOperationSettings;
+ private final UnaryCallSettings
+ moveTableToDatabaseSettings;
+ private final OperationCallSettings<
+ MoveTableToDatabaseRequest, MoveTableToDatabaseResponse, OperationMetadata>
+ moveTableToDatabaseOperationSettings;
+ private final UnaryCallSettings
+ alterMetadataResourceLocationSettings;
+ private final OperationCallSettings<
+ AlterMetadataResourceLocationRequest,
+ AlterMetadataResourceLocationResponse,
+ OperationMetadata>
+ alterMetadataResourceLocationOperationSettings;
private static final PagedListDescriptor
LIST_SERVICES_PAGE_STR_DESC =
@@ -470,6 +496,50 @@ public UnaryCallSettings deleteBackupSettings()
return deleteBackupOperationSettings;
}
+ /** Returns the object with the settings used for calls to removeIamPolicy. */
+ public UnaryCallSettings
+ removeIamPolicySettings() {
+ return removeIamPolicySettings;
+ }
+
+ /** Returns the object with the settings used for calls to queryMetadata. */
+ public UnaryCallSettings queryMetadataSettings() {
+ return queryMetadataSettings;
+ }
+
+ /** Returns the object with the settings used for calls to queryMetadata. */
+ public OperationCallSettings
+ queryMetadataOperationSettings() {
+ return queryMetadataOperationSettings;
+ }
+
+ /** Returns the object with the settings used for calls to moveTableToDatabase. */
+ public UnaryCallSettings moveTableToDatabaseSettings() {
+ return moveTableToDatabaseSettings;
+ }
+
+ /** Returns the object with the settings used for calls to moveTableToDatabase. */
+ public OperationCallSettings<
+ MoveTableToDatabaseRequest, MoveTableToDatabaseResponse, OperationMetadata>
+ moveTableToDatabaseOperationSettings() {
+ return moveTableToDatabaseOperationSettings;
+ }
+
+ /** Returns the object with the settings used for calls to alterMetadataResourceLocation. */
+ public UnaryCallSettings
+ alterMetadataResourceLocationSettings() {
+ return alterMetadataResourceLocationSettings;
+ }
+
+ /** Returns the object with the settings used for calls to alterMetadataResourceLocation. */
+ public OperationCallSettings<
+ AlterMetadataResourceLocationRequest,
+ AlterMetadataResourceLocationResponse,
+ OperationMetadata>
+ alterMetadataResourceLocationOperationSettings() {
+ return alterMetadataResourceLocationOperationSettings;
+ }
+
public DataprocMetastoreStub createStub() throws IOException {
if (getTransportChannelProvider()
.getTransportName()
@@ -602,6 +672,16 @@ protected DataprocMetastoreStubSettings(Builder settingsBuilder) throws IOExcept
createBackupOperationSettings = settingsBuilder.createBackupOperationSettings().build();
deleteBackupSettings = settingsBuilder.deleteBackupSettings().build();
deleteBackupOperationSettings = settingsBuilder.deleteBackupOperationSettings().build();
+ removeIamPolicySettings = settingsBuilder.removeIamPolicySettings().build();
+ queryMetadataSettings = settingsBuilder.queryMetadataSettings().build();
+ queryMetadataOperationSettings = settingsBuilder.queryMetadataOperationSettings().build();
+ moveTableToDatabaseSettings = settingsBuilder.moveTableToDatabaseSettings().build();
+ moveTableToDatabaseOperationSettings =
+ settingsBuilder.moveTableToDatabaseOperationSettings().build();
+ alterMetadataResourceLocationSettings =
+ settingsBuilder.alterMetadataResourceLocationSettings().build();
+ alterMetadataResourceLocationOperationSettings =
+ settingsBuilder.alterMetadataResourceLocationOperationSettings().build();
}
/** Builder for DataprocMetastoreStubSettings. */
@@ -656,6 +736,24 @@ public static class Builder extends StubSettings.Builder deleteBackupSettings;
private final OperationCallSettings.Builder
deleteBackupOperationSettings;
+ private final UnaryCallSettings.Builder
+ removeIamPolicySettings;
+ private final UnaryCallSettings.Builder queryMetadataSettings;
+ private final OperationCallSettings.Builder<
+ QueryMetadataRequest, QueryMetadataResponse, OperationMetadata>
+ queryMetadataOperationSettings;
+ private final UnaryCallSettings.Builder
+ moveTableToDatabaseSettings;
+ private final OperationCallSettings.Builder<
+ MoveTableToDatabaseRequest, MoveTableToDatabaseResponse, OperationMetadata>
+ moveTableToDatabaseOperationSettings;
+ private final UnaryCallSettings.Builder
+ alterMetadataResourceLocationSettings;
+ private final OperationCallSettings.Builder<
+ AlterMetadataResourceLocationRequest,
+ AlterMetadataResourceLocationResponse,
+ OperationMetadata>
+ alterMetadataResourceLocationOperationSettings;
private static final ImmutableMap>
RETRYABLE_CODE_DEFINITIONS;
@@ -729,6 +827,13 @@ protected Builder(ClientContext clientContext) {
createBackupOperationSettings = OperationCallSettings.newBuilder();
deleteBackupSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
deleteBackupOperationSettings = OperationCallSettings.newBuilder();
+ removeIamPolicySettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ queryMetadataSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ queryMetadataOperationSettings = OperationCallSettings.newBuilder();
+ moveTableToDatabaseSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ moveTableToDatabaseOperationSettings = OperationCallSettings.newBuilder();
+ alterMetadataResourceLocationSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ alterMetadataResourceLocationOperationSettings = OperationCallSettings.newBuilder();
unaryMethodSettingsBuilders =
ImmutableList.>of(
@@ -746,7 +851,11 @@ protected Builder(ClientContext clientContext) {
listBackupsSettings,
getBackupSettings,
createBackupSettings,
- deleteBackupSettings);
+ deleteBackupSettings,
+ removeIamPolicySettings,
+ queryMetadataSettings,
+ moveTableToDatabaseSettings,
+ alterMetadataResourceLocationSettings);
initDefaults(this);
}
@@ -779,6 +888,16 @@ protected Builder(DataprocMetastoreStubSettings settings) {
createBackupOperationSettings = settings.createBackupOperationSettings.toBuilder();
deleteBackupSettings = settings.deleteBackupSettings.toBuilder();
deleteBackupOperationSettings = settings.deleteBackupOperationSettings.toBuilder();
+ removeIamPolicySettings = settings.removeIamPolicySettings.toBuilder();
+ queryMetadataSettings = settings.queryMetadataSettings.toBuilder();
+ queryMetadataOperationSettings = settings.queryMetadataOperationSettings.toBuilder();
+ moveTableToDatabaseSettings = settings.moveTableToDatabaseSettings.toBuilder();
+ moveTableToDatabaseOperationSettings =
+ settings.moveTableToDatabaseOperationSettings.toBuilder();
+ alterMetadataResourceLocationSettings =
+ settings.alterMetadataResourceLocationSettings.toBuilder();
+ alterMetadataResourceLocationOperationSettings =
+ settings.alterMetadataResourceLocationOperationSettings.toBuilder();
unaryMethodSettingsBuilders =
ImmutableList.>of(
@@ -796,7 +915,11 @@ protected Builder(DataprocMetastoreStubSettings settings) {
listBackupsSettings,
getBackupSettings,
createBackupSettings,
- deleteBackupSettings);
+ deleteBackupSettings,
+ removeIamPolicySettings,
+ queryMetadataSettings,
+ moveTableToDatabaseSettings,
+ alterMetadataResourceLocationSettings);
}
private static Builder createDefault() {
@@ -901,6 +1024,26 @@ private static Builder initDefaults(Builder builder) {
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes"))
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params"));
+ builder
+ .removeIamPolicySettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_0_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_0_params"));
+
+ builder
+ .queryMetadataSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_0_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_0_params"));
+
+ builder
+ .moveTableToDatabaseSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_0_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_0_params"));
+
+ builder
+ .alterMetadataResourceLocationSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_0_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_0_params"));
+
builder
.createServiceOperationSettings()
.setInitialCallSettings(
@@ -1117,6 +1260,81 @@ private static Builder initDefaults(Builder builder) {
.setTotalTimeout(Duration.ofMillis(1500000L))
.build()));
+ builder
+ .queryMetadataOperationSettings()
+ .setInitialCallSettings(
+ UnaryCallSettings
+ .newUnaryCallSettingsBuilder()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_0_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_0_params"))
+ .build())
+ .setResponseTransformer(
+ ProtoOperationTransformers.ResponseTransformer.create(QueryMetadataResponse.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
+ .moveTableToDatabaseOperationSettings()
+ .setInitialCallSettings(
+ UnaryCallSettings
+ .newUnaryCallSettingsBuilder()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_0_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_0_params"))
+ .build())
+ .setResponseTransformer(
+ ProtoOperationTransformers.ResponseTransformer.create(
+ MoveTableToDatabaseResponse.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
+ .alterMetadataResourceLocationOperationSettings()
+ .setInitialCallSettings(
+ UnaryCallSettings
+ .
+ newUnaryCallSettingsBuilder()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_0_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_0_params"))
+ .build())
+ .setResponseTransformer(
+ ProtoOperationTransformers.ResponseTransformer.create(
+ AlterMetadataResourceLocationResponse.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;
}
@@ -1295,6 +1513,58 @@ public UnaryCallSettings.Builder deleteBackupSet
return deleteBackupOperationSettings;
}
+ /** Returns the builder for the settings used for calls to removeIamPolicy. */
+ public UnaryCallSettings.Builder
+ removeIamPolicySettings() {
+ return removeIamPolicySettings;
+ }
+
+ /** Returns the builder for the settings used for calls to queryMetadata. */
+ public UnaryCallSettings.Builder queryMetadataSettings() {
+ return queryMetadataSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to queryMetadata. */
+ @BetaApi(
+ "The surface for use by generated code is not stable yet and may change in the future.")
+ public OperationCallSettings.Builder<
+ QueryMetadataRequest, QueryMetadataResponse, OperationMetadata>
+ queryMetadataOperationSettings() {
+ return queryMetadataOperationSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to moveTableToDatabase. */
+ public UnaryCallSettings.Builder
+ moveTableToDatabaseSettings() {
+ return moveTableToDatabaseSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to moveTableToDatabase. */
+ @BetaApi(
+ "The surface for use by generated code is not stable yet and may change in the future.")
+ public OperationCallSettings.Builder<
+ MoveTableToDatabaseRequest, MoveTableToDatabaseResponse, OperationMetadata>
+ moveTableToDatabaseOperationSettings() {
+ return moveTableToDatabaseOperationSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to alterMetadataResourceLocation. */
+ public UnaryCallSettings.Builder
+ alterMetadataResourceLocationSettings() {
+ return alterMetadataResourceLocationSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to alterMetadataResourceLocation. */
+ @BetaApi(
+ "The surface for use by generated code is not stable yet and may change in the future.")
+ public OperationCallSettings.Builder<
+ AlterMetadataResourceLocationRequest,
+ AlterMetadataResourceLocationResponse,
+ OperationMetadata>
+ alterMetadataResourceLocationOperationSettings() {
+ return alterMetadataResourceLocationOperationSettings;
+ }
+
@Override
public DataprocMetastoreStubSettings build() throws IOException {
return new DataprocMetastoreStubSettings(this);
diff --git a/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1beta/stub/GrpcDataprocMetastoreStub.java b/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1beta/stub/GrpcDataprocMetastoreStub.java
index d4a575e2eeb5..9b835f152be1 100644
--- a/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1beta/stub/GrpcDataprocMetastoreStub.java
+++ b/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1beta/stub/GrpcDataprocMetastoreStub.java
@@ -28,6 +28,8 @@
import com.google.api.gax.rpc.ClientContext;
import com.google.api.gax.rpc.OperationCallable;
import com.google.api.gax.rpc.UnaryCallable;
+import com.google.cloud.metastore.v1beta.AlterMetadataResourceLocationRequest;
+import com.google.cloud.metastore.v1beta.AlterMetadataResourceLocationResponse;
import com.google.cloud.metastore.v1beta.Backup;
import com.google.cloud.metastore.v1beta.CreateBackupRequest;
import com.google.cloud.metastore.v1beta.CreateMetadataImportRequest;
@@ -46,7 +48,13 @@
import com.google.cloud.metastore.v1beta.ListServicesResponse;
import com.google.cloud.metastore.v1beta.MetadataExport;
import com.google.cloud.metastore.v1beta.MetadataImport;
+import com.google.cloud.metastore.v1beta.MoveTableToDatabaseRequest;
+import com.google.cloud.metastore.v1beta.MoveTableToDatabaseResponse;
import com.google.cloud.metastore.v1beta.OperationMetadata;
+import com.google.cloud.metastore.v1beta.QueryMetadataRequest;
+import com.google.cloud.metastore.v1beta.QueryMetadataResponse;
+import com.google.cloud.metastore.v1beta.RemoveIamPolicyRequest;
+import com.google.cloud.metastore.v1beta.RemoveIamPolicyResponse;
import com.google.cloud.metastore.v1beta.Restore;
import com.google.cloud.metastore.v1beta.RestoreServiceRequest;
import com.google.cloud.metastore.v1beta.Service;
@@ -220,6 +228,49 @@ public class GrpcDataprocMetastoreStub extends DataprocMetastoreStub {
.setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance()))
.build();
+ private static final MethodDescriptor
+ removeIamPolicyMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName("google.cloud.metastore.v1beta.DataprocMetastore/RemoveIamPolicy")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(RemoveIamPolicyRequest.getDefaultInstance()))
+ .setResponseMarshaller(
+ ProtoUtils.marshaller(RemoveIamPolicyResponse.getDefaultInstance()))
+ .build();
+
+ private static final MethodDescriptor
+ queryMetadataMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName("google.cloud.metastore.v1beta.DataprocMetastore/QueryMetadata")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(QueryMetadataRequest.getDefaultInstance()))
+ .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance()))
+ .build();
+
+ private static final MethodDescriptor
+ moveTableToDatabaseMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(
+ "google.cloud.metastore.v1beta.DataprocMetastore/MoveTableToDatabase")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(MoveTableToDatabaseRequest.getDefaultInstance()))
+ .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance()))
+ .build();
+
+ private static final MethodDescriptor
+ alterMetadataResourceLocationMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(
+ "google.cloud.metastore.v1beta.DataprocMetastore/AlterMetadataResourceLocation")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(AlterMetadataResourceLocationRequest.getDefaultInstance()))
+ .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance()))
+ .build();
+
private final UnaryCallable listServicesCallable;
private final UnaryCallable
listServicesPagedCallable;
@@ -260,6 +311,22 @@ public class GrpcDataprocMetastoreStub extends DataprocMetastoreStub {
private final UnaryCallable deleteBackupCallable;
private final OperationCallable
deleteBackupOperationCallable;
+ private final UnaryCallable
+ removeIamPolicyCallable;
+ private final UnaryCallable queryMetadataCallable;
+ private final OperationCallable
+ queryMetadataOperationCallable;
+ private final UnaryCallable moveTableToDatabaseCallable;
+ private final OperationCallable<
+ MoveTableToDatabaseRequest, MoveTableToDatabaseResponse, OperationMetadata>
+ moveTableToDatabaseOperationCallable;
+ private final UnaryCallable
+ alterMetadataResourceLocationCallable;
+ private final OperationCallable<
+ AlterMetadataResourceLocationRequest,
+ AlterMetadataResourceLocationResponse,
+ OperationMetadata>
+ alterMetadataResourceLocationOperationCallable;
private final BackgroundResource backgroundResources;
private final GrpcOperationsStub operationsStub;
@@ -458,6 +525,48 @@ protected GrpcDataprocMetastoreStub(
return params.build();
})
.build();
+ GrpcCallSettings
+ removeIamPolicyTransportSettings =
+ GrpcCallSettings.newBuilder()
+ .setMethodDescriptor(removeIamPolicyMethodDescriptor)
+ .setParamsExtractor(
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("resource", String.valueOf(request.getResource()));
+ return params.build();
+ })
+ .build();
+ GrpcCallSettings queryMetadataTransportSettings =
+ GrpcCallSettings.newBuilder()
+ .setMethodDescriptor(queryMetadataMethodDescriptor)
+ .setParamsExtractor(
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("service", String.valueOf(request.getService()));
+ return params.build();
+ })
+ .build();
+ GrpcCallSettings moveTableToDatabaseTransportSettings =
+ GrpcCallSettings.newBuilder()
+ .setMethodDescriptor(moveTableToDatabaseMethodDescriptor)
+ .setParamsExtractor(
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("service", String.valueOf(request.getService()));
+ return params.build();
+ })
+ .build();
+ GrpcCallSettings
+ alterMetadataResourceLocationTransportSettings =
+ GrpcCallSettings.newBuilder()
+ .setMethodDescriptor(alterMetadataResourceLocationMethodDescriptor)
+ .setParamsExtractor(
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("service", String.valueOf(request.getService()));
+ return params.build();
+ })
+ .build();
this.listServicesCallable =
callableFactory.createUnaryCallable(
@@ -577,6 +686,40 @@ protected GrpcDataprocMetastoreStub(
settings.deleteBackupOperationSettings(),
clientContext,
operationsStub);
+ this.removeIamPolicyCallable =
+ callableFactory.createUnaryCallable(
+ removeIamPolicyTransportSettings, settings.removeIamPolicySettings(), clientContext);
+ this.queryMetadataCallable =
+ callableFactory.createUnaryCallable(
+ queryMetadataTransportSettings, settings.queryMetadataSettings(), clientContext);
+ this.queryMetadataOperationCallable =
+ callableFactory.createOperationCallable(
+ queryMetadataTransportSettings,
+ settings.queryMetadataOperationSettings(),
+ clientContext,
+ operationsStub);
+ this.moveTableToDatabaseCallable =
+ callableFactory.createUnaryCallable(
+ moveTableToDatabaseTransportSettings,
+ settings.moveTableToDatabaseSettings(),
+ clientContext);
+ this.moveTableToDatabaseOperationCallable =
+ callableFactory.createOperationCallable(
+ moveTableToDatabaseTransportSettings,
+ settings.moveTableToDatabaseOperationSettings(),
+ clientContext,
+ operationsStub);
+ this.alterMetadataResourceLocationCallable =
+ callableFactory.createUnaryCallable(
+ alterMetadataResourceLocationTransportSettings,
+ settings.alterMetadataResourceLocationSettings(),
+ clientContext);
+ this.alterMetadataResourceLocationOperationCallable =
+ callableFactory.createOperationCallable(
+ alterMetadataResourceLocationTransportSettings,
+ settings.alterMetadataResourceLocationOperationSettings(),
+ clientContext,
+ operationsStub);
this.backgroundResources =
new BackgroundResourceAggregation(clientContext.getBackgroundResources());
@@ -732,6 +875,49 @@ public UnaryCallable deleteBackupCallable() {
return deleteBackupOperationCallable;
}
+ @Override
+ public UnaryCallable removeIamPolicyCallable() {
+ return removeIamPolicyCallable;
+ }
+
+ @Override
+ public UnaryCallable queryMetadataCallable() {
+ return queryMetadataCallable;
+ }
+
+ @Override
+ public OperationCallable
+ queryMetadataOperationCallable() {
+ return queryMetadataOperationCallable;
+ }
+
+ @Override
+ public UnaryCallable moveTableToDatabaseCallable() {
+ return moveTableToDatabaseCallable;
+ }
+
+ @Override
+ public OperationCallable<
+ MoveTableToDatabaseRequest, MoveTableToDatabaseResponse, OperationMetadata>
+ moveTableToDatabaseOperationCallable() {
+ return moveTableToDatabaseOperationCallable;
+ }
+
+ @Override
+ public UnaryCallable
+ alterMetadataResourceLocationCallable() {
+ return alterMetadataResourceLocationCallable;
+ }
+
+ @Override
+ public OperationCallable<
+ AlterMetadataResourceLocationRequest,
+ AlterMetadataResourceLocationResponse,
+ OperationMetadata>
+ alterMetadataResourceLocationOperationCallable() {
+ return alterMetadataResourceLocationOperationCallable;
+ }
+
@Override
public final void close() {
try {
diff --git a/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1beta/stub/HttpJsonDataprocMetastoreStub.java b/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1beta/stub/HttpJsonDataprocMetastoreStub.java
index b3e2ad8c3c67..0b8d805e90c3 100644
--- a/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1beta/stub/HttpJsonDataprocMetastoreStub.java
+++ b/java-dataproc-metastore/google-cloud-dataproc-metastore/src/main/java/com/google/cloud/metastore/v1beta/stub/HttpJsonDataprocMetastoreStub.java
@@ -35,6 +35,8 @@
import com.google.api.gax.rpc.ClientContext;
import com.google.api.gax.rpc.OperationCallable;
import com.google.api.gax.rpc.UnaryCallable;
+import com.google.cloud.metastore.v1beta.AlterMetadataResourceLocationRequest;
+import com.google.cloud.metastore.v1beta.AlterMetadataResourceLocationResponse;
import com.google.cloud.metastore.v1beta.Backup;
import com.google.cloud.metastore.v1beta.CreateBackupRequest;
import com.google.cloud.metastore.v1beta.CreateMetadataImportRequest;
@@ -53,7 +55,13 @@
import com.google.cloud.metastore.v1beta.ListServicesResponse;
import com.google.cloud.metastore.v1beta.MetadataExport;
import com.google.cloud.metastore.v1beta.MetadataImport;
+import com.google.cloud.metastore.v1beta.MoveTableToDatabaseRequest;
+import com.google.cloud.metastore.v1beta.MoveTableToDatabaseResponse;
import com.google.cloud.metastore.v1beta.OperationMetadata;
+import com.google.cloud.metastore.v1beta.QueryMetadataRequest;
+import com.google.cloud.metastore.v1beta.QueryMetadataResponse;
+import com.google.cloud.metastore.v1beta.RemoveIamPolicyRequest;
+import com.google.cloud.metastore.v1beta.RemoveIamPolicyResponse;
import com.google.cloud.metastore.v1beta.Restore;
import com.google.cloud.metastore.v1beta.RestoreServiceRequest;
import com.google.cloud.metastore.v1beta.Service;
@@ -84,6 +92,9 @@ public class HttpJsonDataprocMetastoreStub extends DataprocMetastoreStub {
.add(OperationMetadata.getDescriptor())
.add(Empty.getDescriptor())
.add(MetadataImport.getDescriptor())
+ .add(MoveTableToDatabaseResponse.getDescriptor())
+ .add(AlterMetadataResourceLocationResponse.getDescriptor())
+ .add(QueryMetadataResponse.getDescriptor())
.add(Restore.getDescriptor())
.add(Service.getDescriptor())
.add(Backup.getDescriptor())
@@ -679,6 +690,165 @@ public class HttpJsonDataprocMetastoreStub extends DataprocMetastoreStub {
HttpJsonOperationSnapshot.create(response))
.build();
+ private static final ApiMethodDescriptor
+ removeIamPolicyMethodDescriptor =
+ ApiMethodDescriptor.newBuilder()
+ .setFullMethodName("google.cloud.metastore.v1beta.DataprocMetastore/RemoveIamPolicy")
+ .setHttpMethod("POST")
+ .setType(ApiMethodDescriptor.MethodType.UNARY)
+ .setRequestFormatter(
+ ProtoMessageRequestFormatter.newBuilder()
+ .setPath(
+ "/v1beta/{resource=projects/*/locations/*/services/*/**}:removeIamPolicy",
+ request -> {
+ Map fields = new HashMap<>();
+ ProtoRestSerializer serializer =
+ ProtoRestSerializer.create();
+ serializer.putPathParam(fields, "resource", request.getResource());
+ return fields;
+ })
+ .setQueryParamsExtractor(
+ request -> {
+ Map> fields = new HashMap<>();
+ ProtoRestSerializer serializer =
+ ProtoRestSerializer.create();
+ serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int");
+ return fields;
+ })
+ .setRequestBodyExtractor(
+ request ->
+ ProtoRestSerializer.create()
+ .toBody("*", request.toBuilder().clearResource().build(), true))
+ .build())
+ .setResponseParser(
+ ProtoMessageResponseParser.newBuilder()
+ .setDefaultInstance(RemoveIamPolicyResponse.getDefaultInstance())
+ .setDefaultTypeRegistry(typeRegistry)
+ .build())
+ .build();
+
+ private static final ApiMethodDescriptor
+ queryMetadataMethodDescriptor =
+ ApiMethodDescriptor.newBuilder()
+ .setFullMethodName("google.cloud.metastore.v1beta.DataprocMetastore/QueryMetadata")
+ .setHttpMethod("POST")
+ .setType(ApiMethodDescriptor.MethodType.UNARY)
+ .setRequestFormatter(
+ ProtoMessageRequestFormatter.newBuilder()
+ .setPath(
+ "/v1beta/{service=projects/*/locations/*/services/*}:queryMetadata",
+ request -> {
+ Map fields = new HashMap<>();
+ ProtoRestSerializer serializer =
+ ProtoRestSerializer.create();
+ serializer.putPathParam(fields, "service", request.getService());
+ return fields;
+ })
+ .setQueryParamsExtractor(
+ request -> {
+ Map> fields = new HashMap<>();
+ ProtoRestSerializer