diff --git a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/BaseBigtableTableAdminClient.java b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/BaseBigtableTableAdminClient.java
index bde3b968bf..f69d03c9b7 100644
--- a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/BaseBigtableTableAdminClient.java
+++ b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/BaseBigtableTableAdminClient.java
@@ -33,8 +33,6 @@
import com.google.bigtable.admin.v2.CheckConsistencyRequest;
import com.google.bigtable.admin.v2.CheckConsistencyResponse;
import com.google.bigtable.admin.v2.ClusterName;
-import com.google.bigtable.admin.v2.CopyBackupMetadata;
-import com.google.bigtable.admin.v2.CopyBackupRequest;
import com.google.bigtable.admin.v2.CreateBackupMetadata;
import com.google.bigtable.admin.v2.CreateBackupRequest;
import com.google.bigtable.admin.v2.CreateTableFromSnapshotMetadata;
@@ -82,95 +80,13 @@
import com.google.longrunning.OperationsClient;
import com.google.protobuf.Empty;
import com.google.protobuf.FieldMask;
-import com.google.protobuf.Timestamp;
import java.io.IOException;
import java.util.List;
import java.util.concurrent.TimeUnit;
import javax.annotation.Generated;
// AUTO-GENERATED DOCUMENTATION AND CLASS.
-/**
- * Service Description: Service for creating, configuring, and deleting Cloud Bigtable tables.
- *
- * Provides access to the table schemas only, not the data stored within the tables.
- *
- *
This class provides the ability to make remote calls to the backing service through method
- * calls that map to API methods. Sample code to get started:
- *
- *
{@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 (BaseBigtableTableAdminClient baseBigtableTableAdminClient =
- * BaseBigtableTableAdminClient.create()) {
- * InstanceName parent = InstanceName.of("[PROJECT]", "[INSTANCE]");
- * String tableId = "tableId-1552905847";
- * Table table = Table.newBuilder().build();
- * Table response = baseBigtableTableAdminClient.createTable(parent, tableId, table);
- * }
- * }
- *
- * Note: close() needs to be called on the BaseBigtableTableAdminClient object to clean up
- * resources such as threads. In the example above, try-with-resources is used, which automatically
- * calls close().
- *
- *
The surface of this class includes several types of Java methods for each of the API's
- * methods:
- *
- *
- * - A "flattened" method. With this type of method, the fields of the request type have been
- * converted into function parameters. It may be the case that not all fields are available as
- * parameters, and not every API method will have a flattened method entry point.
- *
- A "request object" method. This type of method only takes one parameter, a request object,
- * which must be constructed before the call. Not every API method will have a request object
- * method.
- *
- A "callable" method. This type of method takes no parameters and returns an immutable API
- * callable object, which can be used to initiate calls to the service.
- *
- *
- * See the individual methods for example code.
- *
- *
Many parameters require resource names to be formatted in a particular way. To assist with
- * these names, this class includes a format method for each type of name, and additionally a parse
- * method to extract the individual identifiers contained within names that are returned.
- *
- *
This class can be customized by passing in a custom instance of BaseBigtableTableAdminSettings
- * to create(). For example:
- *
- *
To customize credentials:
- *
- *
{@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
- * BaseBigtableTableAdminSettings baseBigtableTableAdminSettings =
- * BaseBigtableTableAdminSettings.newBuilder()
- * .setCredentialsProvider(FixedCredentialsProvider.create(myCredentials))
- * .build();
- * BaseBigtableTableAdminClient baseBigtableTableAdminClient =
- * BaseBigtableTableAdminClient.create(baseBigtableTableAdminSettings);
- * }
- *
- * To customize the endpoint:
- *
- *
{@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
- * BaseBigtableTableAdminSettings baseBigtableTableAdminSettings =
- * BaseBigtableTableAdminSettings.newBuilder().setEndpoint(myEndpoint).build();
- * BaseBigtableTableAdminClient baseBigtableTableAdminClient =
- * BaseBigtableTableAdminClient.create(baseBigtableTableAdminSettings);
- * }
- *
- * Please refer to the GitHub repository's samples for more quickstart code snippets.
- */
+/** For internal use only. */
@Generated("by gapic-generator")
@InternalApi
public class BaseBigtableTableAdminClient implements BackgroundResource {
@@ -660,8 +576,8 @@ public final OperationFuture createTable
* }
*/
public final OperationCallable<
- CreateTableFromSnapshotRequest, Table, CreateTableFromSnapshotMetadata>
- createTableFromSnapshotOperationCallable() {
+ CreateTableFromSnapshotRequest, Table, CreateTableFromSnapshotMetadata>
+ createTableFromSnapshotOperationCallable() {
return stub.createTableFromSnapshotOperationCallable();
}
@@ -700,7 +616,7 @@ public final OperationFuture createTable
* }
*/
public final UnaryCallable
- createTableFromSnapshotCallable() {
+ createTableFromSnapshotCallable() {
return stub.createTableFromSnapshotCallable();
}
@@ -1081,7 +997,7 @@ public final OperationFuture updateTableAsync(
* }
*/
public final OperationCallable
- updateTableOperationCallable() {
+ updateTableOperationCallable() {
return stub.updateTableOperationCallable();
}
@@ -1343,7 +1259,7 @@ public final OperationFuture undeleteTableAsync(
* }
*/
public final OperationCallable
- undeleteTableOperationCallable() {
+ undeleteTableOperationCallable() {
return stub.undeleteTableOperationCallable();
}
@@ -1705,7 +1621,7 @@ public final GenerateConsistencyTokenResponse generateConsistencyToken(
* }
*/
public final UnaryCallable
- generateConsistencyTokenCallable() {
+ generateConsistencyTokenCallable() {
return stub.generateConsistencyTokenCallable();
}
@@ -1842,7 +1758,7 @@ public final CheckConsistencyResponse checkConsistency(CheckConsistencyRequest r
* }
*/
public final UnaryCallable
- checkConsistencyCallable() {
+ checkConsistencyCallable() {
return stub.checkConsistencyCallable();
}
@@ -2134,7 +2050,7 @@ public final OperationFuture snapshotTableAsync
* }
*/
public final OperationCallable
- snapshotTableOperationCallable() {
+ snapshotTableOperationCallable() {
return stub.snapshotTableOperationCallable();
}
@@ -2465,7 +2381,7 @@ public final ListSnapshotsPagedResponse listSnapshots(ListSnapshotsRequest reque
* }
*/
public final UnaryCallable
- listSnapshotsPagedCallable() {
+ listSnapshotsPagedCallable() {
return stub.listSnapshotsPagedCallable();
}
@@ -2826,7 +2742,7 @@ public final OperationFuture createBackupAsync(
* }
*/
public final OperationCallable
- createBackupOperationCallable() {
+ createBackupOperationCallable() {
return stub.createBackupOperationCallable();
}
@@ -3326,7 +3242,7 @@ public final ListBackupsPagedResponse listBackups(ListBackupsRequest request) {
* }
*/
public final UnaryCallable
- listBackupsPagedCallable() {
+ listBackupsPagedCallable() {
return stub.listBackupsPagedCallable();
}
@@ -3442,7 +3358,7 @@ public final OperationFuture restoreTableAsync(
* }
*/
public final OperationCallable
- restoreTableOperationCallable() {
+ restoreTableOperationCallable() {
return stub.restoreTableOperationCallable();
}
@@ -3484,342 +3400,8 @@ public final UnaryCallable restoreTableCallable(
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
- * Copy a Cloud Bigtable backup to a new backup in the destination cluster located in the
- * destination instance and project.
- *
- * 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 (BaseBigtableTableAdminClient baseBigtableTableAdminClient =
- * BaseBigtableTableAdminClient.create()) {
- * ClusterName parent = ClusterName.of("[PROJECT]", "[INSTANCE]", "[CLUSTER]");
- * String backupId = "backupId2121930365";
- * BackupName sourceBackup = BackupName.of("[PROJECT]", "[INSTANCE]", "[CLUSTER]", "[BACKUP]");
- * Timestamp expireTime = Timestamp.newBuilder().build();
- * Backup response =
- * baseBigtableTableAdminClient
- * .copyBackupAsync(parent, backupId, sourceBackup, expireTime)
- * .get();
- * }
- * }
- *
- * @param parent Required. The name of the destination cluster that will contain the backup copy.
- * The cluster must already exist. Values are of the form:
- * `projects/{project}/instances/{instance}/clusters/{cluster}`.
- * @param backupId Required. The id of the new backup. The `backup_id` along with `parent` are
- * combined as `{parent}/backups/{backup_id}` to create the full backup name, of the form:
- * `projects/{project}/instances/{instance}/clusters/{cluster}/backups/{backup_id}`. This
- * string must be between 1 and 50 characters in length and match the regex
- * `[_a-zA-Z0-9][-_.a-zA-Z0-9]*`.
- * @param sourceBackup Required. The source backup to be copied from. The source backup needs to
- * be in READY state for it to be copied. Copying a copied backup is not allowed. Once
- * CopyBackup is in progress, the source backup cannot be deleted or cleaned up on expiration
- * until CopyBackup is finished. Values are of the form:
- * `projects/<project>/instances/<instance>/clusters/<cluster>/backups/<backup>`.
- * @param expireTime Required. Required. The expiration time of the copied backup with microsecond
- * granularity that must be at least 6 hours and at most 30 days from the time the request is
- * received. Once the `expire_time` has passed, Cloud Bigtable will delete the backup and free
- * the resources used by the backup.
- * @throws com.google.api.gax.rpc.ApiException if the remote call fails
- */
- public final OperationFuture copyBackupAsync(
- ClusterName parent, String backupId, BackupName sourceBackup, Timestamp expireTime) {
- CopyBackupRequest request =
- CopyBackupRequest.newBuilder()
- .setParent(parent == null ? null : parent.toString())
- .setBackupId(backupId)
- .setSourceBackup(sourceBackup == null ? null : sourceBackup.toString())
- .setExpireTime(expireTime)
- .build();
- return copyBackupAsync(request);
- }
-
- // AUTO-GENERATED DOCUMENTATION AND METHOD.
- /**
- * Copy a Cloud Bigtable backup to a new backup in the destination cluster located in the
- * destination instance and project.
- *
- * 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 (BaseBigtableTableAdminClient baseBigtableTableAdminClient =
- * BaseBigtableTableAdminClient.create()) {
- * ClusterName parent = ClusterName.of("[PROJECT]", "[INSTANCE]", "[CLUSTER]");
- * String backupId = "backupId2121930365";
- * String sourceBackup =
- * BackupName.of("[PROJECT]", "[INSTANCE]", "[CLUSTER]", "[BACKUP]").toString();
- * Timestamp expireTime = Timestamp.newBuilder().build();
- * Backup response =
- * baseBigtableTableAdminClient
- * .copyBackupAsync(parent, backupId, sourceBackup, expireTime)
- * .get();
- * }
- * }
- *
- * @param parent Required. The name of the destination cluster that will contain the backup copy.
- * The cluster must already exist. Values are of the form:
- * `projects/{project}/instances/{instance}/clusters/{cluster}`.
- * @param backupId Required. The id of the new backup. The `backup_id` along with `parent` are
- * combined as `{parent}/backups/{backup_id}` to create the full backup name, of the form:
- * `projects/{project}/instances/{instance}/clusters/{cluster}/backups/{backup_id}`. This
- * string must be between 1 and 50 characters in length and match the regex
- * `[_a-zA-Z0-9][-_.a-zA-Z0-9]*`.
- * @param sourceBackup Required. The source backup to be copied from. The source backup needs to
- * be in READY state for it to be copied. Copying a copied backup is not allowed. Once
- * CopyBackup is in progress, the source backup cannot be deleted or cleaned up on expiration
- * until CopyBackup is finished. Values are of the form:
- * `projects/<project>/instances/<instance>/clusters/<cluster>/backups/<backup>`.
- * @param expireTime Required. Required. The expiration time of the copied backup with microsecond
- * granularity that must be at least 6 hours and at most 30 days from the time the request is
- * received. Once the `expire_time` has passed, Cloud Bigtable will delete the backup and free
- * the resources used by the backup.
- * @throws com.google.api.gax.rpc.ApiException if the remote call fails
- */
- public final OperationFuture copyBackupAsync(
- ClusterName parent, String backupId, String sourceBackup, Timestamp expireTime) {
- CopyBackupRequest request =
- CopyBackupRequest.newBuilder()
- .setParent(parent == null ? null : parent.toString())
- .setBackupId(backupId)
- .setSourceBackup(sourceBackup)
- .setExpireTime(expireTime)
- .build();
- return copyBackupAsync(request);
- }
-
- // AUTO-GENERATED DOCUMENTATION AND METHOD.
- /**
- * Copy a Cloud Bigtable backup to a new backup in the destination cluster located in the
- * destination instance and project.
- *
- * 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 (BaseBigtableTableAdminClient baseBigtableTableAdminClient =
- * BaseBigtableTableAdminClient.create()) {
- * String parent = ClusterName.of("[PROJECT]", "[INSTANCE]", "[CLUSTER]").toString();
- * String backupId = "backupId2121930365";
- * BackupName sourceBackup = BackupName.of("[PROJECT]", "[INSTANCE]", "[CLUSTER]", "[BACKUP]");
- * Timestamp expireTime = Timestamp.newBuilder().build();
- * Backup response =
- * baseBigtableTableAdminClient
- * .copyBackupAsync(parent, backupId, sourceBackup, expireTime)
- * .get();
- * }
- * }
- *
- * @param parent Required. The name of the destination cluster that will contain the backup copy.
- * The cluster must already exist. Values are of the form:
- * `projects/{project}/instances/{instance}/clusters/{cluster}`.
- * @param backupId Required. The id of the new backup. The `backup_id` along with `parent` are
- * combined as `{parent}/backups/{backup_id}` to create the full backup name, of the form:
- * `projects/{project}/instances/{instance}/clusters/{cluster}/backups/{backup_id}`. This
- * string must be between 1 and 50 characters in length and match the regex
- * `[_a-zA-Z0-9][-_.a-zA-Z0-9]*`.
- * @param sourceBackup Required. The source backup to be copied from. The source backup needs to
- * be in READY state for it to be copied. Copying a copied backup is not allowed. Once
- * CopyBackup is in progress, the source backup cannot be deleted or cleaned up on expiration
- * until CopyBackup is finished. Values are of the form:
- * `projects/<project>/instances/<instance>/clusters/<cluster>/backups/<backup>`.
- * @param expireTime Required. Required. The expiration time of the copied backup with microsecond
- * granularity that must be at least 6 hours and at most 30 days from the time the request is
- * received. Once the `expire_time` has passed, Cloud Bigtable will delete the backup and free
- * the resources used by the backup.
- * @throws com.google.api.gax.rpc.ApiException if the remote call fails
- */
- public final OperationFuture copyBackupAsync(
- String parent, String backupId, BackupName sourceBackup, Timestamp expireTime) {
- CopyBackupRequest request =
- CopyBackupRequest.newBuilder()
- .setParent(parent)
- .setBackupId(backupId)
- .setSourceBackup(sourceBackup == null ? null : sourceBackup.toString())
- .setExpireTime(expireTime)
- .build();
- return copyBackupAsync(request);
- }
-
- // AUTO-GENERATED DOCUMENTATION AND METHOD.
- /**
- * Copy a Cloud Bigtable backup to a new backup in the destination cluster located in the
- * destination instance and project.
- *
- * 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 (BaseBigtableTableAdminClient baseBigtableTableAdminClient =
- * BaseBigtableTableAdminClient.create()) {
- * String parent = ClusterName.of("[PROJECT]", "[INSTANCE]", "[CLUSTER]").toString();
- * String backupId = "backupId2121930365";
- * String sourceBackup =
- * BackupName.of("[PROJECT]", "[INSTANCE]", "[CLUSTER]", "[BACKUP]").toString();
- * Timestamp expireTime = Timestamp.newBuilder().build();
- * Backup response =
- * baseBigtableTableAdminClient
- * .copyBackupAsync(parent, backupId, sourceBackup, expireTime)
- * .get();
- * }
- * }
- *
- * @param parent Required. The name of the destination cluster that will contain the backup copy.
- * The cluster must already exist. Values are of the form:
- * `projects/{project}/instances/{instance}/clusters/{cluster}`.
- * @param backupId Required. The id of the new backup. The `backup_id` along with `parent` are
- * combined as `{parent}/backups/{backup_id}` to create the full backup name, of the form:
- * `projects/{project}/instances/{instance}/clusters/{cluster}/backups/{backup_id}`. This
- * string must be between 1 and 50 characters in length and match the regex
- * `[_a-zA-Z0-9][-_.a-zA-Z0-9]*`.
- * @param sourceBackup Required. The source backup to be copied from. The source backup needs to
- * be in READY state for it to be copied. Copying a copied backup is not allowed. Once
- * CopyBackup is in progress, the source backup cannot be deleted or cleaned up on expiration
- * until CopyBackup is finished. Values are of the form:
- * `projects/<project>/instances/<instance>/clusters/<cluster>/backups/<backup>`.
- * @param expireTime Required. Required. The expiration time of the copied backup with microsecond
- * granularity that must be at least 6 hours and at most 30 days from the time the request is
- * received. Once the `expire_time` has passed, Cloud Bigtable will delete the backup and free
- * the resources used by the backup.
- * @throws com.google.api.gax.rpc.ApiException if the remote call fails
- */
- public final OperationFuture copyBackupAsync(
- String parent, String backupId, String sourceBackup, Timestamp expireTime) {
- CopyBackupRequest request =
- CopyBackupRequest.newBuilder()
- .setParent(parent)
- .setBackupId(backupId)
- .setSourceBackup(sourceBackup)
- .setExpireTime(expireTime)
- .build();
- return copyBackupAsync(request);
- }
-
- // AUTO-GENERATED DOCUMENTATION AND METHOD.
- /**
- * Copy a Cloud Bigtable backup to a new backup in the destination cluster located in the
- * destination instance and project.
- *
- * 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 (BaseBigtableTableAdminClient baseBigtableTableAdminClient =
- * BaseBigtableTableAdminClient.create()) {
- * CopyBackupRequest request =
- * CopyBackupRequest.newBuilder()
- * .setParent(ClusterName.of("[PROJECT]", "[INSTANCE]", "[CLUSTER]").toString())
- * .setBackupId("backupId2121930365")
- * .setSourceBackup(
- * BackupName.of("[PROJECT]", "[INSTANCE]", "[CLUSTER]", "[BACKUP]").toString())
- * .setExpireTime(Timestamp.newBuilder().build())
- * .build();
- * Backup response = baseBigtableTableAdminClient.copyBackupAsync(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 copyBackupAsync(
- CopyBackupRequest request) {
- return copyBackupOperationCallable().futureCall(request);
- }
-
- // AUTO-GENERATED DOCUMENTATION AND METHOD.
- /**
- * Copy a Cloud Bigtable backup to a new backup in the destination cluster located in the
- * destination instance and project.
- *
- * 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 (BaseBigtableTableAdminClient baseBigtableTableAdminClient =
- * BaseBigtableTableAdminClient.create()) {
- * CopyBackupRequest request =
- * CopyBackupRequest.newBuilder()
- * .setParent(ClusterName.of("[PROJECT]", "[INSTANCE]", "[CLUSTER]").toString())
- * .setBackupId("backupId2121930365")
- * .setSourceBackup(
- * BackupName.of("[PROJECT]", "[INSTANCE]", "[CLUSTER]", "[BACKUP]").toString())
- * .setExpireTime(Timestamp.newBuilder().build())
- * .build();
- * OperationFuture future =
- * baseBigtableTableAdminClient.copyBackupOperationCallable().futureCall(request);
- * // Do something.
- * Backup response = future.get();
- * }
- * }
- */
- public final OperationCallable
- copyBackupOperationCallable() {
- return stub.copyBackupOperationCallable();
- }
-
- // AUTO-GENERATED DOCUMENTATION AND METHOD.
- /**
- * Copy a Cloud Bigtable backup to a new backup in the destination cluster located in the
- * destination instance and project.
- *
- * 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 (BaseBigtableTableAdminClient baseBigtableTableAdminClient =
- * BaseBigtableTableAdminClient.create()) {
- * CopyBackupRequest request =
- * CopyBackupRequest.newBuilder()
- * .setParent(ClusterName.of("[PROJECT]", "[INSTANCE]", "[CLUSTER]").toString())
- * .setBackupId("backupId2121930365")
- * .setSourceBackup(
- * BackupName.of("[PROJECT]", "[INSTANCE]", "[CLUSTER]", "[BACKUP]").toString())
- * .setExpireTime(Timestamp.newBuilder().build())
- * .build();
- * ApiFuture future =
- * baseBigtableTableAdminClient.copyBackupCallable().futureCall(request);
- * // Do something.
- * Operation response = future.get();
- * }
- * }
- */
- public final UnaryCallable copyBackupCallable() {
- return stub.copyBackupCallable();
- }
-
- // AUTO-GENERATED DOCUMENTATION AND METHOD.
- /**
- * Gets the access control policy for a Table resource. Returns an empty policy if the resource
- * exists but does not have a policy set.
+ * Gets the access control policy for a Table or Backup resource. Returns an empty policy if the
+ * resource exists but does not have a policy set.
*
* Sample code:
*
@@ -3850,8 +3432,8 @@ public final Policy getIamPolicy(ResourceName resource) {
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
- * Gets the access control policy for a Table resource. Returns an empty policy if the resource
- * exists but does not have a policy set.
+ * Gets the access control policy for a Table or Backup resource. Returns an empty policy if the
+ * resource exists but does not have a policy set.
*
*
Sample code:
*
@@ -3879,8 +3461,8 @@ public final Policy getIamPolicy(String resource) {
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
- * Gets the access control policy for a Table resource. Returns an empty policy if the resource
- * exists but does not have a policy set.
+ * Gets the access control policy for a Table or Backup resource. Returns an empty policy if the
+ * resource exists but does not have a policy set.
*
*
Sample code:
*
@@ -3911,8 +3493,8 @@ public final Policy getIamPolicy(GetIamPolicyRequest request) {
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
- * Gets the access control policy for a Table resource. Returns an empty policy if the resource
- * exists but does not have a policy set.
+ * Gets the access control policy for a Table or Backup resource. Returns an empty policy if the
+ * resource exists but does not have a policy set.
*
*
Sample code:
*
@@ -3943,7 +3525,7 @@ public final UnaryCallable getIamPolicyCallable() {
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
- * Sets the access control policy on a Table resource. Replaces any existing policy.
+ * Sets the access control policy on a Table or Backup resource. Replaces any existing policy.
*
* Sample code:
*
@@ -3979,7 +3561,7 @@ public final Policy setIamPolicy(ResourceName resource, Policy policy) {
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
- * Sets the access control policy on a Table resource. Replaces any existing policy.
+ * Sets the access control policy on a Table or Backup resource. Replaces any existing policy.
*
*
Sample code:
*
@@ -4012,7 +3594,7 @@ public final Policy setIamPolicy(String resource, Policy policy) {
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
- * Sets the access control policy on a Table resource. Replaces any existing policy.
+ * Sets the access control policy on a Table or Backup resource. Replaces any existing policy.
*
*
Sample code:
*
@@ -4029,6 +3611,7 @@ public final Policy setIamPolicy(String resource, Policy policy) {
* .setResource(
* BackupName.of("[PROJECT]", "[INSTANCE]", "[CLUSTER]", "[BACKUP]").toString())
* .setPolicy(Policy.newBuilder().build())
+ * .setUpdateMask(FieldMask.newBuilder().build())
* .build();
* Policy response = baseBigtableTableAdminClient.setIamPolicy(request);
* }
@@ -4043,7 +3626,7 @@ public final Policy setIamPolicy(SetIamPolicyRequest request) {
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
- * Sets the access control policy on a Table resource. Replaces any existing policy.
+ * Sets the access control policy on a Table or Backup resource. Replaces any existing policy.
*
*
Sample code:
*
@@ -4060,6 +3643,7 @@ public final Policy setIamPolicy(SetIamPolicyRequest request) {
* .setResource(
* BackupName.of("[PROJECT]", "[INSTANCE]", "[CLUSTER]", "[BACKUP]").toString())
* .setPolicy(Policy.newBuilder().build())
+ * .setUpdateMask(FieldMask.newBuilder().build())
* .build();
* ApiFuture future =
* baseBigtableTableAdminClient.setIamPolicyCallable().futureCall(request);
@@ -4074,7 +3658,7 @@ public final UnaryCallable setIamPolicyCallable() {
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
- * Returns permissions that the caller has on the specified table resource.
+ * Returns permissions that the caller has on the specified Table or Backup resource.
*
* Sample code:
*
@@ -4112,7 +3696,7 @@ public final TestIamPermissionsResponse testIamPermissions(
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
- * Returns permissions that the caller has on the specified table resource.
+ * Returns permissions that the caller has on the specified Table or Backup resource.
*
*
Sample code:
*
@@ -4150,7 +3734,7 @@ public final TestIamPermissionsResponse testIamPermissions(
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
- * Returns permissions that the caller has on the specified table resource.
+ * Returns permissions that the caller has on the specified Table or Backup resource.
*
*
Sample code:
*
@@ -4182,7 +3766,7 @@ public final TestIamPermissionsResponse testIamPermissions(TestIamPermissionsReq
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
- * Returns permissions that the caller has on the specified table resource.
+ * Returns permissions that the caller has on the specified Table or Backup resource.
*
*
Sample code:
*
@@ -4208,7 +3792,7 @@ public final TestIamPermissionsResponse testIamPermissions(TestIamPermissionsReq
* }
*/
public final UnaryCallable
- testIamPermissionsCallable() {
+ testIamPermissionsCallable() {
return stub.testIamPermissionsCallable();
}
@@ -4244,11 +3828,11 @@ public boolean awaitTermination(long duration, TimeUnit unit) throws Interrupted
public static class ListTablesPagedResponse
extends AbstractPagedListResponse<
- ListTablesRequest,
- ListTablesResponse,
- Table,
- ListTablesPage,
- ListTablesFixedSizeCollection> {
+ ListTablesRequest,
+ ListTablesResponse,
+ Table,
+ ListTablesPage,
+ ListTablesFixedSizeCollection> {
public static ApiFuture createAsync(
PageContext context,
@@ -4294,11 +3878,11 @@ public ApiFuture createPageAsync(
public static class ListTablesFixedSizeCollection
extends AbstractFixedSizeCollection<
- ListTablesRequest,
- ListTablesResponse,
- Table,
- ListTablesPage,
- ListTablesFixedSizeCollection> {
+ ListTablesRequest,
+ ListTablesResponse,
+ Table,
+ ListTablesPage,
+ ListTablesFixedSizeCollection> {
private ListTablesFixedSizeCollection(List pages, int collectionSize) {
super(pages, collectionSize);
@@ -4317,11 +3901,11 @@ protected ListTablesFixedSizeCollection createCollection(
public static class ListSnapshotsPagedResponse
extends AbstractPagedListResponse<
- ListSnapshotsRequest,
- ListSnapshotsResponse,
- Snapshot,
- ListSnapshotsPage,
- ListSnapshotsFixedSizeCollection> {
+ ListSnapshotsRequest,
+ ListSnapshotsResponse,
+ Snapshot,
+ ListSnapshotsPage,
+ ListSnapshotsFixedSizeCollection> {
public static ApiFuture createAsync(
PageContext context,
@@ -4341,7 +3925,7 @@ private ListSnapshotsPagedResponse(ListSnapshotsPage page) {
public static class ListSnapshotsPage
extends AbstractPage<
- ListSnapshotsRequest, ListSnapshotsResponse, Snapshot, ListSnapshotsPage> {
+ ListSnapshotsRequest, ListSnapshotsResponse, Snapshot, ListSnapshotsPage> {
private ListSnapshotsPage(
PageContext context,
@@ -4370,11 +3954,11 @@ public ApiFuture createPageAsync(
public static class ListSnapshotsFixedSizeCollection
extends AbstractFixedSizeCollection<
- ListSnapshotsRequest,
- ListSnapshotsResponse,
- Snapshot,
- ListSnapshotsPage,
- ListSnapshotsFixedSizeCollection> {
+ ListSnapshotsRequest,
+ ListSnapshotsResponse,
+ Snapshot,
+ ListSnapshotsPage,
+ ListSnapshotsFixedSizeCollection> {
private ListSnapshotsFixedSizeCollection(List pages, int collectionSize) {
super(pages, collectionSize);
@@ -4393,11 +3977,11 @@ protected ListSnapshotsFixedSizeCollection createCollection(
public static class ListBackupsPagedResponse
extends AbstractPagedListResponse<
- ListBackupsRequest,
- ListBackupsResponse,
- Backup,
- ListBackupsPage,
- ListBackupsFixedSizeCollection> {
+ ListBackupsRequest,
+ ListBackupsResponse,
+ Backup,
+ ListBackupsPage,
+ ListBackupsFixedSizeCollection> {
public static ApiFuture createAsync(
PageContext context,
@@ -4443,11 +4027,11 @@ public ApiFuture createPageAsync(
public static class ListBackupsFixedSizeCollection
extends AbstractFixedSizeCollection<
- ListBackupsRequest,
- ListBackupsResponse,
- Backup,
- ListBackupsPage,
- ListBackupsFixedSizeCollection> {
+ ListBackupsRequest,
+ ListBackupsResponse,
+ Backup,
+ ListBackupsPage,
+ ListBackupsFixedSizeCollection> {
private ListBackupsFixedSizeCollection(List pages, int collectionSize) {
super(pages, collectionSize);
diff --git a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/BaseBigtableTableAdminSettings.java b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/BaseBigtableTableAdminSettings.java
index 6f08c1749f..7f353a0d68 100644
--- a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/BaseBigtableTableAdminSettings.java
+++ b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/BaseBigtableTableAdminSettings.java
@@ -36,8 +36,6 @@
import com.google.bigtable.admin.v2.Backup;
import com.google.bigtable.admin.v2.CheckConsistencyRequest;
import com.google.bigtable.admin.v2.CheckConsistencyResponse;
-import com.google.bigtable.admin.v2.CopyBackupMetadata;
-import com.google.bigtable.admin.v2.CopyBackupRequest;
import com.google.bigtable.admin.v2.CreateBackupMetadata;
import com.google.bigtable.admin.v2.CreateBackupRequest;
import com.google.bigtable.admin.v2.CreateTableFromSnapshotMetadata;
@@ -83,43 +81,7 @@
import javax.annotation.Generated;
// AUTO-GENERATED DOCUMENTATION AND CLASS.
-/**
- * Settings class to configure an instance of {@link BaseBigtableTableAdminClient}.
- *
- * The default instance has everything set to sensible defaults:
- *
- *
- * - The default service address (bigtableadmin.googleapis.com) and default port (443) are used.
- *
- Credentials are acquired automatically through Application Default Credentials.
- *
- Retries are configured for idempotent methods but not for non-idempotent methods.
- *
- *
- * The builder of this class is recursive, so contained classes are themselves builders. When
- * build() is called, the tree of builders is called to create the complete settings object.
- *
- *
For example, to set the total timeout of createTable to 30 seconds:
- *
- *
{@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
- * BaseBigtableTableAdminSettings.Builder baseBigtableTableAdminSettingsBuilder =
- * BaseBigtableTableAdminSettings.newBuilder();
- * baseBigtableTableAdminSettingsBuilder
- * .createTableSettings()
- * .setRetrySettings(
- * baseBigtableTableAdminSettingsBuilder
- * .createTableSettings()
- * .getRetrySettings()
- * .toBuilder()
- * .setTotalTimeout(Duration.ofSeconds(30))
- * .build());
- * BaseBigtableTableAdminSettings baseBigtableTableAdminSettings =
- * baseBigtableTableAdminSettingsBuilder.build();
- * }
- */
+/** For internal use only. */
@Generated("by gapic-generator")
@InternalApi
public class BaseBigtableTableAdminSettings extends ClientSettings {
@@ -273,17 +235,6 @@ public UnaryCallSettings restoreTableSettings()
return ((BigtableTableAdminStubSettings) getStubSettings()).restoreTableOperationSettings();
}
- /** Returns the object with the settings used for calls to copyBackup. */
- public UnaryCallSettings copyBackupSettings() {
- return ((BigtableTableAdminStubSettings) getStubSettings()).copyBackupSettings();
- }
-
- /** Returns the object with the settings used for calls to copyBackup. */
- public OperationCallSettings
- copyBackupOperationSettings() {
- return ((BigtableTableAdminStubSettings) getStubSettings()).copyBackupOperationSettings();
- }
-
/** Returns the object with the settings used for calls to getIamPolicy. */
public UnaryCallSettings getIamPolicySettings() {
return ((BigtableTableAdminStubSettings) getStubSettings()).getIamPolicySettings();
@@ -550,17 +501,6 @@ public UnaryCallSettings.Builder restoreTableSet
return getStubSettingsBuilder().restoreTableOperationSettings();
}
- /** Returns the builder for the settings used for calls to copyBackup. */
- public UnaryCallSettings.Builder copyBackupSettings() {
- return getStubSettingsBuilder().copyBackupSettings();
- }
-
- /** Returns the builder for the settings used for calls to copyBackup. */
- public OperationCallSettings.Builder
- copyBackupOperationSettings() {
- return getStubSettingsBuilder().copyBackupOperationSettings();
- }
-
/** Returns the builder for the settings used for calls to getIamPolicy. */
public UnaryCallSettings.Builder getIamPolicySettings() {
return getStubSettingsBuilder().getIamPolicySettings();
diff --git a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/stub/BigtableTableAdminStub.java b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/stub/BigtableTableAdminStub.java
index b29e1d03db..5f4bcd05a6 100644
--- a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/stub/BigtableTableAdminStub.java
+++ b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/stub/BigtableTableAdminStub.java
@@ -27,8 +27,6 @@
import com.google.bigtable.admin.v2.Backup;
import com.google.bigtable.admin.v2.CheckConsistencyRequest;
import com.google.bigtable.admin.v2.CheckConsistencyResponse;
-import com.google.bigtable.admin.v2.CopyBackupMetadata;
-import com.google.bigtable.admin.v2.CopyBackupRequest;
import com.google.bigtable.admin.v2.CreateBackupMetadata;
import com.google.bigtable.admin.v2.CreateBackupRequest;
import com.google.bigtable.admin.v2.CreateTableFromSnapshotMetadata;
@@ -72,11 +70,7 @@
import javax.annotation.Generated;
// AUTO-GENERATED DOCUMENTATION AND CLASS.
-/**
- * Base stub class for the BigtableTableAdmin service API.
- *
- * This class is for advanced usage and reflects the underlying API directly.
- */
+/** For internal use only. */
@Generated("by gapic-generator")
@InternalApi
public abstract class BigtableTableAdminStub implements BackgroundResource {
@@ -216,15 +210,6 @@ public UnaryCallable restoreTableCallable() {
throw new UnsupportedOperationException("Not implemented: restoreTableCallable()");
}
- public OperationCallable
- copyBackupOperationCallable() {
- throw new UnsupportedOperationException("Not implemented: copyBackupOperationCallable()");
- }
-
- public UnaryCallable copyBackupCallable() {
- throw new UnsupportedOperationException("Not implemented: copyBackupCallable()");
- }
-
public UnaryCallable getIamPolicyCallable() {
throw new UnsupportedOperationException("Not implemented: getIamPolicyCallable()");
}
diff --git a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/stub/BigtableTableAdminStubSettings.java b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/stub/BigtableTableAdminStubSettings.java
index 802774b593..ede9ad10c9 100644
--- a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/stub/BigtableTableAdminStubSettings.java
+++ b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/stub/BigtableTableAdminStubSettings.java
@@ -23,7 +23,6 @@
import com.google.api.core.ApiFunction;
import com.google.api.core.ApiFuture;
import com.google.api.core.BetaApi;
-import com.google.api.core.InternalApi;
import com.google.api.gax.core.GaxProperties;
import com.google.api.gax.core.GoogleCredentialsProvider;
import com.google.api.gax.core.InstantiatingExecutorProvider;
@@ -50,8 +49,6 @@
import com.google.bigtable.admin.v2.Backup;
import com.google.bigtable.admin.v2.CheckConsistencyRequest;
import com.google.bigtable.admin.v2.CheckConsistencyResponse;
-import com.google.bigtable.admin.v2.CopyBackupMetadata;
-import com.google.bigtable.admin.v2.CopyBackupRequest;
import com.google.bigtable.admin.v2.CreateBackupMetadata;
import com.google.bigtable.admin.v2.CreateBackupRequest;
import com.google.bigtable.admin.v2.CreateTableFromSnapshotMetadata;
@@ -138,8 +135,7 @@
* baseBigtableTableAdminSettingsBuilder.build();
* }
*/
-@Generated("by gapic-generator")
-@InternalApi
+@Generated("by gapic-generator-java")
public class BigtableTableAdminStubSettings extends StubSettings {
/** The default scopes of the service. */
private static final ImmutableList DEFAULT_SERVICE_SCOPES =
@@ -193,9 +189,6 @@ public class BigtableTableAdminStubSettings extends StubSettings restoreTableSettings;
private final OperationCallSettings
restoreTableOperationSettings;
- private final UnaryCallSettings copyBackupSettings;
- private final OperationCallSettings
- copyBackupOperationSettings;
private final UnaryCallSettings getIamPolicySettings;
private final UnaryCallSettings setIamPolicySettings;
private final UnaryCallSettings
@@ -508,17 +501,6 @@ public UnaryCallSettings restoreTableSettings()
return restoreTableOperationSettings;
}
- /** Returns the object with the settings used for calls to copyBackup. */
- public UnaryCallSettings copyBackupSettings() {
- return copyBackupSettings;
- }
-
- /** Returns the object with the settings used for calls to copyBackup. */
- public OperationCallSettings
- copyBackupOperationSettings() {
- return copyBackupOperationSettings;
- }
-
/** Returns the object with the settings used for calls to getIamPolicy. */
public UnaryCallSettings getIamPolicySettings() {
return getIamPolicySettings;
@@ -638,8 +620,6 @@ protected BigtableTableAdminStubSettings(Builder settingsBuilder) throws IOExcep
listBackupsSettings = settingsBuilder.listBackupsSettings().build();
restoreTableSettings = settingsBuilder.restoreTableSettings().build();
restoreTableOperationSettings = settingsBuilder.restoreTableOperationSettings().build();
- copyBackupSettings = settingsBuilder.copyBackupSettings().build();
- copyBackupOperationSettings = settingsBuilder.copyBackupOperationSettings().build();
getIamPolicySettings = settingsBuilder.getIamPolicySettings().build();
setIamPolicySettings = settingsBuilder.setIamPolicySettings().build();
testIamPermissionsSettings = settingsBuilder.testIamPermissionsSettings().build();
@@ -695,9 +675,6 @@ public static class Builder
private final UnaryCallSettings.Builder restoreTableSettings;
private final OperationCallSettings.Builder
restoreTableOperationSettings;
- private final UnaryCallSettings.Builder copyBackupSettings;
- private final OperationCallSettings.Builder
- copyBackupOperationSettings;
private final UnaryCallSettings.Builder getIamPolicySettings;
private final UnaryCallSettings.Builder setIamPolicySettings;
private final UnaryCallSettings.Builder
@@ -710,16 +687,21 @@ public static class Builder
ImmutableMap.builder();
definitions.put(
"no_retry_0_codes", ImmutableSet.copyOf(Lists.newArrayList()));
- definitions.put(
- "no_retry_1_codes", ImmutableSet.copyOf(Lists.newArrayList()));
+ definitions.put("no_retry_codes", ImmutableSet.copyOf(Lists.newArrayList()));
definitions.put(
"retry_policy_2_codes",
ImmutableSet.copyOf(
Lists.newArrayList(
StatusCode.Code.UNAVAILABLE, StatusCode.Code.DEADLINE_EXCEEDED)));
- definitions.put("no_retry_codes", ImmutableSet.copyOf(Lists.newArrayList()));
definitions.put(
- "no_retry_3_codes", ImmutableSet.copyOf(Lists.newArrayList()));
+ "no_retry_1_codes", ImmutableSet.copyOf(Lists.newArrayList()));
+ definitions.put(
+ "no_retry_4_codes", ImmutableSet.copyOf(Lists.newArrayList()));
+ definitions.put(
+ "retry_policy_3_codes",
+ ImmutableSet.copyOf(
+ Lists.newArrayList(
+ StatusCode.Code.UNAVAILABLE, StatusCode.Code.DEADLINE_EXCEEDED)));
RETRYABLE_CODE_DEFINITIONS = definitions.build();
}
@@ -736,27 +718,27 @@ public static class Builder
.setTotalTimeout(Duration.ofMillis(300000L))
.build();
definitions.put("no_retry_0_params", settings);
+ settings = RetrySettings.newBuilder().setRpcTimeoutMultiplier(1.0).build();
+ definitions.put("no_retry_params", settings);
settings =
RetrySettings.newBuilder()
+ .setInitialRetryDelay(Duration.ofMillis(1000L))
+ .setRetryDelayMultiplier(2.0)
+ .setMaxRetryDelay(Duration.ofMillis(60000L))
.setInitialRpcTimeout(Duration.ofMillis(60000L))
.setRpcTimeoutMultiplier(1.0)
.setMaxRpcTimeout(Duration.ofMillis(60000L))
.setTotalTimeout(Duration.ofMillis(60000L))
.build();
- definitions.put("no_retry_1_params", settings);
+ definitions.put("retry_policy_2_params", settings);
settings =
RetrySettings.newBuilder()
- .setInitialRetryDelay(Duration.ofMillis(1000L))
- .setRetryDelayMultiplier(2.0)
- .setMaxRetryDelay(Duration.ofMillis(60000L))
.setInitialRpcTimeout(Duration.ofMillis(60000L))
.setRpcTimeoutMultiplier(1.0)
.setMaxRpcTimeout(Duration.ofMillis(60000L))
.setTotalTimeout(Duration.ofMillis(60000L))
.build();
- definitions.put("retry_policy_2_params", settings);
- settings = RetrySettings.newBuilder().setRpcTimeoutMultiplier(1.0).build();
- definitions.put("no_retry_params", settings);
+ definitions.put("no_retry_1_params", settings);
settings =
RetrySettings.newBuilder()
.setInitialRpcTimeout(Duration.ofMillis(3600000L))
@@ -764,7 +746,18 @@ public static class Builder
.setMaxRpcTimeout(Duration.ofMillis(3600000L))
.setTotalTimeout(Duration.ofMillis(3600000L))
.build();
- definitions.put("no_retry_3_params", settings);
+ definitions.put("no_retry_4_params", settings);
+ settings =
+ RetrySettings.newBuilder()
+ .setInitialRetryDelay(Duration.ofMillis(1000L))
+ .setRetryDelayMultiplier(2.0)
+ .setMaxRetryDelay(Duration.ofMillis(60000L))
+ .setInitialRpcTimeout(Duration.ofMillis(60000L))
+ .setRpcTimeoutMultiplier(1.0)
+ .setMaxRpcTimeout(Duration.ofMillis(60000L))
+ .setTotalTimeout(Duration.ofMillis(60000L))
+ .build();
+ definitions.put("retry_policy_3_params", settings);
RETRY_PARAM_DEFINITIONS = definitions.build();
}
@@ -802,8 +795,6 @@ protected Builder(ClientContext clientContext) {
listBackupsSettings = PagedCallSettings.newBuilder(LIST_BACKUPS_PAGE_STR_FACT);
restoreTableSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
restoreTableOperationSettings = OperationCallSettings.newBuilder();
- copyBackupSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
- copyBackupOperationSettings = OperationCallSettings.newBuilder();
getIamPolicySettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
setIamPolicySettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
testIamPermissionsSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
@@ -831,7 +822,6 @@ protected Builder(ClientContext clientContext) {
deleteBackupSettings,
listBackupsSettings,
restoreTableSettings,
- copyBackupSettings,
getIamPolicySettings,
setIamPolicySettings,
testIamPermissionsSettings);
@@ -869,8 +859,6 @@ protected Builder(BigtableTableAdminStubSettings settings) {
listBackupsSettings = settings.listBackupsSettings.toBuilder();
restoreTableSettings = settings.restoreTableSettings.toBuilder();
restoreTableOperationSettings = settings.restoreTableOperationSettings.toBuilder();
- copyBackupSettings = settings.copyBackupSettings.toBuilder();
- copyBackupOperationSettings = settings.copyBackupOperationSettings.toBuilder();
getIamPolicySettings = settings.getIamPolicySettings.toBuilder();
setIamPolicySettings = settings.setIamPolicySettings.toBuilder();
testIamPermissionsSettings = settings.testIamPermissionsSettings.toBuilder();
@@ -898,7 +886,6 @@ protected Builder(BigtableTableAdminStubSettings settings) {
deleteBackupSettings,
listBackupsSettings,
restoreTableSettings,
- copyBackupSettings,
getIamPolicySettings,
setIamPolicySettings,
testIamPermissionsSettings);
@@ -925,8 +912,8 @@ private static Builder initDefaults(Builder builder) {
builder
.createTableFromSnapshotSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params"));
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
builder
.listTablesSettings()
@@ -960,23 +947,23 @@ private static Builder initDefaults(Builder builder) {
builder
.dropRowRangeSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_3_codes"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_3_params"));
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_4_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_4_params"));
builder
.generateConsistencyTokenSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_2_codes"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_2_params"));
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_3_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_3_params"));
builder
.checkConsistencySettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_2_codes"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_2_params"));
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_3_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_3_params"));
builder
.snapshotTableSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params"));
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
builder
.getSnapshotSettings()
@@ -985,8 +972,8 @@ private static Builder initDefaults(Builder builder) {
builder
.listSnapshotsSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_2_codes"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_2_params"));
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_3_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_3_params"));
builder
.deleteSnapshotSettings()
@@ -995,43 +982,38 @@ private static Builder initDefaults(Builder builder) {
builder
.createBackupSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params"));
builder
.getBackupSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_2_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_2_params"));
builder
.updateBackupSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params"));
builder
.deleteBackupSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params"));
builder
.listBackupsSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_2_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_2_params"));
builder
.restoreTableSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
-
- builder
- .copyBackupSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params"));
builder
.getIamPolicySettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_2_codes"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_2_params"));
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_3_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_3_params"));
builder
.setIamPolicySettings()
@@ -1040,16 +1022,16 @@ private static Builder initDefaults(Builder builder) {
builder
.testIamPermissionsSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_2_codes"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_2_params"));
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_3_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_3_params"));
builder
.createTableFromSnapshotOperationSettings()
.setInitialCallSettings(
UnaryCallSettings
.newUnaryCallSettingsBuilder()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params"))
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"))
.build())
.setResponseTransformer(
ProtoOperationTransformers.ResponseTransformer.create(Table.class))
@@ -1120,8 +1102,8 @@ private static Builder initDefaults(Builder builder) {
.setInitialCallSettings(
UnaryCallSettings
.newUnaryCallSettingsBuilder()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params"))
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"))
.build())
.setResponseTransformer(
ProtoOperationTransformers.ResponseTransformer.create(Snapshot.class))
@@ -1144,8 +1126,8 @@ private static Builder initDefaults(Builder builder) {
.setInitialCallSettings(
UnaryCallSettings
.newUnaryCallSettingsBuilder()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"))
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params"))
.build())
.setResponseTransformer(
ProtoOperationTransformers.ResponseTransformer.create(Backup.class))
@@ -1168,8 +1150,8 @@ private static Builder initDefaults(Builder builder) {
.setInitialCallSettings(
UnaryCallSettings
.newUnaryCallSettingsBuilder()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"))
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params"))
.build())
.setResponseTransformer(
ProtoOperationTransformers.ResponseTransformer.create(Table.class))
@@ -1187,29 +1169,6 @@ private static Builder initDefaults(Builder builder) {
.setTotalTimeout(Duration.ofMillis(600000L))
.build()));
- builder
- .copyBackupOperationSettings()
- .setInitialCallSettings(
- UnaryCallSettings.newUnaryCallSettingsBuilder()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"))
- .build())
- .setResponseTransformer(
- ProtoOperationTransformers.ResponseTransformer.create(Backup.class))
- .setMetadataTransformer(
- ProtoOperationTransformers.MetadataTransformer.create(CopyBackupMetadata.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;
}
@@ -1392,19 +1351,6 @@ public UnaryCallSettings.Builder restoreTableSet
return restoreTableOperationSettings;
}
- /** Returns the builder for the settings used for calls to copyBackup. */
- public UnaryCallSettings.Builder copyBackupSettings() {
- return copyBackupSettings;
- }
-
- /** Returns the builder for the settings used for calls to copyBackup. */
- @BetaApi(
- "The surface for use by generated code is not stable yet and may change in the future.")
- public OperationCallSettings.Builder
- copyBackupOperationSettings() {
- return copyBackupOperationSettings;
- }
-
/** Returns the builder for the settings used for calls to getIamPolicy. */
public UnaryCallSettings.Builder getIamPolicySettings() {
return getIamPolicySettings;
diff --git a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/stub/GrpcBigtableTableAdminStub.java b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/stub/GrpcBigtableTableAdminStub.java
index 15b56edf8a..c6be2b72b9 100644
--- a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/stub/GrpcBigtableTableAdminStub.java
+++ b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/stub/GrpcBigtableTableAdminStub.java
@@ -31,8 +31,6 @@
import com.google.bigtable.admin.v2.Backup;
import com.google.bigtable.admin.v2.CheckConsistencyRequest;
import com.google.bigtable.admin.v2.CheckConsistencyResponse;
-import com.google.bigtable.admin.v2.CopyBackupMetadata;
-import com.google.bigtable.admin.v2.CopyBackupRequest;
import com.google.bigtable.admin.v2.CreateBackupMetadata;
import com.google.bigtable.admin.v2.CreateBackupRequest;
import com.google.bigtable.admin.v2.CreateTableFromSnapshotMetadata;
@@ -81,11 +79,7 @@
import javax.annotation.Generated;
// AUTO-GENERATED DOCUMENTATION AND CLASS.
-/**
- * gRPC stub implementation for the BigtableTableAdmin service API.
- *
- * This class is for advanced usage and reflects the underlying API directly.
- */
+/** For internal use only. */
@Generated("by gapic-generator")
@InternalApi
public class GrpcBigtableTableAdminStub extends BigtableTableAdminStub {
@@ -285,14 +279,6 @@ public class GrpcBigtableTableAdminStub extends BigtableTableAdminStub {
.setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance()))
.build();
- private static final MethodDescriptor copyBackupMethodDescriptor =
- MethodDescriptor.newBuilder()
- .setType(MethodDescriptor.MethodType.UNARY)
- .setFullMethodName("google.bigtable.admin.v2.BigtableTableAdmin/CopyBackup")
- .setRequestMarshaller(ProtoUtils.marshaller(CopyBackupRequest.getDefaultInstance()))
- .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance()))
- .build();
-
private static final MethodDescriptor getIamPolicyMethodDescriptor =
MethodDescriptor.newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
@@ -362,9 +348,6 @@ public class GrpcBigtableTableAdminStub extends BigtableTableAdminStub {
private final UnaryCallable restoreTableCallable;
private final OperationCallable
restoreTableOperationCallable;
- private final UnaryCallable copyBackupCallable;
- private final OperationCallable
- copyBackupOperationCallable;
private final UnaryCallable getIamPolicyCallable;
private final UnaryCallable setIamPolicyCallable;
private final UnaryCallable
@@ -628,16 +611,6 @@ protected GrpcBigtableTableAdminStub(
return params.build();
})
.build();
- GrpcCallSettings copyBackupTransportSettings =
- GrpcCallSettings.newBuilder()
- .setMethodDescriptor(copyBackupMethodDescriptor)
- .setParamsExtractor(
- request -> {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("parent", String.valueOf(request.getParent()));
- return params.build();
- })
- .build();
GrpcCallSettings getIamPolicyTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(getIamPolicyMethodDescriptor)
@@ -784,15 +757,6 @@ protected GrpcBigtableTableAdminStub(
settings.restoreTableOperationSettings(),
clientContext,
operationsStub);
- this.copyBackupCallable =
- callableFactory.createUnaryCallable(
- copyBackupTransportSettings, settings.copyBackupSettings(), clientContext);
- this.copyBackupOperationCallable =
- callableFactory.createOperationCallable(
- copyBackupTransportSettings,
- settings.copyBackupOperationSettings(),
- clientContext,
- operationsStub);
this.getIamPolicyCallable =
callableFactory.createUnaryCallable(
getIamPolicyTransportSettings, settings.getIamPolicySettings(), clientContext);
@@ -973,17 +937,6 @@ public UnaryCallable restoreTableCallable() {
return restoreTableOperationCallable;
}
- @Override
- public UnaryCallable copyBackupCallable() {
- return copyBackupCallable;
- }
-
- @Override
- public OperationCallable
- copyBackupOperationCallable() {
- return copyBackupOperationCallable;
- }
-
@Override
public UnaryCallable getIamPolicyCallable() {
return getIamPolicyCallable;
diff --git a/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/admin/v2/BaseBigtableTableAdminClientTest.java b/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/admin/v2/BaseBigtableTableAdminClientTest.java
index 113a0797d2..6a79402f73 100644
--- a/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/admin/v2/BaseBigtableTableAdminClientTest.java
+++ b/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/admin/v2/BaseBigtableTableAdminClientTest.java
@@ -35,7 +35,6 @@
import com.google.bigtable.admin.v2.CheckConsistencyResponse;
import com.google.bigtable.admin.v2.ClusterName;
import com.google.bigtable.admin.v2.ColumnFamily;
-import com.google.bigtable.admin.v2.CopyBackupRequest;
import com.google.bigtable.admin.v2.CreateBackupRequest;
import com.google.bigtable.admin.v2.CreateTableFromSnapshotRequest;
import com.google.bigtable.admin.v2.CreateTableRequest;
@@ -68,6 +67,7 @@
import com.google.bigtable.admin.v2.UpdateBackupRequest;
import com.google.bigtable.admin.v2.UpdateTableRequest;
import com.google.common.collect.Lists;
+import com.google.iam.v1.AuditConfig;
import com.google.iam.v1.Binding;
import com.google.iam.v1.GetIamPolicyRequest;
import com.google.iam.v1.Policy;
@@ -1649,7 +1649,6 @@ public void createBackupTest() throws Exception {
Backup.newBuilder()
.setName(BackupName.of("[PROJECT]", "[INSTANCE]", "[CLUSTER]", "[BACKUP]").toString())
.setSourceTable("sourceTable-95372173")
- .setSourceBackup("sourceBackup823134653")
.setExpireTime(Timestamp.newBuilder().build())
.setStartTime(Timestamp.newBuilder().build())
.setEndTime(Timestamp.newBuilder().build())
@@ -1708,7 +1707,6 @@ public void createBackupTest2() throws Exception {
Backup.newBuilder()
.setName(BackupName.of("[PROJECT]", "[INSTANCE]", "[CLUSTER]", "[BACKUP]").toString())
.setSourceTable("sourceTable-95372173")
- .setSourceBackup("sourceBackup823134653")
.setExpireTime(Timestamp.newBuilder().build())
.setStartTime(Timestamp.newBuilder().build())
.setEndTime(Timestamp.newBuilder().build())
@@ -1767,7 +1765,6 @@ public void getBackupTest() throws Exception {
Backup.newBuilder()
.setName(BackupName.of("[PROJECT]", "[INSTANCE]", "[CLUSTER]", "[BACKUP]").toString())
.setSourceTable("sourceTable-95372173")
- .setSourceBackup("sourceBackup823134653")
.setExpireTime(Timestamp.newBuilder().build())
.setStartTime(Timestamp.newBuilder().build())
.setEndTime(Timestamp.newBuilder().build())
@@ -1812,7 +1809,6 @@ public void getBackupTest2() throws Exception {
Backup.newBuilder()
.setName(BackupName.of("[PROJECT]", "[INSTANCE]", "[CLUSTER]", "[BACKUP]").toString())
.setSourceTable("sourceTable-95372173")
- .setSourceBackup("sourceBackup823134653")
.setExpireTime(Timestamp.newBuilder().build())
.setStartTime(Timestamp.newBuilder().build())
.setEndTime(Timestamp.newBuilder().build())
@@ -1857,7 +1853,6 @@ public void updateBackupTest() throws Exception {
Backup.newBuilder()
.setName(BackupName.of("[PROJECT]", "[INSTANCE]", "[CLUSTER]", "[BACKUP]").toString())
.setSourceTable("sourceTable-95372173")
- .setSourceBackup("sourceBackup823134653")
.setExpireTime(Timestamp.newBuilder().build())
.setStartTime(Timestamp.newBuilder().build())
.setEndTime(Timestamp.newBuilder().build())
@@ -2115,264 +2110,13 @@ public void restoreTableExceptionTest() throws Exception {
}
}
- @Test
- public void copyBackupTest() throws Exception {
- Backup expectedResponse =
- Backup.newBuilder()
- .setName(BackupName.of("[PROJECT]", "[INSTANCE]", "[CLUSTER]", "[BACKUP]").toString())
- .setSourceTable("sourceTable-95372173")
- .setSourceBackup("sourceBackup823134653")
- .setExpireTime(Timestamp.newBuilder().build())
- .setStartTime(Timestamp.newBuilder().build())
- .setEndTime(Timestamp.newBuilder().build())
- .setSizeBytes(-1796325715)
- .setEncryptionInfo(EncryptionInfo.newBuilder().build())
- .build();
- Operation resultOperation =
- Operation.newBuilder()
- .setName("copyBackupTest")
- .setDone(true)
- .setResponse(Any.pack(expectedResponse))
- .build();
- mockBigtableTableAdmin.addResponse(resultOperation);
-
- ClusterName parent = ClusterName.of("[PROJECT]", "[INSTANCE]", "[CLUSTER]");
- String backupId = "backupId2121930365";
- BackupName sourceBackup = BackupName.of("[PROJECT]", "[INSTANCE]", "[CLUSTER]", "[BACKUP]");
- Timestamp expireTime = Timestamp.newBuilder().build();
-
- Backup actualResponse =
- client.copyBackupAsync(parent, backupId, sourceBackup, expireTime).get();
- Assert.assertEquals(expectedResponse, actualResponse);
-
- List actualRequests = mockBigtableTableAdmin.getRequests();
- Assert.assertEquals(1, actualRequests.size());
- CopyBackupRequest actualRequest = ((CopyBackupRequest) actualRequests.get(0));
-
- Assert.assertEquals(parent.toString(), actualRequest.getParent());
- Assert.assertEquals(backupId, actualRequest.getBackupId());
- Assert.assertEquals(sourceBackup.toString(), actualRequest.getSourceBackup());
- Assert.assertEquals(expireTime, actualRequest.getExpireTime());
- Assert.assertTrue(
- channelProvider.isHeaderSent(
- ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
- GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
- }
-
- @Test
- public void copyBackupExceptionTest() throws Exception {
- StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
- mockBigtableTableAdmin.addException(exception);
-
- try {
- ClusterName parent = ClusterName.of("[PROJECT]", "[INSTANCE]", "[CLUSTER]");
- String backupId = "backupId2121930365";
- BackupName sourceBackup = BackupName.of("[PROJECT]", "[INSTANCE]", "[CLUSTER]", "[BACKUP]");
- Timestamp expireTime = Timestamp.newBuilder().build();
- client.copyBackupAsync(parent, backupId, sourceBackup, expireTime).get();
- Assert.fail("No exception raised");
- } catch (ExecutionException e) {
- Assert.assertEquals(InvalidArgumentException.class, e.getCause().getClass());
- InvalidArgumentException apiException = ((InvalidArgumentException) e.getCause());
- Assert.assertEquals(StatusCode.Code.INVALID_ARGUMENT, apiException.getStatusCode().getCode());
- }
- }
-
- @Test
- public void copyBackupTest2() throws Exception {
- Backup expectedResponse =
- Backup.newBuilder()
- .setName(BackupName.of("[PROJECT]", "[INSTANCE]", "[CLUSTER]", "[BACKUP]").toString())
- .setSourceTable("sourceTable-95372173")
- .setSourceBackup("sourceBackup823134653")
- .setExpireTime(Timestamp.newBuilder().build())
- .setStartTime(Timestamp.newBuilder().build())
- .setEndTime(Timestamp.newBuilder().build())
- .setSizeBytes(-1796325715)
- .setEncryptionInfo(EncryptionInfo.newBuilder().build())
- .build();
- Operation resultOperation =
- Operation.newBuilder()
- .setName("copyBackupTest")
- .setDone(true)
- .setResponse(Any.pack(expectedResponse))
- .build();
- mockBigtableTableAdmin.addResponse(resultOperation);
-
- ClusterName parent = ClusterName.of("[PROJECT]", "[INSTANCE]", "[CLUSTER]");
- String backupId = "backupId2121930365";
- String sourceBackup = "sourceBackup823134653";
- Timestamp expireTime = Timestamp.newBuilder().build();
-
- Backup actualResponse =
- client.copyBackupAsync(parent, backupId, sourceBackup, expireTime).get();
- Assert.assertEquals(expectedResponse, actualResponse);
-
- List actualRequests = mockBigtableTableAdmin.getRequests();
- Assert.assertEquals(1, actualRequests.size());
- CopyBackupRequest actualRequest = ((CopyBackupRequest) actualRequests.get(0));
-
- Assert.assertEquals(parent.toString(), actualRequest.getParent());
- Assert.assertEquals(backupId, actualRequest.getBackupId());
- Assert.assertEquals(sourceBackup, actualRequest.getSourceBackup());
- Assert.assertEquals(expireTime, actualRequest.getExpireTime());
- Assert.assertTrue(
- channelProvider.isHeaderSent(
- ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
- GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
- }
-
- @Test
- public void copyBackupExceptionTest2() throws Exception {
- StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
- mockBigtableTableAdmin.addException(exception);
-
- try {
- ClusterName parent = ClusterName.of("[PROJECT]", "[INSTANCE]", "[CLUSTER]");
- String backupId = "backupId2121930365";
- String sourceBackup = "sourceBackup823134653";
- Timestamp expireTime = Timestamp.newBuilder().build();
- client.copyBackupAsync(parent, backupId, sourceBackup, expireTime).get();
- Assert.fail("No exception raised");
- } catch (ExecutionException e) {
- Assert.assertEquals(InvalidArgumentException.class, e.getCause().getClass());
- InvalidArgumentException apiException = ((InvalidArgumentException) e.getCause());
- Assert.assertEquals(StatusCode.Code.INVALID_ARGUMENT, apiException.getStatusCode().getCode());
- }
- }
-
- @Test
- public void copyBackupTest3() throws Exception {
- Backup expectedResponse =
- Backup.newBuilder()
- .setName(BackupName.of("[PROJECT]", "[INSTANCE]", "[CLUSTER]", "[BACKUP]").toString())
- .setSourceTable("sourceTable-95372173")
- .setSourceBackup("sourceBackup823134653")
- .setExpireTime(Timestamp.newBuilder().build())
- .setStartTime(Timestamp.newBuilder().build())
- .setEndTime(Timestamp.newBuilder().build())
- .setSizeBytes(-1796325715)
- .setEncryptionInfo(EncryptionInfo.newBuilder().build())
- .build();
- Operation resultOperation =
- Operation.newBuilder()
- .setName("copyBackupTest")
- .setDone(true)
- .setResponse(Any.pack(expectedResponse))
- .build();
- mockBigtableTableAdmin.addResponse(resultOperation);
-
- String parent = "parent-995424086";
- String backupId = "backupId2121930365";
- BackupName sourceBackup = BackupName.of("[PROJECT]", "[INSTANCE]", "[CLUSTER]", "[BACKUP]");
- Timestamp expireTime = Timestamp.newBuilder().build();
-
- Backup actualResponse =
- client.copyBackupAsync(parent, backupId, sourceBackup, expireTime).get();
- Assert.assertEquals(expectedResponse, actualResponse);
-
- List actualRequests = mockBigtableTableAdmin.getRequests();
- Assert.assertEquals(1, actualRequests.size());
- CopyBackupRequest actualRequest = ((CopyBackupRequest) actualRequests.get(0));
-
- Assert.assertEquals(parent, actualRequest.getParent());
- Assert.assertEquals(backupId, actualRequest.getBackupId());
- Assert.assertEquals(sourceBackup.toString(), actualRequest.getSourceBackup());
- Assert.assertEquals(expireTime, actualRequest.getExpireTime());
- Assert.assertTrue(
- channelProvider.isHeaderSent(
- ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
- GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
- }
-
- @Test
- public void copyBackupExceptionTest3() throws Exception {
- StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
- mockBigtableTableAdmin.addException(exception);
-
- try {
- String parent = "parent-995424086";
- String backupId = "backupId2121930365";
- BackupName sourceBackup = BackupName.of("[PROJECT]", "[INSTANCE]", "[CLUSTER]", "[BACKUP]");
- Timestamp expireTime = Timestamp.newBuilder().build();
- client.copyBackupAsync(parent, backupId, sourceBackup, expireTime).get();
- Assert.fail("No exception raised");
- } catch (ExecutionException e) {
- Assert.assertEquals(InvalidArgumentException.class, e.getCause().getClass());
- InvalidArgumentException apiException = ((InvalidArgumentException) e.getCause());
- Assert.assertEquals(StatusCode.Code.INVALID_ARGUMENT, apiException.getStatusCode().getCode());
- }
- }
-
- @Test
- public void copyBackupTest4() throws Exception {
- Backup expectedResponse =
- Backup.newBuilder()
- .setName(BackupName.of("[PROJECT]", "[INSTANCE]", "[CLUSTER]", "[BACKUP]").toString())
- .setSourceTable("sourceTable-95372173")
- .setSourceBackup("sourceBackup823134653")
- .setExpireTime(Timestamp.newBuilder().build())
- .setStartTime(Timestamp.newBuilder().build())
- .setEndTime(Timestamp.newBuilder().build())
- .setSizeBytes(-1796325715)
- .setEncryptionInfo(EncryptionInfo.newBuilder().build())
- .build();
- Operation resultOperation =
- Operation.newBuilder()
- .setName("copyBackupTest")
- .setDone(true)
- .setResponse(Any.pack(expectedResponse))
- .build();
- mockBigtableTableAdmin.addResponse(resultOperation);
-
- String parent = "parent-995424086";
- String backupId = "backupId2121930365";
- String sourceBackup = "sourceBackup823134653";
- Timestamp expireTime = Timestamp.newBuilder().build();
-
- Backup actualResponse =
- client.copyBackupAsync(parent, backupId, sourceBackup, expireTime).get();
- Assert.assertEquals(expectedResponse, actualResponse);
-
- List actualRequests = mockBigtableTableAdmin.getRequests();
- Assert.assertEquals(1, actualRequests.size());
- CopyBackupRequest actualRequest = ((CopyBackupRequest) actualRequests.get(0));
-
- Assert.assertEquals(parent, actualRequest.getParent());
- Assert.assertEquals(backupId, actualRequest.getBackupId());
- Assert.assertEquals(sourceBackup, actualRequest.getSourceBackup());
- Assert.assertEquals(expireTime, actualRequest.getExpireTime());
- Assert.assertTrue(
- channelProvider.isHeaderSent(
- ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
- GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
- }
-
- @Test
- public void copyBackupExceptionTest4() throws Exception {
- StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
- mockBigtableTableAdmin.addException(exception);
-
- try {
- String parent = "parent-995424086";
- String backupId = "backupId2121930365";
- String sourceBackup = "sourceBackup823134653";
- Timestamp expireTime = Timestamp.newBuilder().build();
- client.copyBackupAsync(parent, backupId, sourceBackup, expireTime).get();
- Assert.fail("No exception raised");
- } catch (ExecutionException e) {
- Assert.assertEquals(InvalidArgumentException.class, e.getCause().getClass());
- InvalidArgumentException apiException = ((InvalidArgumentException) e.getCause());
- Assert.assertEquals(StatusCode.Code.INVALID_ARGUMENT, apiException.getStatusCode().getCode());
- }
- }
-
@Test
public void getIamPolicyTest() throws Exception {
Policy expectedResponse =
Policy.newBuilder()
.setVersion(351608024)
.addAllBindings(new ArrayList())
+ .addAllAuditConfigs(new ArrayList())
.setEtag(ByteString.EMPTY)
.build();
mockBigtableTableAdmin.addResponse(expectedResponse);
@@ -2413,6 +2157,7 @@ public void getIamPolicyTest2() throws Exception {
Policy.newBuilder()
.setVersion(351608024)
.addAllBindings(new ArrayList())
+ .addAllAuditConfigs(new ArrayList())
.setEtag(ByteString.EMPTY)
.build();
mockBigtableTableAdmin.addResponse(expectedResponse);
@@ -2453,6 +2198,7 @@ public void setIamPolicyTest() throws Exception {
Policy.newBuilder()
.setVersion(351608024)
.addAllBindings(new ArrayList())
+ .addAllAuditConfigs(new ArrayList())
.setEtag(ByteString.EMPTY)
.build();
mockBigtableTableAdmin.addResponse(expectedResponse);
@@ -2496,6 +2242,7 @@ public void setIamPolicyTest2() throws Exception {
Policy.newBuilder()
.setVersion(351608024)
.addAllBindings(new ArrayList())
+ .addAllAuditConfigs(new ArrayList())
.setEtag(ByteString.EMPTY)
.build();
mockBigtableTableAdmin.addResponse(expectedResponse);
diff --git a/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/admin/v2/MockBigtableTableAdminImpl.java b/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/admin/v2/MockBigtableTableAdminImpl.java
index 33536953e9..211197811a 100644
--- a/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/admin/v2/MockBigtableTableAdminImpl.java
+++ b/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/admin/v2/MockBigtableTableAdminImpl.java
@@ -21,7 +21,6 @@
import com.google.bigtable.admin.v2.BigtableTableAdminGrpc.BigtableTableAdminImplBase;
import com.google.bigtable.admin.v2.CheckConsistencyRequest;
import com.google.bigtable.admin.v2.CheckConsistencyResponse;
-import com.google.bigtable.admin.v2.CopyBackupRequest;
import com.google.bigtable.admin.v2.CreateBackupRequest;
import com.google.bigtable.admin.v2.CreateTableFromSnapshotRequest;
import com.google.bigtable.admin.v2.CreateTableRequest;
@@ -528,26 +527,6 @@ public void restoreTable(
}
}
- @Override
- public void copyBackup(CopyBackupRequest request, StreamObserver responseObserver) {
- Object response = responses.poll();
- if (response instanceof Operation) {
- requests.add(request);
- responseObserver.onNext(((Operation) response));
- responseObserver.onCompleted();
- } else if (response instanceof Exception) {
- responseObserver.onError(((Exception) response));
- } else {
- responseObserver.onError(
- new IllegalArgumentException(
- String.format(
- "Unrecognized response type %s for method CopyBackup, expected %s or %s",
- response == null ? "null" : response.getClass().getName(),
- Operation.class.getName(),
- Exception.class.getName())));
- }
- }
-
@Override
public void getIamPolicy(GetIamPolicyRequest request, StreamObserver responseObserver) {
Object response = responses.poll();
diff --git a/grpc-google-cloud-bigtable-admin-v2/src/main/java/com/google/bigtable/admin/v2/BigtableTableAdminGrpc.java b/grpc-google-cloud-bigtable-admin-v2/src/main/java/com/google/bigtable/admin/v2/BigtableTableAdminGrpc.java
index 777aa9c4f7..b4d101214c 100644
--- a/grpc-google-cloud-bigtable-admin-v2/src/main/java/com/google/bigtable/admin/v2/BigtableTableAdminGrpc.java
+++ b/grpc-google-cloud-bigtable-admin-v2/src/main/java/com/google/bigtable/admin/v2/BigtableTableAdminGrpc.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2022 Google LLC
+ * Copyright 2020 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -18,6 +18,8 @@
import static io.grpc.MethodDescriptor.generateFullMethodName;
/**
+ *
+ *
*
* Service for creating, configuring, and deleting Cloud Bigtable tables.
* Provides access to the table schemas only, not the data stored within
@@ -35,789 +37,1067 @@ private BigtableTableAdminGrpc() {}
public static final String SERVICE_NAME = "google.bigtable.admin.v2.BigtableTableAdmin";
// Static method descriptors that strictly reflect the proto.
- private static volatile io.grpc.MethodDescriptor getCreateTableMethod;
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.CreateTableRequest, com.google.bigtable.admin.v2.Table>
+ getCreateTableMethod;
@io.grpc.stub.annotations.RpcMethod(
fullMethodName = SERVICE_NAME + '/' + "CreateTable",
requestType = com.google.bigtable.admin.v2.CreateTableRequest.class,
responseType = com.google.bigtable.admin.v2.Table.class,
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getCreateTableMethod() {
- io.grpc.MethodDescriptor getCreateTableMethod;
+ public static io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.CreateTableRequest, com.google.bigtable.admin.v2.Table>
+ getCreateTableMethod() {
+ io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.CreateTableRequest, com.google.bigtable.admin.v2.Table>
+ getCreateTableMethod;
if ((getCreateTableMethod = BigtableTableAdminGrpc.getCreateTableMethod) == null) {
synchronized (BigtableTableAdminGrpc.class) {
if ((getCreateTableMethod = BigtableTableAdminGrpc.getCreateTableMethod) == null) {
- BigtableTableAdminGrpc.getCreateTableMethod = getCreateTableMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "CreateTable"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.bigtable.admin.v2.CreateTableRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.bigtable.admin.v2.Table.getDefaultInstance()))
- .setSchemaDescriptor(new BigtableTableAdminMethodDescriptorSupplier("CreateTable"))
- .build();
+ BigtableTableAdminGrpc.getCreateTableMethod =
+ getCreateTableMethod =
+ io.grpc.MethodDescriptor
+ .
+ newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "CreateTable"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.bigtable.admin.v2.CreateTableRequest.getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.bigtable.admin.v2.Table.getDefaultInstance()))
+ .setSchemaDescriptor(
+ new BigtableTableAdminMethodDescriptorSupplier("CreateTable"))
+ .build();
}
}
}
return getCreateTableMethod;
}
- private static volatile io.grpc.MethodDescriptor getCreateTableFromSnapshotMethod;
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.CreateTableFromSnapshotRequest,
+ com.google.longrunning.Operation>
+ getCreateTableFromSnapshotMethod;
@io.grpc.stub.annotations.RpcMethod(
fullMethodName = SERVICE_NAME + '/' + "CreateTableFromSnapshot",
requestType = com.google.bigtable.admin.v2.CreateTableFromSnapshotRequest.class,
responseType = com.google.longrunning.Operation.class,
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getCreateTableFromSnapshotMethod() {
- io.grpc.MethodDescriptor getCreateTableFromSnapshotMethod;
- if ((getCreateTableFromSnapshotMethod = BigtableTableAdminGrpc.getCreateTableFromSnapshotMethod) == null) {
+ public static io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.CreateTableFromSnapshotRequest,
+ com.google.longrunning.Operation>
+ getCreateTableFromSnapshotMethod() {
+ io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.CreateTableFromSnapshotRequest,
+ com.google.longrunning.Operation>
+ getCreateTableFromSnapshotMethod;
+ if ((getCreateTableFromSnapshotMethod = BigtableTableAdminGrpc.getCreateTableFromSnapshotMethod)
+ == null) {
synchronized (BigtableTableAdminGrpc.class) {
- if ((getCreateTableFromSnapshotMethod = BigtableTableAdminGrpc.getCreateTableFromSnapshotMethod) == null) {
- BigtableTableAdminGrpc.getCreateTableFromSnapshotMethod = getCreateTableFromSnapshotMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "CreateTableFromSnapshot"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.bigtable.admin.v2.CreateTableFromSnapshotRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.longrunning.Operation.getDefaultInstance()))
- .setSchemaDescriptor(new BigtableTableAdminMethodDescriptorSupplier("CreateTableFromSnapshot"))
- .build();
+ if ((getCreateTableFromSnapshotMethod =
+ BigtableTableAdminGrpc.getCreateTableFromSnapshotMethod)
+ == null) {
+ BigtableTableAdminGrpc.getCreateTableFromSnapshotMethod =
+ getCreateTableFromSnapshotMethod =
+ io.grpc.MethodDescriptor
+ .
+ newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(
+ generateFullMethodName(SERVICE_NAME, "CreateTableFromSnapshot"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.bigtable.admin.v2.CreateTableFromSnapshotRequest
+ .getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.longrunning.Operation.getDefaultInstance()))
+ .setSchemaDescriptor(
+ new BigtableTableAdminMethodDescriptorSupplier("CreateTableFromSnapshot"))
+ .build();
}
}
}
return getCreateTableFromSnapshotMethod;
}
- private static volatile io.grpc.MethodDescriptor getListTablesMethod;
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.ListTablesRequest,
+ com.google.bigtable.admin.v2.ListTablesResponse>
+ getListTablesMethod;
@io.grpc.stub.annotations.RpcMethod(
fullMethodName = SERVICE_NAME + '/' + "ListTables",
requestType = com.google.bigtable.admin.v2.ListTablesRequest.class,
responseType = com.google.bigtable.admin.v2.ListTablesResponse.class,
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getListTablesMethod() {
- io.grpc.MethodDescriptor getListTablesMethod;
+ public static io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.ListTablesRequest,
+ com.google.bigtable.admin.v2.ListTablesResponse>
+ getListTablesMethod() {
+ io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.ListTablesRequest,
+ com.google.bigtable.admin.v2.ListTablesResponse>
+ getListTablesMethod;
if ((getListTablesMethod = BigtableTableAdminGrpc.getListTablesMethod) == null) {
synchronized (BigtableTableAdminGrpc.class) {
if ((getListTablesMethod = BigtableTableAdminGrpc.getListTablesMethod) == null) {
- BigtableTableAdminGrpc.getListTablesMethod = getListTablesMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListTables"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.bigtable.admin.v2.ListTablesRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.bigtable.admin.v2.ListTablesResponse.getDefaultInstance()))
- .setSchemaDescriptor(new BigtableTableAdminMethodDescriptorSupplier("ListTables"))
- .build();
+ BigtableTableAdminGrpc.getListTablesMethod =
+ getListTablesMethod =
+ io.grpc.MethodDescriptor
+ .
+ newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListTables"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.bigtable.admin.v2.ListTablesRequest.getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.bigtable.admin.v2.ListTablesResponse.getDefaultInstance()))
+ .setSchemaDescriptor(
+ new BigtableTableAdminMethodDescriptorSupplier("ListTables"))
+ .build();
}
}
}
return getListTablesMethod;
}
- private static volatile io.grpc.MethodDescriptor getGetTableMethod;
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.GetTableRequest, com.google.bigtable.admin.v2.Table>
+ getGetTableMethod;
@io.grpc.stub.annotations.RpcMethod(
fullMethodName = SERVICE_NAME + '/' + "GetTable",
requestType = com.google.bigtable.admin.v2.GetTableRequest.class,
responseType = com.google.bigtable.admin.v2.Table.class,
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getGetTableMethod() {
- io.grpc.MethodDescriptor getGetTableMethod;
+ public static io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.GetTableRequest, com.google.bigtable.admin.v2.Table>
+ getGetTableMethod() {
+ io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.GetTableRequest, com.google.bigtable.admin.v2.Table>
+ getGetTableMethod;
if ((getGetTableMethod = BigtableTableAdminGrpc.getGetTableMethod) == null) {
synchronized (BigtableTableAdminGrpc.class) {
if ((getGetTableMethod = BigtableTableAdminGrpc.getGetTableMethod) == null) {
- BigtableTableAdminGrpc.getGetTableMethod = getGetTableMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetTable"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.bigtable.admin.v2.GetTableRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.bigtable.admin.v2.Table.getDefaultInstance()))
- .setSchemaDescriptor(new BigtableTableAdminMethodDescriptorSupplier("GetTable"))
- .build();
+ BigtableTableAdminGrpc.getGetTableMethod =
+ getGetTableMethod =
+ io.grpc.MethodDescriptor
+ .
+ newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetTable"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.bigtable.admin.v2.GetTableRequest.getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.bigtable.admin.v2.Table.getDefaultInstance()))
+ .setSchemaDescriptor(
+ new BigtableTableAdminMethodDescriptorSupplier("GetTable"))
+ .build();
}
}
}
return getGetTableMethod;
}
- private static volatile io.grpc.MethodDescriptor getUpdateTableMethod;
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.UpdateTableRequest, com.google.longrunning.Operation>
+ getUpdateTableMethod;
@io.grpc.stub.annotations.RpcMethod(
fullMethodName = SERVICE_NAME + '/' + "UpdateTable",
requestType = com.google.bigtable.admin.v2.UpdateTableRequest.class,
responseType = com.google.longrunning.Operation.class,
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getUpdateTableMethod() {
- io.grpc.MethodDescriptor getUpdateTableMethod;
+ public static io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.UpdateTableRequest, com.google.longrunning.Operation>
+ getUpdateTableMethod() {
+ io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.UpdateTableRequest, com.google.longrunning.Operation>
+ getUpdateTableMethod;
if ((getUpdateTableMethod = BigtableTableAdminGrpc.getUpdateTableMethod) == null) {
synchronized (BigtableTableAdminGrpc.class) {
if ((getUpdateTableMethod = BigtableTableAdminGrpc.getUpdateTableMethod) == null) {
- BigtableTableAdminGrpc.getUpdateTableMethod = getUpdateTableMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "UpdateTable"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.bigtable.admin.v2.UpdateTableRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.longrunning.Operation.getDefaultInstance()))
- .setSchemaDescriptor(new BigtableTableAdminMethodDescriptorSupplier("UpdateTable"))
- .build();
+ BigtableTableAdminGrpc.getUpdateTableMethod =
+ getUpdateTableMethod =
+ io.grpc.MethodDescriptor
+ .
+ newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "UpdateTable"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.bigtable.admin.v2.UpdateTableRequest.getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.longrunning.Operation.getDefaultInstance()))
+ .setSchemaDescriptor(
+ new BigtableTableAdminMethodDescriptorSupplier("UpdateTable"))
+ .build();
}
}
}
return getUpdateTableMethod;
}
- private static volatile io.grpc.MethodDescriptor getDeleteTableMethod;
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.DeleteTableRequest, com.google.protobuf.Empty>
+ getDeleteTableMethod;
@io.grpc.stub.annotations.RpcMethod(
fullMethodName = SERVICE_NAME + '/' + "DeleteTable",
requestType = com.google.bigtable.admin.v2.DeleteTableRequest.class,
responseType = com.google.protobuf.Empty.class,
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getDeleteTableMethod() {
- io.grpc.MethodDescriptor getDeleteTableMethod;
+ public static io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.DeleteTableRequest, com.google.protobuf.Empty>
+ getDeleteTableMethod() {
+ io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.DeleteTableRequest, com.google.protobuf.Empty>
+ getDeleteTableMethod;
if ((getDeleteTableMethod = BigtableTableAdminGrpc.getDeleteTableMethod) == null) {
synchronized (BigtableTableAdminGrpc.class) {
if ((getDeleteTableMethod = BigtableTableAdminGrpc.getDeleteTableMethod) == null) {
- BigtableTableAdminGrpc.getDeleteTableMethod = getDeleteTableMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "DeleteTable"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.bigtable.admin.v2.DeleteTableRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.protobuf.Empty.getDefaultInstance()))
- .setSchemaDescriptor(new BigtableTableAdminMethodDescriptorSupplier("DeleteTable"))
- .build();
+ BigtableTableAdminGrpc.getDeleteTableMethod =
+ getDeleteTableMethod =
+ io.grpc.MethodDescriptor
+ .
+ newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "DeleteTable"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.bigtable.admin.v2.DeleteTableRequest.getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.protobuf.Empty.getDefaultInstance()))
+ .setSchemaDescriptor(
+ new BigtableTableAdminMethodDescriptorSupplier("DeleteTable"))
+ .build();
}
}
}
return getDeleteTableMethod;
}
- private static volatile io.grpc.MethodDescriptor getUndeleteTableMethod;
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.UndeleteTableRequest, com.google.longrunning.Operation>
+ getUndeleteTableMethod;
@io.grpc.stub.annotations.RpcMethod(
fullMethodName = SERVICE_NAME + '/' + "UndeleteTable",
requestType = com.google.bigtable.admin.v2.UndeleteTableRequest.class,
responseType = com.google.longrunning.Operation.class,
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getUndeleteTableMethod() {
- io.grpc.MethodDescriptor getUndeleteTableMethod;
+ public static io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.UndeleteTableRequest, com.google.longrunning.Operation>
+ getUndeleteTableMethod() {
+ io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.UndeleteTableRequest, com.google.longrunning.Operation>
+ getUndeleteTableMethod;
if ((getUndeleteTableMethod = BigtableTableAdminGrpc.getUndeleteTableMethod) == null) {
synchronized (BigtableTableAdminGrpc.class) {
if ((getUndeleteTableMethod = BigtableTableAdminGrpc.getUndeleteTableMethod) == null) {
- BigtableTableAdminGrpc.getUndeleteTableMethod = getUndeleteTableMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "UndeleteTable"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.bigtable.admin.v2.UndeleteTableRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.longrunning.Operation.getDefaultInstance()))
- .setSchemaDescriptor(new BigtableTableAdminMethodDescriptorSupplier("UndeleteTable"))
- .build();
+ BigtableTableAdminGrpc.getUndeleteTableMethod =
+ getUndeleteTableMethod =
+ io.grpc.MethodDescriptor
+ .
+ newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "UndeleteTable"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.bigtable.admin.v2.UndeleteTableRequest
+ .getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.longrunning.Operation.getDefaultInstance()))
+ .setSchemaDescriptor(
+ new BigtableTableAdminMethodDescriptorSupplier("UndeleteTable"))
+ .build();
}
}
}
return getUndeleteTableMethod;
}
- private static volatile io.grpc.MethodDescriptor getModifyColumnFamiliesMethod;
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.ModifyColumnFamiliesRequest,
+ com.google.bigtable.admin.v2.Table>
+ getModifyColumnFamiliesMethod;
@io.grpc.stub.annotations.RpcMethod(
fullMethodName = SERVICE_NAME + '/' + "ModifyColumnFamilies",
requestType = com.google.bigtable.admin.v2.ModifyColumnFamiliesRequest.class,
responseType = com.google.bigtable.admin.v2.Table.class,
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getModifyColumnFamiliesMethod() {
- io.grpc.MethodDescriptor getModifyColumnFamiliesMethod;
- if ((getModifyColumnFamiliesMethod = BigtableTableAdminGrpc.getModifyColumnFamiliesMethod) == null) {
+ public static io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.ModifyColumnFamiliesRequest,
+ com.google.bigtable.admin.v2.Table>
+ getModifyColumnFamiliesMethod() {
+ io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.ModifyColumnFamiliesRequest,
+ com.google.bigtable.admin.v2.Table>
+ getModifyColumnFamiliesMethod;
+ if ((getModifyColumnFamiliesMethod = BigtableTableAdminGrpc.getModifyColumnFamiliesMethod)
+ == null) {
synchronized (BigtableTableAdminGrpc.class) {
- if ((getModifyColumnFamiliesMethod = BigtableTableAdminGrpc.getModifyColumnFamiliesMethod) == null) {
- BigtableTableAdminGrpc.getModifyColumnFamiliesMethod = getModifyColumnFamiliesMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ModifyColumnFamilies"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.bigtable.admin.v2.ModifyColumnFamiliesRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.bigtable.admin.v2.Table.getDefaultInstance()))
- .setSchemaDescriptor(new BigtableTableAdminMethodDescriptorSupplier("ModifyColumnFamilies"))
- .build();
+ if ((getModifyColumnFamiliesMethod = BigtableTableAdminGrpc.getModifyColumnFamiliesMethod)
+ == null) {
+ BigtableTableAdminGrpc.getModifyColumnFamiliesMethod =
+ getModifyColumnFamiliesMethod =
+ io.grpc.MethodDescriptor
+ .
+ newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(
+ generateFullMethodName(SERVICE_NAME, "ModifyColumnFamilies"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.bigtable.admin.v2.ModifyColumnFamiliesRequest
+ .getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.bigtable.admin.v2.Table.getDefaultInstance()))
+ .setSchemaDescriptor(
+ new BigtableTableAdminMethodDescriptorSupplier("ModifyColumnFamilies"))
+ .build();
}
}
}
return getModifyColumnFamiliesMethod;
}
- private static volatile io.grpc.MethodDescriptor getDropRowRangeMethod;
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.DropRowRangeRequest, com.google.protobuf.Empty>
+ getDropRowRangeMethod;
@io.grpc.stub.annotations.RpcMethod(
fullMethodName = SERVICE_NAME + '/' + "DropRowRange",
requestType = com.google.bigtable.admin.v2.DropRowRangeRequest.class,
responseType = com.google.protobuf.Empty.class,
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getDropRowRangeMethod() {
- io.grpc.MethodDescriptor getDropRowRangeMethod;
+ public static io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.DropRowRangeRequest, com.google.protobuf.Empty>
+ getDropRowRangeMethod() {
+ io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.DropRowRangeRequest, com.google.protobuf.Empty>
+ getDropRowRangeMethod;
if ((getDropRowRangeMethod = BigtableTableAdminGrpc.getDropRowRangeMethod) == null) {
synchronized (BigtableTableAdminGrpc.class) {
if ((getDropRowRangeMethod = BigtableTableAdminGrpc.getDropRowRangeMethod) == null) {
- BigtableTableAdminGrpc.getDropRowRangeMethod = getDropRowRangeMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "DropRowRange"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.bigtable.admin.v2.DropRowRangeRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.protobuf.Empty.getDefaultInstance()))
- .setSchemaDescriptor(new BigtableTableAdminMethodDescriptorSupplier("DropRowRange"))
- .build();
+ BigtableTableAdminGrpc.getDropRowRangeMethod =
+ getDropRowRangeMethod =
+ io.grpc.MethodDescriptor
+ .
+ newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "DropRowRange"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.bigtable.admin.v2.DropRowRangeRequest
+ .getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.protobuf.Empty.getDefaultInstance()))
+ .setSchemaDescriptor(
+ new BigtableTableAdminMethodDescriptorSupplier("DropRowRange"))
+ .build();
}
}
}
return getDropRowRangeMethod;
}
- private static volatile io.grpc.MethodDescriptor getGenerateConsistencyTokenMethod;
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.GenerateConsistencyTokenRequest,
+ com.google.bigtable.admin.v2.GenerateConsistencyTokenResponse>
+ getGenerateConsistencyTokenMethod;
@io.grpc.stub.annotations.RpcMethod(
fullMethodName = SERVICE_NAME + '/' + "GenerateConsistencyToken",
requestType = com.google.bigtable.admin.v2.GenerateConsistencyTokenRequest.class,
responseType = com.google.bigtable.admin.v2.GenerateConsistencyTokenResponse.class,
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getGenerateConsistencyTokenMethod() {
- io.grpc.MethodDescriptor getGenerateConsistencyTokenMethod;
- if ((getGenerateConsistencyTokenMethod = BigtableTableAdminGrpc.getGenerateConsistencyTokenMethod) == null) {
+ public static io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.GenerateConsistencyTokenRequest,
+ com.google.bigtable.admin.v2.GenerateConsistencyTokenResponse>
+ getGenerateConsistencyTokenMethod() {
+ io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.GenerateConsistencyTokenRequest,
+ com.google.bigtable.admin.v2.GenerateConsistencyTokenResponse>
+ getGenerateConsistencyTokenMethod;
+ if ((getGenerateConsistencyTokenMethod =
+ BigtableTableAdminGrpc.getGenerateConsistencyTokenMethod)
+ == null) {
synchronized (BigtableTableAdminGrpc.class) {
- if ((getGenerateConsistencyTokenMethod = BigtableTableAdminGrpc.getGenerateConsistencyTokenMethod) == null) {
- BigtableTableAdminGrpc.getGenerateConsistencyTokenMethod = getGenerateConsistencyTokenMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GenerateConsistencyToken"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.bigtable.admin.v2.GenerateConsistencyTokenRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.bigtable.admin.v2.GenerateConsistencyTokenResponse.getDefaultInstance()))
- .setSchemaDescriptor(new BigtableTableAdminMethodDescriptorSupplier("GenerateConsistencyToken"))
- .build();
+ if ((getGenerateConsistencyTokenMethod =
+ BigtableTableAdminGrpc.getGenerateConsistencyTokenMethod)
+ == null) {
+ BigtableTableAdminGrpc.getGenerateConsistencyTokenMethod =
+ getGenerateConsistencyTokenMethod =
+ io.grpc.MethodDescriptor
+ .
+ newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(
+ generateFullMethodName(SERVICE_NAME, "GenerateConsistencyToken"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.bigtable.admin.v2.GenerateConsistencyTokenRequest
+ .getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.bigtable.admin.v2.GenerateConsistencyTokenResponse
+ .getDefaultInstance()))
+ .setSchemaDescriptor(
+ new BigtableTableAdminMethodDescriptorSupplier(
+ "GenerateConsistencyToken"))
+ .build();
}
}
}
return getGenerateConsistencyTokenMethod;
}
- private static volatile io.grpc.MethodDescriptor getCheckConsistencyMethod;
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.CheckConsistencyRequest,
+ com.google.bigtable.admin.v2.CheckConsistencyResponse>
+ getCheckConsistencyMethod;
@io.grpc.stub.annotations.RpcMethod(
fullMethodName = SERVICE_NAME + '/' + "CheckConsistency",
requestType = com.google.bigtable.admin.v2.CheckConsistencyRequest.class,
responseType = com.google.bigtable.admin.v2.CheckConsistencyResponse.class,
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getCheckConsistencyMethod() {
- io.grpc.MethodDescriptor getCheckConsistencyMethod;
+ public static io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.CheckConsistencyRequest,
+ com.google.bigtable.admin.v2.CheckConsistencyResponse>
+ getCheckConsistencyMethod() {
+ io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.CheckConsistencyRequest,
+ com.google.bigtable.admin.v2.CheckConsistencyResponse>
+ getCheckConsistencyMethod;
if ((getCheckConsistencyMethod = BigtableTableAdminGrpc.getCheckConsistencyMethod) == null) {
synchronized (BigtableTableAdminGrpc.class) {
- if ((getCheckConsistencyMethod = BigtableTableAdminGrpc.getCheckConsistencyMethod) == null) {
- BigtableTableAdminGrpc.getCheckConsistencyMethod = getCheckConsistencyMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "CheckConsistency"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.bigtable.admin.v2.CheckConsistencyRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.bigtable.admin.v2.CheckConsistencyResponse.getDefaultInstance()))
- .setSchemaDescriptor(new BigtableTableAdminMethodDescriptorSupplier("CheckConsistency"))
- .build();
+ if ((getCheckConsistencyMethod = BigtableTableAdminGrpc.getCheckConsistencyMethod)
+ == null) {
+ BigtableTableAdminGrpc.getCheckConsistencyMethod =
+ getCheckConsistencyMethod =
+ io.grpc.MethodDescriptor
+ .
+ newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "CheckConsistency"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.bigtable.admin.v2.CheckConsistencyRequest
+ .getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.bigtable.admin.v2.CheckConsistencyResponse
+ .getDefaultInstance()))
+ .setSchemaDescriptor(
+ new BigtableTableAdminMethodDescriptorSupplier("CheckConsistency"))
+ .build();
}
}
}
return getCheckConsistencyMethod;
}
- private static volatile io.grpc.MethodDescriptor getSnapshotTableMethod;
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.SnapshotTableRequest, com.google.longrunning.Operation>
+ getSnapshotTableMethod;
@io.grpc.stub.annotations.RpcMethod(
fullMethodName = SERVICE_NAME + '/' + "SnapshotTable",
requestType = com.google.bigtable.admin.v2.SnapshotTableRequest.class,
responseType = com.google.longrunning.Operation.class,
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getSnapshotTableMethod() {
- io.grpc.MethodDescriptor getSnapshotTableMethod;
+ public static io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.SnapshotTableRequest, com.google.longrunning.Operation>
+ getSnapshotTableMethod() {
+ io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.SnapshotTableRequest, com.google.longrunning.Operation>
+ getSnapshotTableMethod;
if ((getSnapshotTableMethod = BigtableTableAdminGrpc.getSnapshotTableMethod) == null) {
synchronized (BigtableTableAdminGrpc.class) {
if ((getSnapshotTableMethod = BigtableTableAdminGrpc.getSnapshotTableMethod) == null) {
- BigtableTableAdminGrpc.getSnapshotTableMethod = getSnapshotTableMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "SnapshotTable"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.bigtable.admin.v2.SnapshotTableRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.longrunning.Operation.getDefaultInstance()))
- .setSchemaDescriptor(new BigtableTableAdminMethodDescriptorSupplier("SnapshotTable"))
- .build();
+ BigtableTableAdminGrpc.getSnapshotTableMethod =
+ getSnapshotTableMethod =
+ io.grpc.MethodDescriptor
+ .
+ newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "SnapshotTable"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.bigtable.admin.v2.SnapshotTableRequest
+ .getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.longrunning.Operation.getDefaultInstance()))
+ .setSchemaDescriptor(
+ new BigtableTableAdminMethodDescriptorSupplier("SnapshotTable"))
+ .build();
}
}
}
return getSnapshotTableMethod;
}
- private static volatile io.grpc.MethodDescriptor getGetSnapshotMethod;
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.GetSnapshotRequest, com.google.bigtable.admin.v2.Snapshot>
+ getGetSnapshotMethod;
@io.grpc.stub.annotations.RpcMethod(
fullMethodName = SERVICE_NAME + '/' + "GetSnapshot",
requestType = com.google.bigtable.admin.v2.GetSnapshotRequest.class,
responseType = com.google.bigtable.admin.v2.Snapshot.class,
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getGetSnapshotMethod() {
- io.grpc.MethodDescriptor getGetSnapshotMethod;
+ public static io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.GetSnapshotRequest, com.google.bigtable.admin.v2.Snapshot>
+ getGetSnapshotMethod() {
+ io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.GetSnapshotRequest, com.google.bigtable.admin.v2.Snapshot>
+ getGetSnapshotMethod;
if ((getGetSnapshotMethod = BigtableTableAdminGrpc.getGetSnapshotMethod) == null) {
synchronized (BigtableTableAdminGrpc.class) {
if ((getGetSnapshotMethod = BigtableTableAdminGrpc.getGetSnapshotMethod) == null) {
- BigtableTableAdminGrpc.getGetSnapshotMethod = getGetSnapshotMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetSnapshot"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.bigtable.admin.v2.GetSnapshotRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.bigtable.admin.v2.Snapshot.getDefaultInstance()))
- .setSchemaDescriptor(new BigtableTableAdminMethodDescriptorSupplier("GetSnapshot"))
- .build();
+ BigtableTableAdminGrpc.getGetSnapshotMethod =
+ getGetSnapshotMethod =
+ io.grpc.MethodDescriptor
+ .
+ newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetSnapshot"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.bigtable.admin.v2.GetSnapshotRequest.getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.bigtable.admin.v2.Snapshot.getDefaultInstance()))
+ .setSchemaDescriptor(
+ new BigtableTableAdminMethodDescriptorSupplier("GetSnapshot"))
+ .build();
}
}
}
return getGetSnapshotMethod;
}
- private static volatile io.grpc.MethodDescriptor getListSnapshotsMethod;
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.ListSnapshotsRequest,
+ com.google.bigtable.admin.v2.ListSnapshotsResponse>
+ getListSnapshotsMethod;
@io.grpc.stub.annotations.RpcMethod(
fullMethodName = SERVICE_NAME + '/' + "ListSnapshots",
requestType = com.google.bigtable.admin.v2.ListSnapshotsRequest.class,
responseType = com.google.bigtable.admin.v2.ListSnapshotsResponse.class,
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getListSnapshotsMethod() {
- io.grpc.MethodDescriptor getListSnapshotsMethod;
+ public static io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.ListSnapshotsRequest,
+ com.google.bigtable.admin.v2.ListSnapshotsResponse>
+ getListSnapshotsMethod() {
+ io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.ListSnapshotsRequest,
+ com.google.bigtable.admin.v2.ListSnapshotsResponse>
+ getListSnapshotsMethod;
if ((getListSnapshotsMethod = BigtableTableAdminGrpc.getListSnapshotsMethod) == null) {
synchronized (BigtableTableAdminGrpc.class) {
if ((getListSnapshotsMethod = BigtableTableAdminGrpc.getListSnapshotsMethod) == null) {
- BigtableTableAdminGrpc.getListSnapshotsMethod = getListSnapshotsMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListSnapshots"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.bigtable.admin.v2.ListSnapshotsRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.bigtable.admin.v2.ListSnapshotsResponse.getDefaultInstance()))
- .setSchemaDescriptor(new BigtableTableAdminMethodDescriptorSupplier("ListSnapshots"))
- .build();
+ BigtableTableAdminGrpc.getListSnapshotsMethod =
+ getListSnapshotsMethod =
+ io.grpc.MethodDescriptor
+ .
+ newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListSnapshots"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.bigtable.admin.v2.ListSnapshotsRequest
+ .getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.bigtable.admin.v2.ListSnapshotsResponse
+ .getDefaultInstance()))
+ .setSchemaDescriptor(
+ new BigtableTableAdminMethodDescriptorSupplier("ListSnapshots"))
+ .build();
}
}
}
return getListSnapshotsMethod;
}
- private static volatile io.grpc.MethodDescriptor getDeleteSnapshotMethod;
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.DeleteSnapshotRequest, com.google.protobuf.Empty>
+ getDeleteSnapshotMethod;
@io.grpc.stub.annotations.RpcMethod(
fullMethodName = SERVICE_NAME + '/' + "DeleteSnapshot",
requestType = com.google.bigtable.admin.v2.DeleteSnapshotRequest.class,
responseType = com.google.protobuf.Empty.class,
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getDeleteSnapshotMethod() {
- io.grpc.MethodDescriptor getDeleteSnapshotMethod;
+ public static io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.DeleteSnapshotRequest, com.google.protobuf.Empty>
+ getDeleteSnapshotMethod() {
+ io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.DeleteSnapshotRequest, com.google.protobuf.Empty>
+ getDeleteSnapshotMethod;
if ((getDeleteSnapshotMethod = BigtableTableAdminGrpc.getDeleteSnapshotMethod) == null) {
synchronized (BigtableTableAdminGrpc.class) {
if ((getDeleteSnapshotMethod = BigtableTableAdminGrpc.getDeleteSnapshotMethod) == null) {
- BigtableTableAdminGrpc.getDeleteSnapshotMethod = getDeleteSnapshotMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "DeleteSnapshot"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.bigtable.admin.v2.DeleteSnapshotRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.protobuf.Empty.getDefaultInstance()))
- .setSchemaDescriptor(new BigtableTableAdminMethodDescriptorSupplier("DeleteSnapshot"))
- .build();
+ BigtableTableAdminGrpc.getDeleteSnapshotMethod =
+ getDeleteSnapshotMethod =
+ io.grpc.MethodDescriptor
+ .
+ newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "DeleteSnapshot"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.bigtable.admin.v2.DeleteSnapshotRequest
+ .getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.protobuf.Empty.getDefaultInstance()))
+ .setSchemaDescriptor(
+ new BigtableTableAdminMethodDescriptorSupplier("DeleteSnapshot"))
+ .build();
}
}
}
return getDeleteSnapshotMethod;
}
- private static volatile io.grpc.MethodDescriptor getCreateBackupMethod;
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.CreateBackupRequest, com.google.longrunning.Operation>
+ getCreateBackupMethod;
@io.grpc.stub.annotations.RpcMethod(
fullMethodName = SERVICE_NAME + '/' + "CreateBackup",
requestType = com.google.bigtable.admin.v2.CreateBackupRequest.class,
responseType = com.google.longrunning.Operation.class,
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getCreateBackupMethod() {
- io.grpc.MethodDescriptor getCreateBackupMethod;
+ public static io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.CreateBackupRequest, com.google.longrunning.Operation>
+ getCreateBackupMethod() {
+ io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.CreateBackupRequest, com.google.longrunning.Operation>
+ getCreateBackupMethod;
if ((getCreateBackupMethod = BigtableTableAdminGrpc.getCreateBackupMethod) == null) {
synchronized (BigtableTableAdminGrpc.class) {
if ((getCreateBackupMethod = BigtableTableAdminGrpc.getCreateBackupMethod) == null) {
- BigtableTableAdminGrpc.getCreateBackupMethod = getCreateBackupMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "CreateBackup"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.bigtable.admin.v2.CreateBackupRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.longrunning.Operation.getDefaultInstance()))
- .setSchemaDescriptor(new BigtableTableAdminMethodDescriptorSupplier("CreateBackup"))
- .build();
+ BigtableTableAdminGrpc.getCreateBackupMethod =
+ getCreateBackupMethod =
+ io.grpc.MethodDescriptor
+ .
+ newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "CreateBackup"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.bigtable.admin.v2.CreateBackupRequest
+ .getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.longrunning.Operation.getDefaultInstance()))
+ .setSchemaDescriptor(
+ new BigtableTableAdminMethodDescriptorSupplier("CreateBackup"))
+ .build();
}
}
}
return getCreateBackupMethod;
}
- private static volatile io.grpc.MethodDescriptor getGetBackupMethod;
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.GetBackupRequest, com.google.bigtable.admin.v2.Backup>
+ getGetBackupMethod;
@io.grpc.stub.annotations.RpcMethod(
fullMethodName = SERVICE_NAME + '/' + "GetBackup",
requestType = com.google.bigtable.admin.v2.GetBackupRequest.class,
responseType = com.google.bigtable.admin.v2.Backup.class,
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getGetBackupMethod() {
- io.grpc.MethodDescriptor getGetBackupMethod;
+ public static io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.GetBackupRequest, com.google.bigtable.admin.v2.Backup>
+ getGetBackupMethod() {
+ io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.GetBackupRequest, com.google.bigtable.admin.v2.Backup>
+ getGetBackupMethod;
if ((getGetBackupMethod = BigtableTableAdminGrpc.getGetBackupMethod) == null) {
synchronized (BigtableTableAdminGrpc.class) {
if ((getGetBackupMethod = BigtableTableAdminGrpc.getGetBackupMethod) == null) {
- BigtableTableAdminGrpc.getGetBackupMethod = getGetBackupMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetBackup"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.bigtable.admin.v2.GetBackupRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.bigtable.admin.v2.Backup.getDefaultInstance()))
- .setSchemaDescriptor(new BigtableTableAdminMethodDescriptorSupplier("GetBackup"))
- .build();
+ BigtableTableAdminGrpc.getGetBackupMethod =
+ getGetBackupMethod =
+ io.grpc.MethodDescriptor
+ .
+ newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetBackup"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.bigtable.admin.v2.GetBackupRequest.getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.bigtable.admin.v2.Backup.getDefaultInstance()))
+ .setSchemaDescriptor(
+ new BigtableTableAdminMethodDescriptorSupplier("GetBackup"))
+ .build();
}
}
}
return getGetBackupMethod;
}
- private static volatile io.grpc.MethodDescriptor getUpdateBackupMethod;
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.UpdateBackupRequest, com.google.bigtable.admin.v2.Backup>
+ getUpdateBackupMethod;
@io.grpc.stub.annotations.RpcMethod(
fullMethodName = SERVICE_NAME + '/' + "UpdateBackup",
requestType = com.google.bigtable.admin.v2.UpdateBackupRequest.class,
responseType = com.google.bigtable.admin.v2.Backup.class,
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getUpdateBackupMethod() {
- io.grpc.MethodDescriptor getUpdateBackupMethod;
+ public static io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.UpdateBackupRequest, com.google.bigtable.admin.v2.Backup>
+ getUpdateBackupMethod() {
+ io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.UpdateBackupRequest, com.google.bigtable.admin.v2.Backup>
+ getUpdateBackupMethod;
if ((getUpdateBackupMethod = BigtableTableAdminGrpc.getUpdateBackupMethod) == null) {
synchronized (BigtableTableAdminGrpc.class) {
if ((getUpdateBackupMethod = BigtableTableAdminGrpc.getUpdateBackupMethod) == null) {
- BigtableTableAdminGrpc.getUpdateBackupMethod = getUpdateBackupMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "UpdateBackup"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.bigtable.admin.v2.UpdateBackupRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.bigtable.admin.v2.Backup.getDefaultInstance()))
- .setSchemaDescriptor(new BigtableTableAdminMethodDescriptorSupplier("UpdateBackup"))
- .build();
+ BigtableTableAdminGrpc.getUpdateBackupMethod =
+ getUpdateBackupMethod =
+ io.grpc.MethodDescriptor
+ .
+ newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "UpdateBackup"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.bigtable.admin.v2.UpdateBackupRequest
+ .getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.bigtable.admin.v2.Backup.getDefaultInstance()))
+ .setSchemaDescriptor(
+ new BigtableTableAdminMethodDescriptorSupplier("UpdateBackup"))
+ .build();
}
}
}
return getUpdateBackupMethod;
}
- private static volatile io.grpc.MethodDescriptor getDeleteBackupMethod;
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.DeleteBackupRequest, com.google.protobuf.Empty>
+ getDeleteBackupMethod;
@io.grpc.stub.annotations.RpcMethod(
fullMethodName = SERVICE_NAME + '/' + "DeleteBackup",
requestType = com.google.bigtable.admin.v2.DeleteBackupRequest.class,
responseType = com.google.protobuf.Empty.class,
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getDeleteBackupMethod() {
- io.grpc.MethodDescriptor getDeleteBackupMethod;
+ public static io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.DeleteBackupRequest, com.google.protobuf.Empty>
+ getDeleteBackupMethod() {
+ io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.DeleteBackupRequest, com.google.protobuf.Empty>
+ getDeleteBackupMethod;
if ((getDeleteBackupMethod = BigtableTableAdminGrpc.getDeleteBackupMethod) == null) {
synchronized (BigtableTableAdminGrpc.class) {
if ((getDeleteBackupMethod = BigtableTableAdminGrpc.getDeleteBackupMethod) == null) {
- BigtableTableAdminGrpc.getDeleteBackupMethod = getDeleteBackupMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "DeleteBackup"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.bigtable.admin.v2.DeleteBackupRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.protobuf.Empty.getDefaultInstance()))
- .setSchemaDescriptor(new BigtableTableAdminMethodDescriptorSupplier("DeleteBackup"))
- .build();
+ BigtableTableAdminGrpc.getDeleteBackupMethod =
+ getDeleteBackupMethod =
+ io.grpc.MethodDescriptor
+ .
+ newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "DeleteBackup"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.bigtable.admin.v2.DeleteBackupRequest
+ .getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.protobuf.Empty.getDefaultInstance()))
+ .setSchemaDescriptor(
+ new BigtableTableAdminMethodDescriptorSupplier("DeleteBackup"))
+ .build();
}
}
}
return getDeleteBackupMethod;
}
- private static volatile io.grpc.MethodDescriptor getListBackupsMethod;
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.ListBackupsRequest,
+ com.google.bigtable.admin.v2.ListBackupsResponse>
+ getListBackupsMethod;
@io.grpc.stub.annotations.RpcMethod(
fullMethodName = SERVICE_NAME + '/' + "ListBackups",
requestType = com.google.bigtable.admin.v2.ListBackupsRequest.class,
responseType = com.google.bigtable.admin.v2.ListBackupsResponse.class,
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getListBackupsMethod() {
- io.grpc.MethodDescriptor getListBackupsMethod;
+ public static io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.ListBackupsRequest,
+ com.google.bigtable.admin.v2.ListBackupsResponse>
+ getListBackupsMethod() {
+ io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.ListBackupsRequest,
+ com.google.bigtable.admin.v2.ListBackupsResponse>
+ getListBackupsMethod;
if ((getListBackupsMethod = BigtableTableAdminGrpc.getListBackupsMethod) == null) {
synchronized (BigtableTableAdminGrpc.class) {
if ((getListBackupsMethod = BigtableTableAdminGrpc.getListBackupsMethod) == null) {
- BigtableTableAdminGrpc.getListBackupsMethod = getListBackupsMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListBackups"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.bigtable.admin.v2.ListBackupsRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.bigtable.admin.v2.ListBackupsResponse.getDefaultInstance()))
- .setSchemaDescriptor(new BigtableTableAdminMethodDescriptorSupplier("ListBackups"))
- .build();
+ BigtableTableAdminGrpc.getListBackupsMethod =
+ getListBackupsMethod =
+ io.grpc.MethodDescriptor
+ .
+ newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListBackups"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.bigtable.admin.v2.ListBackupsRequest.getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.bigtable.admin.v2.ListBackupsResponse
+ .getDefaultInstance()))
+ .setSchemaDescriptor(
+ new BigtableTableAdminMethodDescriptorSupplier("ListBackups"))
+ .build();
}
}
}
return getListBackupsMethod;
}
- private static volatile io.grpc.MethodDescriptor getRestoreTableMethod;
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.RestoreTableRequest, com.google.longrunning.Operation>
+ getRestoreTableMethod;
@io.grpc.stub.annotations.RpcMethod(
fullMethodName = SERVICE_NAME + '/' + "RestoreTable",
requestType = com.google.bigtable.admin.v2.RestoreTableRequest.class,
responseType = com.google.longrunning.Operation.class,
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getRestoreTableMethod() {
- io.grpc.MethodDescriptor getRestoreTableMethod;
+ public static io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.RestoreTableRequest, com.google.longrunning.Operation>
+ getRestoreTableMethod() {
+ io.grpc.MethodDescriptor<
+ com.google.bigtable.admin.v2.RestoreTableRequest, com.google.longrunning.Operation>
+ getRestoreTableMethod;
if ((getRestoreTableMethod = BigtableTableAdminGrpc.getRestoreTableMethod) == null) {
synchronized (BigtableTableAdminGrpc.class) {
if ((getRestoreTableMethod = BigtableTableAdminGrpc.getRestoreTableMethod) == null) {
- BigtableTableAdminGrpc.getRestoreTableMethod = getRestoreTableMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "RestoreTable"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.bigtable.admin.v2.RestoreTableRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.longrunning.Operation.getDefaultInstance()))
- .setSchemaDescriptor(new BigtableTableAdminMethodDescriptorSupplier("RestoreTable"))
- .build();
+ BigtableTableAdminGrpc.getRestoreTableMethod =
+ getRestoreTableMethod =
+ io.grpc.MethodDescriptor
+ .
+ newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "RestoreTable"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.bigtable.admin.v2.RestoreTableRequest
+ .getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.longrunning.Operation.getDefaultInstance()))
+ .setSchemaDescriptor(
+ new BigtableTableAdminMethodDescriptorSupplier("RestoreTable"))
+ .build();
}
}
}
return getRestoreTableMethod;
}
- private static volatile io.grpc.MethodDescriptor getCopyBackupMethod;
-
- @io.grpc.stub.annotations.RpcMethod(
- fullMethodName = SERVICE_NAME + '/' + "CopyBackup",
- requestType = com.google.bigtable.admin.v2.CopyBackupRequest.class,
- responseType = com.google.longrunning.Operation.class,
- methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getCopyBackupMethod() {
- io.grpc.MethodDescriptor getCopyBackupMethod;
- if ((getCopyBackupMethod = BigtableTableAdminGrpc.getCopyBackupMethod) == null) {
- synchronized (BigtableTableAdminGrpc.class) {
- if ((getCopyBackupMethod = BigtableTableAdminGrpc.getCopyBackupMethod) == null) {
- BigtableTableAdminGrpc.getCopyBackupMethod = getCopyBackupMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "CopyBackup"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.bigtable.admin.v2.CopyBackupRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.longrunning.Operation.getDefaultInstance()))
- .setSchemaDescriptor(new BigtableTableAdminMethodDescriptorSupplier("CopyBackup"))
- .build();
- }
- }
- }
- return getCopyBackupMethod;
- }
-
- private static volatile io.grpc.MethodDescriptor getGetIamPolicyMethod;
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.iam.v1.GetIamPolicyRequest, com.google.iam.v1.Policy>
+ getGetIamPolicyMethod;
@io.grpc.stub.annotations.RpcMethod(
fullMethodName = SERVICE_NAME + '/' + "GetIamPolicy",
requestType = com.google.iam.v1.GetIamPolicyRequest.class,
responseType = com.google.iam.v1.Policy.class,
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getGetIamPolicyMethod() {
- io.grpc.MethodDescriptor getGetIamPolicyMethod;
+ public static io.grpc.MethodDescriptor<
+ com.google.iam.v1.GetIamPolicyRequest, com.google.iam.v1.Policy>
+ getGetIamPolicyMethod() {
+ io.grpc.MethodDescriptor
+ getGetIamPolicyMethod;
if ((getGetIamPolicyMethod = BigtableTableAdminGrpc.getGetIamPolicyMethod) == null) {
synchronized (BigtableTableAdminGrpc.class) {
if ((getGetIamPolicyMethod = BigtableTableAdminGrpc.getGetIamPolicyMethod) == null) {
- BigtableTableAdminGrpc.getGetIamPolicyMethod = getGetIamPolicyMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetIamPolicy"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.iam.v1.GetIamPolicyRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.iam.v1.Policy.getDefaultInstance()))
- .setSchemaDescriptor(new BigtableTableAdminMethodDescriptorSupplier("GetIamPolicy"))
- .build();
+ BigtableTableAdminGrpc.getGetIamPolicyMethod =
+ getGetIamPolicyMethod =
+ io.grpc.MethodDescriptor
+ .newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetIamPolicy"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.iam.v1.GetIamPolicyRequest.getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.iam.v1.Policy.getDefaultInstance()))
+ .setSchemaDescriptor(
+ new BigtableTableAdminMethodDescriptorSupplier("GetIamPolicy"))
+ .build();
}
}
}
return getGetIamPolicyMethod;
}
- private static volatile io.grpc.MethodDescriptor getSetIamPolicyMethod;
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.iam.v1.SetIamPolicyRequest, com.google.iam.v1.Policy>
+ getSetIamPolicyMethod;
@io.grpc.stub.annotations.RpcMethod(
fullMethodName = SERVICE_NAME + '/' + "SetIamPolicy",
requestType = com.google.iam.v1.SetIamPolicyRequest.class,
responseType = com.google.iam.v1.Policy.class,
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getSetIamPolicyMethod() {
- io.grpc.MethodDescriptor getSetIamPolicyMethod;
+ public static io.grpc.MethodDescriptor<
+ com.google.iam.v1.SetIamPolicyRequest, com.google.iam.v1.Policy>
+ getSetIamPolicyMethod() {
+ io.grpc.MethodDescriptor