+ listLogicalViewsCallable() {
+ return stub.listLogicalViewsCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Updates a logical view within an instance.
+ *
+ * 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 (BaseBigtableInstanceAdminClient baseBigtableInstanceAdminClient =
+ * BaseBigtableInstanceAdminClient.create()) {
+ * LogicalView logicalView = LogicalView.newBuilder().build();
+ * FieldMask updateMask = FieldMask.newBuilder().build();
+ * LogicalView response =
+ * baseBigtableInstanceAdminClient.updateLogicalViewAsync(logicalView, updateMask).get();
+ * }
+ * }
+ *
+ * @param logicalView Required. The logical view to update.
+ * The logical view's `name` field is used to identify the view to update. Format:
+ * `projects/{project}/instances/{instance}/logicalViews/{logical_view}`.
+ * @param updateMask Optional. The list of fields to update.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final OperationFuture updateLogicalViewAsync(
+ LogicalView logicalView, FieldMask updateMask) {
+ UpdateLogicalViewRequest request =
+ UpdateLogicalViewRequest.newBuilder()
+ .setLogicalView(logicalView)
+ .setUpdateMask(updateMask)
+ .build();
+ return updateLogicalViewAsync(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Updates a logical view within an instance.
+ *
+ * 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 (BaseBigtableInstanceAdminClient baseBigtableInstanceAdminClient =
+ * BaseBigtableInstanceAdminClient.create()) {
+ * UpdateLogicalViewRequest request =
+ * UpdateLogicalViewRequest.newBuilder()
+ * .setLogicalView(LogicalView.newBuilder().build())
+ * .setUpdateMask(FieldMask.newBuilder().build())
+ * .build();
+ * LogicalView response = baseBigtableInstanceAdminClient.updateLogicalViewAsync(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 updateLogicalViewAsync(
+ UpdateLogicalViewRequest request) {
+ return updateLogicalViewOperationCallable().futureCall(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Updates a logical view within an instance.
+ *
+ * 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 (BaseBigtableInstanceAdminClient baseBigtableInstanceAdminClient =
+ * BaseBigtableInstanceAdminClient.create()) {
+ * UpdateLogicalViewRequest request =
+ * UpdateLogicalViewRequest.newBuilder()
+ * .setLogicalView(LogicalView.newBuilder().build())
+ * .setUpdateMask(FieldMask.newBuilder().build())
+ * .build();
+ * OperationFuture future =
+ * baseBigtableInstanceAdminClient.updateLogicalViewOperationCallable().futureCall(request);
+ * // Do something.
+ * LogicalView response = future.get();
+ * }
+ * }
+ */
+ public final OperationCallable
+ updateLogicalViewOperationCallable() {
+ return stub.updateLogicalViewOperationCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Updates a logical view within an instance.
+ *
+ * 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 (BaseBigtableInstanceAdminClient baseBigtableInstanceAdminClient =
+ * BaseBigtableInstanceAdminClient.create()) {
+ * UpdateLogicalViewRequest request =
+ * UpdateLogicalViewRequest.newBuilder()
+ * .setLogicalView(LogicalView.newBuilder().build())
+ * .setUpdateMask(FieldMask.newBuilder().build())
+ * .build();
+ * ApiFuture future =
+ * baseBigtableInstanceAdminClient.updateLogicalViewCallable().futureCall(request);
+ * // Do something.
+ * Operation response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable updateLogicalViewCallable() {
+ return stub.updateLogicalViewCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Deletes a logical view from an instance.
+ *
+ * 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 (BaseBigtableInstanceAdminClient baseBigtableInstanceAdminClient =
+ * BaseBigtableInstanceAdminClient.create()) {
+ * LogicalViewName name = LogicalViewName.of("[PROJECT]", "[INSTANCE]", "[LOGICAL_VIEW]");
+ * baseBigtableInstanceAdminClient.deleteLogicalView(name);
+ * }
+ * }
+ *
+ * @param name Required. The unique name of the logical view to be deleted. Format:
+ * `projects/{project}/instances/{instance}/logicalViews/{logical_view}`.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final void deleteLogicalView(LogicalViewName name) {
+ DeleteLogicalViewRequest request =
+ DeleteLogicalViewRequest.newBuilder()
+ .setName(name == null ? null : name.toString())
+ .build();
+ deleteLogicalView(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Deletes a logical view from an instance.
+ *
+ * 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 (BaseBigtableInstanceAdminClient baseBigtableInstanceAdminClient =
+ * BaseBigtableInstanceAdminClient.create()) {
+ * String name = LogicalViewName.of("[PROJECT]", "[INSTANCE]", "[LOGICAL_VIEW]").toString();
+ * baseBigtableInstanceAdminClient.deleteLogicalView(name);
+ * }
+ * }
+ *
+ * @param name Required. The unique name of the logical view to be deleted. Format:
+ * `projects/{project}/instances/{instance}/logicalViews/{logical_view}`.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final void deleteLogicalView(String name) {
+ DeleteLogicalViewRequest request = DeleteLogicalViewRequest.newBuilder().setName(name).build();
+ deleteLogicalView(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Deletes a logical view from an instance.
+ *
+ * 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 (BaseBigtableInstanceAdminClient baseBigtableInstanceAdminClient =
+ * BaseBigtableInstanceAdminClient.create()) {
+ * DeleteLogicalViewRequest request =
+ * DeleteLogicalViewRequest.newBuilder()
+ * .setName(LogicalViewName.of("[PROJECT]", "[INSTANCE]", "[LOGICAL_VIEW]").toString())
+ * .setEtag("etag3123477")
+ * .build();
+ * baseBigtableInstanceAdminClient.deleteLogicalView(request);
+ * }
+ * }
+ *
+ * @param request The request object containing all of the parameters for the API call.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final void deleteLogicalView(DeleteLogicalViewRequest request) {
+ deleteLogicalViewCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Deletes a logical view from an instance.
+ *
+ * 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 (BaseBigtableInstanceAdminClient baseBigtableInstanceAdminClient =
+ * BaseBigtableInstanceAdminClient.create()) {
+ * DeleteLogicalViewRequest request =
+ * DeleteLogicalViewRequest.newBuilder()
+ * .setName(LogicalViewName.of("[PROJECT]", "[INSTANCE]", "[LOGICAL_VIEW]").toString())
+ * .setEtag("etag3123477")
+ * .build();
+ * ApiFuture future =
+ * baseBigtableInstanceAdminClient.deleteLogicalViewCallable().futureCall(request);
+ * // Do something.
+ * future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable deleteLogicalViewCallable() {
+ return stub.deleteLogicalViewCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Creates a materialized view within an instance.
+ *
+ * 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 (BaseBigtableInstanceAdminClient baseBigtableInstanceAdminClient =
+ * BaseBigtableInstanceAdminClient.create()) {
+ * InstanceName parent = InstanceName.of("[PROJECT]", "[INSTANCE]");
+ * MaterializedView materializedView = MaterializedView.newBuilder().build();
+ * String materializedViewId = "materializedViewId682270903";
+ * MaterializedView response =
+ * baseBigtableInstanceAdminClient
+ * .createMaterializedViewAsync(parent, materializedView, materializedViewId)
+ * .get();
+ * }
+ * }
+ *
+ * @param parent Required. The parent instance where this materialized view will be created.
+ * Format: `projects/{project}/instances/{instance}`.
+ * @param materializedView Required. The materialized view to create.
+ * @param materializedViewId Required. The ID to use for the materialized view, which will become
+ * the final component of the materialized view's resource name.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final OperationFuture
+ createMaterializedViewAsync(
+ InstanceName parent, MaterializedView materializedView, String materializedViewId) {
+ CreateMaterializedViewRequest request =
+ CreateMaterializedViewRequest.newBuilder()
+ .setParent(parent == null ? null : parent.toString())
+ .setMaterializedView(materializedView)
+ .setMaterializedViewId(materializedViewId)
+ .build();
+ return createMaterializedViewAsync(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Creates a materialized view within an instance.
+ *
+ * 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 (BaseBigtableInstanceAdminClient baseBigtableInstanceAdminClient =
+ * BaseBigtableInstanceAdminClient.create()) {
+ * String parent = InstanceName.of("[PROJECT]", "[INSTANCE]").toString();
+ * MaterializedView materializedView = MaterializedView.newBuilder().build();
+ * String materializedViewId = "materializedViewId682270903";
+ * MaterializedView response =
+ * baseBigtableInstanceAdminClient
+ * .createMaterializedViewAsync(parent, materializedView, materializedViewId)
+ * .get();
+ * }
+ * }
+ *
+ * @param parent Required. The parent instance where this materialized view will be created.
+ * Format: `projects/{project}/instances/{instance}`.
+ * @param materializedView Required. The materialized view to create.
+ * @param materializedViewId Required. The ID to use for the materialized view, which will become
+ * the final component of the materialized view's resource name.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final OperationFuture
+ createMaterializedViewAsync(
+ String parent, MaterializedView materializedView, String materializedViewId) {
+ CreateMaterializedViewRequest request =
+ CreateMaterializedViewRequest.newBuilder()
+ .setParent(parent)
+ .setMaterializedView(materializedView)
+ .setMaterializedViewId(materializedViewId)
+ .build();
+ return createMaterializedViewAsync(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Creates a materialized view within an instance.
+ *
+ * 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 (BaseBigtableInstanceAdminClient baseBigtableInstanceAdminClient =
+ * BaseBigtableInstanceAdminClient.create()) {
+ * CreateMaterializedViewRequest request =
+ * CreateMaterializedViewRequest.newBuilder()
+ * .setParent(InstanceName.of("[PROJECT]", "[INSTANCE]").toString())
+ * .setMaterializedViewId("materializedViewId682270903")
+ * .setMaterializedView(MaterializedView.newBuilder().build())
+ * .build();
+ * MaterializedView response =
+ * baseBigtableInstanceAdminClient.createMaterializedViewAsync(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
+ createMaterializedViewAsync(CreateMaterializedViewRequest request) {
+ return createMaterializedViewOperationCallable().futureCall(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Creates a materialized view within an instance.
+ *
+ * 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 (BaseBigtableInstanceAdminClient baseBigtableInstanceAdminClient =
+ * BaseBigtableInstanceAdminClient.create()) {
+ * CreateMaterializedViewRequest request =
+ * CreateMaterializedViewRequest.newBuilder()
+ * .setParent(InstanceName.of("[PROJECT]", "[INSTANCE]").toString())
+ * .setMaterializedViewId("materializedViewId682270903")
+ * .setMaterializedView(MaterializedView.newBuilder().build())
+ * .build();
+ * OperationFuture future =
+ * baseBigtableInstanceAdminClient
+ * .createMaterializedViewOperationCallable()
+ * .futureCall(request);
+ * // Do something.
+ * MaterializedView response = future.get();
+ * }
+ * }
+ */
+ public final OperationCallable<
+ CreateMaterializedViewRequest, MaterializedView, CreateMaterializedViewMetadata>
+ createMaterializedViewOperationCallable() {
+ return stub.createMaterializedViewOperationCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Creates a materialized view within an instance.
+ *
+ * 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 (BaseBigtableInstanceAdminClient baseBigtableInstanceAdminClient =
+ * BaseBigtableInstanceAdminClient.create()) {
+ * CreateMaterializedViewRequest request =
+ * CreateMaterializedViewRequest.newBuilder()
+ * .setParent(InstanceName.of("[PROJECT]", "[INSTANCE]").toString())
+ * .setMaterializedViewId("materializedViewId682270903")
+ * .setMaterializedView(MaterializedView.newBuilder().build())
+ * .build();
+ * ApiFuture future =
+ * baseBigtableInstanceAdminClient.createMaterializedViewCallable().futureCall(request);
+ * // Do something.
+ * Operation response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable
+ createMaterializedViewCallable() {
+ return stub.createMaterializedViewCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Gets information about a materialized view.
+ *
+ * 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 (BaseBigtableInstanceAdminClient baseBigtableInstanceAdminClient =
+ * BaseBigtableInstanceAdminClient.create()) {
+ * MaterializedViewName name =
+ * MaterializedViewName.of("[PROJECT]", "[INSTANCE]", "[MATERIALIZED_VIEW]");
+ * MaterializedView response = baseBigtableInstanceAdminClient.getMaterializedView(name);
+ * }
+ * }
+ *
+ * @param name Required. The unique name of the requested materialized view. Values are of the
+ * form `projects/{project}/instances/{instance}/materializedViews/{materialized_view}`.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final MaterializedView getMaterializedView(MaterializedViewName name) {
+ GetMaterializedViewRequest request =
+ GetMaterializedViewRequest.newBuilder()
+ .setName(name == null ? null : name.toString())
+ .build();
+ return getMaterializedView(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Gets information about a materialized view.
+ *
+ * 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 (BaseBigtableInstanceAdminClient baseBigtableInstanceAdminClient =
+ * BaseBigtableInstanceAdminClient.create()) {
+ * String name =
+ * MaterializedViewName.of("[PROJECT]", "[INSTANCE]", "[MATERIALIZED_VIEW]").toString();
+ * MaterializedView response = baseBigtableInstanceAdminClient.getMaterializedView(name);
+ * }
+ * }
+ *
+ * @param name Required. The unique name of the requested materialized view. Values are of the
+ * form `projects/{project}/instances/{instance}/materializedViews/{materialized_view}`.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final MaterializedView getMaterializedView(String name) {
+ GetMaterializedViewRequest request =
+ GetMaterializedViewRequest.newBuilder().setName(name).build();
+ return getMaterializedView(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Gets information about a materialized view.
+ *
+ * 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 (BaseBigtableInstanceAdminClient baseBigtableInstanceAdminClient =
+ * BaseBigtableInstanceAdminClient.create()) {
+ * GetMaterializedViewRequest request =
+ * GetMaterializedViewRequest.newBuilder()
+ * .setName(
+ * MaterializedViewName.of("[PROJECT]", "[INSTANCE]", "[MATERIALIZED_VIEW]")
+ * .toString())
+ * .build();
+ * MaterializedView response = baseBigtableInstanceAdminClient.getMaterializedView(request);
+ * }
+ * }
+ *
+ * @param request The request object containing all of the parameters for the API call.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final MaterializedView getMaterializedView(GetMaterializedViewRequest request) {
+ return getMaterializedViewCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Gets information about a materialized view.
+ *
+ * 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 (BaseBigtableInstanceAdminClient baseBigtableInstanceAdminClient =
+ * BaseBigtableInstanceAdminClient.create()) {
+ * GetMaterializedViewRequest request =
+ * GetMaterializedViewRequest.newBuilder()
+ * .setName(
+ * MaterializedViewName.of("[PROJECT]", "[INSTANCE]", "[MATERIALIZED_VIEW]")
+ * .toString())
+ * .build();
+ * ApiFuture future =
+ * baseBigtableInstanceAdminClient.getMaterializedViewCallable().futureCall(request);
+ * // Do something.
+ * MaterializedView response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable
+ getMaterializedViewCallable() {
+ return stub.getMaterializedViewCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists information about materialized views in an instance.
+ *
+ * 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 (BaseBigtableInstanceAdminClient baseBigtableInstanceAdminClient =
+ * BaseBigtableInstanceAdminClient.create()) {
+ * InstanceName parent = InstanceName.of("[PROJECT]", "[INSTANCE]");
+ * for (MaterializedView element :
+ * baseBigtableInstanceAdminClient.listMaterializedViews(parent).iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ * }
+ *
+ * @param parent Required. The unique name of the instance for which the list of materialized
+ * views is requested. Values are of the form `projects/{project}/instances/{instance}`.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final ListMaterializedViewsPagedResponse listMaterializedViews(InstanceName parent) {
+ ListMaterializedViewsRequest request =
+ ListMaterializedViewsRequest.newBuilder()
+ .setParent(parent == null ? null : parent.toString())
+ .build();
+ return listMaterializedViews(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists information about materialized views in an instance.
+ *
+ * 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 (BaseBigtableInstanceAdminClient baseBigtableInstanceAdminClient =
+ * BaseBigtableInstanceAdminClient.create()) {
+ * String parent = InstanceName.of("[PROJECT]", "[INSTANCE]").toString();
+ * for (MaterializedView element :
+ * baseBigtableInstanceAdminClient.listMaterializedViews(parent).iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ * }
+ *
+ * @param parent Required. The unique name of the instance for which the list of materialized
+ * views is requested. Values are of the form `projects/{project}/instances/{instance}`.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final ListMaterializedViewsPagedResponse listMaterializedViews(String parent) {
+ ListMaterializedViewsRequest request =
+ ListMaterializedViewsRequest.newBuilder().setParent(parent).build();
+ return listMaterializedViews(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists information about materialized views in an instance.
+ *
+ * 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 (BaseBigtableInstanceAdminClient baseBigtableInstanceAdminClient =
+ * BaseBigtableInstanceAdminClient.create()) {
+ * ListMaterializedViewsRequest request =
+ * ListMaterializedViewsRequest.newBuilder()
+ * .setParent(InstanceName.of("[PROJECT]", "[INSTANCE]").toString())
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .build();
+ * for (MaterializedView element :
+ * baseBigtableInstanceAdminClient.listMaterializedViews(request).iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ * }
+ *
+ * @param request The request object containing all of the parameters for the API call.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final ListMaterializedViewsPagedResponse listMaterializedViews(
+ ListMaterializedViewsRequest request) {
+ return listMaterializedViewsPagedCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists information about materialized views in an instance.
+ *
+ * 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 (BaseBigtableInstanceAdminClient baseBigtableInstanceAdminClient =
+ * BaseBigtableInstanceAdminClient.create()) {
+ * ListMaterializedViewsRequest request =
+ * ListMaterializedViewsRequest.newBuilder()
+ * .setParent(InstanceName.of("[PROJECT]", "[INSTANCE]").toString())
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .build();
+ * ApiFuture future =
+ * baseBigtableInstanceAdminClient.listMaterializedViewsPagedCallable().futureCall(request);
+ * // Do something.
+ * for (MaterializedView element : future.get().iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ * }
+ */
+ public final UnaryCallable
+ listMaterializedViewsPagedCallable() {
+ return stub.listMaterializedViewsPagedCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists information about materialized views in an instance.
+ *
+ * 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 (BaseBigtableInstanceAdminClient baseBigtableInstanceAdminClient =
+ * BaseBigtableInstanceAdminClient.create()) {
+ * ListMaterializedViewsRequest request =
+ * ListMaterializedViewsRequest.newBuilder()
+ * .setParent(InstanceName.of("[PROJECT]", "[INSTANCE]").toString())
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .build();
+ * while (true) {
+ * ListMaterializedViewsResponse response =
+ * baseBigtableInstanceAdminClient.listMaterializedViewsCallable().call(request);
+ * for (MaterializedView element : response.getMaterializedViewsList()) {
+ * // doThingsWith(element);
+ * }
+ * String nextPageToken = response.getNextPageToken();
+ * if (!Strings.isNullOrEmpty(nextPageToken)) {
+ * request = request.toBuilder().setPageToken(nextPageToken).build();
+ * } else {
+ * break;
+ * }
+ * }
+ * }
+ * }
+ */
+ public final UnaryCallable
+ listMaterializedViewsCallable() {
+ return stub.listMaterializedViewsCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Updates a materialized view within an instance.
+ *
+ * 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 (BaseBigtableInstanceAdminClient baseBigtableInstanceAdminClient =
+ * BaseBigtableInstanceAdminClient.create()) {
+ * MaterializedView materializedView = MaterializedView.newBuilder().build();
+ * FieldMask updateMask = FieldMask.newBuilder().build();
+ * MaterializedView response =
+ * baseBigtableInstanceAdminClient
+ * .updateMaterializedViewAsync(materializedView, updateMask)
+ * .get();
+ * }
+ * }
+ *
+ * @param materializedView Required. The materialized view to update.
+ * The materialized view's `name` field is used to identify the view to update. Format:
+ * `projects/{project}/instances/{instance}/materializedViews/{materialized_view}`.
+ * @param updateMask Optional. The list of fields to update.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final OperationFuture
+ updateMaterializedViewAsync(MaterializedView materializedView, FieldMask updateMask) {
+ UpdateMaterializedViewRequest request =
+ UpdateMaterializedViewRequest.newBuilder()
+ .setMaterializedView(materializedView)
+ .setUpdateMask(updateMask)
+ .build();
+ return updateMaterializedViewAsync(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Updates a materialized view within an instance.
+ *
+ * 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 (BaseBigtableInstanceAdminClient baseBigtableInstanceAdminClient =
+ * BaseBigtableInstanceAdminClient.create()) {
+ * UpdateMaterializedViewRequest request =
+ * UpdateMaterializedViewRequest.newBuilder()
+ * .setMaterializedView(MaterializedView.newBuilder().build())
+ * .setUpdateMask(FieldMask.newBuilder().build())
+ * .build();
+ * MaterializedView response =
+ * baseBigtableInstanceAdminClient.updateMaterializedViewAsync(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
+ updateMaterializedViewAsync(UpdateMaterializedViewRequest request) {
+ return updateMaterializedViewOperationCallable().futureCall(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Updates a materialized view within an instance.
+ *
+ * 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 (BaseBigtableInstanceAdminClient baseBigtableInstanceAdminClient =
+ * BaseBigtableInstanceAdminClient.create()) {
+ * UpdateMaterializedViewRequest request =
+ * UpdateMaterializedViewRequest.newBuilder()
+ * .setMaterializedView(MaterializedView.newBuilder().build())
+ * .setUpdateMask(FieldMask.newBuilder().build())
+ * .build();
+ * OperationFuture future =
+ * baseBigtableInstanceAdminClient
+ * .updateMaterializedViewOperationCallable()
+ * .futureCall(request);
+ * // Do something.
+ * MaterializedView response = future.get();
+ * }
+ * }
+ */
+ public final OperationCallable<
+ UpdateMaterializedViewRequest, MaterializedView, UpdateMaterializedViewMetadata>
+ updateMaterializedViewOperationCallable() {
+ return stub.updateMaterializedViewOperationCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Updates a materialized view within an instance.
+ *
+ * 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 (BaseBigtableInstanceAdminClient baseBigtableInstanceAdminClient =
+ * BaseBigtableInstanceAdminClient.create()) {
+ * UpdateMaterializedViewRequest request =
+ * UpdateMaterializedViewRequest.newBuilder()
+ * .setMaterializedView(MaterializedView.newBuilder().build())
+ * .setUpdateMask(FieldMask.newBuilder().build())
+ * .build();
+ * ApiFuture future =
+ * baseBigtableInstanceAdminClient.updateMaterializedViewCallable().futureCall(request);
+ * // Do something.
+ * Operation response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable
+ updateMaterializedViewCallable() {
+ return stub.updateMaterializedViewCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Deletes a materialized view from an instance.
+ *
+ * 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 (BaseBigtableInstanceAdminClient baseBigtableInstanceAdminClient =
+ * BaseBigtableInstanceAdminClient.create()) {
+ * MaterializedViewName name =
+ * MaterializedViewName.of("[PROJECT]", "[INSTANCE]", "[MATERIALIZED_VIEW]");
+ * baseBigtableInstanceAdminClient.deleteMaterializedView(name);
+ * }
+ * }
+ *
+ * @param name Required. The unique name of the materialized view to be deleted. Format:
+ * `projects/{project}/instances/{instance}/materializedViews/{materialized_view}`.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final void deleteMaterializedView(MaterializedViewName name) {
+ DeleteMaterializedViewRequest request =
+ DeleteMaterializedViewRequest.newBuilder()
+ .setName(name == null ? null : name.toString())
+ .build();
+ deleteMaterializedView(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Deletes a materialized view from an instance.
+ *
+ * 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 (BaseBigtableInstanceAdminClient baseBigtableInstanceAdminClient =
+ * BaseBigtableInstanceAdminClient.create()) {
+ * String name =
+ * MaterializedViewName.of("[PROJECT]", "[INSTANCE]", "[MATERIALIZED_VIEW]").toString();
+ * baseBigtableInstanceAdminClient.deleteMaterializedView(name);
+ * }
+ * }
+ *
+ * @param name Required. The unique name of the materialized view to be deleted. Format:
+ * `projects/{project}/instances/{instance}/materializedViews/{materialized_view}`.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final void deleteMaterializedView(String name) {
+ DeleteMaterializedViewRequest request =
+ DeleteMaterializedViewRequest.newBuilder().setName(name).build();
+ deleteMaterializedView(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Deletes a materialized view from an instance.
+ *
+ * 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 (BaseBigtableInstanceAdminClient baseBigtableInstanceAdminClient =
+ * BaseBigtableInstanceAdminClient.create()) {
+ * DeleteMaterializedViewRequest request =
+ * DeleteMaterializedViewRequest.newBuilder()
+ * .setName(
+ * MaterializedViewName.of("[PROJECT]", "[INSTANCE]", "[MATERIALIZED_VIEW]")
+ * .toString())
+ * .setEtag("etag3123477")
+ * .build();
+ * baseBigtableInstanceAdminClient.deleteMaterializedView(request);
+ * }
+ * }
+ *
+ * @param request The request object containing all of the parameters for the API call.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final void deleteMaterializedView(DeleteMaterializedViewRequest request) {
+ deleteMaterializedViewCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Deletes a materialized view from an instance.
+ *
+ * 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 (BaseBigtableInstanceAdminClient baseBigtableInstanceAdminClient =
+ * BaseBigtableInstanceAdminClient.create()) {
+ * DeleteMaterializedViewRequest request =
+ * DeleteMaterializedViewRequest.newBuilder()
+ * .setName(
+ * MaterializedViewName.of("[PROJECT]", "[INSTANCE]", "[MATERIALIZED_VIEW]")
+ * .toString())
+ * .setEtag("etag3123477")
+ * .build();
+ * ApiFuture future =
+ * baseBigtableInstanceAdminClient.deleteMaterializedViewCallable().futureCall(request);
+ * // Do something.
+ * future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable
+ deleteMaterializedViewCallable() {
+ return stub.deleteMaterializedViewCallable();
+ }
+
@Override
public final void close() {
stub.close();
@@ -3274,4 +4761,165 @@ protected ListHotTabletsFixedSizeCollection createCollection(
return new ListHotTabletsFixedSizeCollection(pages, collectionSize);
}
}
+
+ public static class ListLogicalViewsPagedResponse
+ extends AbstractPagedListResponse<
+ ListLogicalViewsRequest,
+ ListLogicalViewsResponse,
+ LogicalView,
+ ListLogicalViewsPage,
+ ListLogicalViewsFixedSizeCollection> {
+
+ public static ApiFuture createAsync(
+ PageContext context,
+ ApiFuture futureResponse) {
+ ApiFuture futurePage =
+ ListLogicalViewsPage.createEmptyPage().createPageAsync(context, futureResponse);
+ return ApiFutures.transform(
+ futurePage,
+ input -> new ListLogicalViewsPagedResponse(input),
+ MoreExecutors.directExecutor());
+ }
+
+ private ListLogicalViewsPagedResponse(ListLogicalViewsPage page) {
+ super(page, ListLogicalViewsFixedSizeCollection.createEmptyCollection());
+ }
+ }
+
+ public static class ListLogicalViewsPage
+ extends AbstractPage<
+ ListLogicalViewsRequest, ListLogicalViewsResponse, LogicalView, ListLogicalViewsPage> {
+
+ private ListLogicalViewsPage(
+ PageContext context,
+ ListLogicalViewsResponse response) {
+ super(context, response);
+ }
+
+ private static ListLogicalViewsPage createEmptyPage() {
+ return new ListLogicalViewsPage(null, null);
+ }
+
+ @Override
+ protected ListLogicalViewsPage createPage(
+ PageContext context,
+ ListLogicalViewsResponse response) {
+ return new ListLogicalViewsPage(context, response);
+ }
+
+ @Override
+ public ApiFuture createPageAsync(
+ PageContext context,
+ ApiFuture futureResponse) {
+ return super.createPageAsync(context, futureResponse);
+ }
+ }
+
+ public static class ListLogicalViewsFixedSizeCollection
+ extends AbstractFixedSizeCollection<
+ ListLogicalViewsRequest,
+ ListLogicalViewsResponse,
+ LogicalView,
+ ListLogicalViewsPage,
+ ListLogicalViewsFixedSizeCollection> {
+
+ private ListLogicalViewsFixedSizeCollection(
+ List pages, int collectionSize) {
+ super(pages, collectionSize);
+ }
+
+ private static ListLogicalViewsFixedSizeCollection createEmptyCollection() {
+ return new ListLogicalViewsFixedSizeCollection(null, 0);
+ }
+
+ @Override
+ protected ListLogicalViewsFixedSizeCollection createCollection(
+ List pages, int collectionSize) {
+ return new ListLogicalViewsFixedSizeCollection(pages, collectionSize);
+ }
+ }
+
+ public static class ListMaterializedViewsPagedResponse
+ extends AbstractPagedListResponse<
+ ListMaterializedViewsRequest,
+ ListMaterializedViewsResponse,
+ MaterializedView,
+ ListMaterializedViewsPage,
+ ListMaterializedViewsFixedSizeCollection> {
+
+ public static ApiFuture createAsync(
+ PageContext
+ context,
+ ApiFuture futureResponse) {
+ ApiFuture futurePage =
+ ListMaterializedViewsPage.createEmptyPage().createPageAsync(context, futureResponse);
+ return ApiFutures.transform(
+ futurePage,
+ input -> new ListMaterializedViewsPagedResponse(input),
+ MoreExecutors.directExecutor());
+ }
+
+ private ListMaterializedViewsPagedResponse(ListMaterializedViewsPage page) {
+ super(page, ListMaterializedViewsFixedSizeCollection.createEmptyCollection());
+ }
+ }
+
+ public static class ListMaterializedViewsPage
+ extends AbstractPage<
+ ListMaterializedViewsRequest,
+ ListMaterializedViewsResponse,
+ MaterializedView,
+ ListMaterializedViewsPage> {
+
+ private ListMaterializedViewsPage(
+ PageContext
+ context,
+ ListMaterializedViewsResponse response) {
+ super(context, response);
+ }
+
+ private static ListMaterializedViewsPage createEmptyPage() {
+ return new ListMaterializedViewsPage(null, null);
+ }
+
+ @Override
+ protected ListMaterializedViewsPage createPage(
+ PageContext
+ context,
+ ListMaterializedViewsResponse response) {
+ return new ListMaterializedViewsPage(context, response);
+ }
+
+ @Override
+ public ApiFuture createPageAsync(
+ PageContext
+ context,
+ ApiFuture futureResponse) {
+ return super.createPageAsync(context, futureResponse);
+ }
+ }
+
+ public static class ListMaterializedViewsFixedSizeCollection
+ extends AbstractFixedSizeCollection<
+ ListMaterializedViewsRequest,
+ ListMaterializedViewsResponse,
+ MaterializedView,
+ ListMaterializedViewsPage,
+ ListMaterializedViewsFixedSizeCollection> {
+
+ private ListMaterializedViewsFixedSizeCollection(
+ List pages, int collectionSize) {
+ super(pages, collectionSize);
+ }
+
+ private static ListMaterializedViewsFixedSizeCollection createEmptyCollection() {
+ return new ListMaterializedViewsFixedSizeCollection(null, 0);
+ }
+
+ @Override
+ protected ListMaterializedViewsFixedSizeCollection createCollection(
+ List pages, int collectionSize) {
+ return new ListMaterializedViewsFixedSizeCollection(pages, collectionSize);
+ }
+ }
}
diff --git a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/BaseBigtableInstanceAdminSettings.java b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/BaseBigtableInstanceAdminSettings.java
index 80a0dbf0a75f..8223e0fc243a 100644
--- a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/BaseBigtableInstanceAdminSettings.java
+++ b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/BaseBigtableInstanceAdminSettings.java
@@ -18,6 +18,8 @@
import static com.google.cloud.bigtable.admin.v2.BaseBigtableInstanceAdminClient.ListAppProfilesPagedResponse;
import static com.google.cloud.bigtable.admin.v2.BaseBigtableInstanceAdminClient.ListHotTabletsPagedResponse;
+import static com.google.cloud.bigtable.admin.v2.BaseBigtableInstanceAdminClient.ListLogicalViewsPagedResponse;
+import static com.google.cloud.bigtable.admin.v2.BaseBigtableInstanceAdminClient.ListMaterializedViewsPagedResponse;
import com.google.api.core.ApiFunction;
import com.google.api.core.InternalApi;
@@ -38,12 +40,20 @@
import com.google.bigtable.admin.v2.CreateClusterRequest;
import com.google.bigtable.admin.v2.CreateInstanceMetadata;
import com.google.bigtable.admin.v2.CreateInstanceRequest;
+import com.google.bigtable.admin.v2.CreateLogicalViewMetadata;
+import com.google.bigtable.admin.v2.CreateLogicalViewRequest;
+import com.google.bigtable.admin.v2.CreateMaterializedViewMetadata;
+import com.google.bigtable.admin.v2.CreateMaterializedViewRequest;
import com.google.bigtable.admin.v2.DeleteAppProfileRequest;
import com.google.bigtable.admin.v2.DeleteClusterRequest;
import com.google.bigtable.admin.v2.DeleteInstanceRequest;
+import com.google.bigtable.admin.v2.DeleteLogicalViewRequest;
+import com.google.bigtable.admin.v2.DeleteMaterializedViewRequest;
import com.google.bigtable.admin.v2.GetAppProfileRequest;
import com.google.bigtable.admin.v2.GetClusterRequest;
import com.google.bigtable.admin.v2.GetInstanceRequest;
+import com.google.bigtable.admin.v2.GetLogicalViewRequest;
+import com.google.bigtable.admin.v2.GetMaterializedViewRequest;
import com.google.bigtable.admin.v2.Instance;
import com.google.bigtable.admin.v2.ListAppProfilesRequest;
import com.google.bigtable.admin.v2.ListAppProfilesResponse;
@@ -53,6 +63,12 @@
import com.google.bigtable.admin.v2.ListHotTabletsResponse;
import com.google.bigtable.admin.v2.ListInstancesRequest;
import com.google.bigtable.admin.v2.ListInstancesResponse;
+import com.google.bigtable.admin.v2.ListLogicalViewsRequest;
+import com.google.bigtable.admin.v2.ListLogicalViewsResponse;
+import com.google.bigtable.admin.v2.ListMaterializedViewsRequest;
+import com.google.bigtable.admin.v2.ListMaterializedViewsResponse;
+import com.google.bigtable.admin.v2.LogicalView;
+import com.google.bigtable.admin.v2.MaterializedView;
import com.google.bigtable.admin.v2.PartialUpdateClusterMetadata;
import com.google.bigtable.admin.v2.PartialUpdateClusterRequest;
import com.google.bigtable.admin.v2.PartialUpdateInstanceRequest;
@@ -60,6 +76,10 @@
import com.google.bigtable.admin.v2.UpdateAppProfileRequest;
import com.google.bigtable.admin.v2.UpdateClusterMetadata;
import com.google.bigtable.admin.v2.UpdateInstanceMetadata;
+import com.google.bigtable.admin.v2.UpdateLogicalViewMetadata;
+import com.google.bigtable.admin.v2.UpdateLogicalViewRequest;
+import com.google.bigtable.admin.v2.UpdateMaterializedViewMetadata;
+import com.google.bigtable.admin.v2.UpdateMaterializedViewRequest;
import com.google.cloud.bigtable.admin.v2.stub.BigtableInstanceAdminStubSettings;
import com.google.iam.v1.GetIamPolicyRequest;
import com.google.iam.v1.Policy;
@@ -225,6 +245,95 @@ public UnaryCallSettings setIamPolicySettings() {
return ((BigtableInstanceAdminStubSettings) getStubSettings()).listHotTabletsSettings();
}
+ /** Returns the object with the settings used for calls to createLogicalView. */
+ public UnaryCallSettings createLogicalViewSettings() {
+ return ((BigtableInstanceAdminStubSettings) getStubSettings()).createLogicalViewSettings();
+ }
+
+ /** Returns the object with the settings used for calls to createLogicalView. */
+ public OperationCallSettings
+ createLogicalViewOperationSettings() {
+ return ((BigtableInstanceAdminStubSettings) getStubSettings())
+ .createLogicalViewOperationSettings();
+ }
+
+ /** Returns the object with the settings used for calls to getLogicalView. */
+ public UnaryCallSettings getLogicalViewSettings() {
+ return ((BigtableInstanceAdminStubSettings) getStubSettings()).getLogicalViewSettings();
+ }
+
+ /** Returns the object with the settings used for calls to listLogicalViews. */
+ public PagedCallSettings<
+ ListLogicalViewsRequest, ListLogicalViewsResponse, ListLogicalViewsPagedResponse>
+ listLogicalViewsSettings() {
+ return ((BigtableInstanceAdminStubSettings) getStubSettings()).listLogicalViewsSettings();
+ }
+
+ /** Returns the object with the settings used for calls to updateLogicalView. */
+ public UnaryCallSettings updateLogicalViewSettings() {
+ return ((BigtableInstanceAdminStubSettings) getStubSettings()).updateLogicalViewSettings();
+ }
+
+ /** Returns the object with the settings used for calls to updateLogicalView. */
+ public OperationCallSettings
+ updateLogicalViewOperationSettings() {
+ return ((BigtableInstanceAdminStubSettings) getStubSettings())
+ .updateLogicalViewOperationSettings();
+ }
+
+ /** Returns the object with the settings used for calls to deleteLogicalView. */
+ public UnaryCallSettings deleteLogicalViewSettings() {
+ return ((BigtableInstanceAdminStubSettings) getStubSettings()).deleteLogicalViewSettings();
+ }
+
+ /** Returns the object with the settings used for calls to createMaterializedView. */
+ public UnaryCallSettings
+ createMaterializedViewSettings() {
+ return ((BigtableInstanceAdminStubSettings) getStubSettings()).createMaterializedViewSettings();
+ }
+
+ /** Returns the object with the settings used for calls to createMaterializedView. */
+ public OperationCallSettings<
+ CreateMaterializedViewRequest, MaterializedView, CreateMaterializedViewMetadata>
+ createMaterializedViewOperationSettings() {
+ return ((BigtableInstanceAdminStubSettings) getStubSettings())
+ .createMaterializedViewOperationSettings();
+ }
+
+ /** Returns the object with the settings used for calls to getMaterializedView. */
+ public UnaryCallSettings
+ getMaterializedViewSettings() {
+ return ((BigtableInstanceAdminStubSettings) getStubSettings()).getMaterializedViewSettings();
+ }
+
+ /** Returns the object with the settings used for calls to listMaterializedViews. */
+ public PagedCallSettings<
+ ListMaterializedViewsRequest,
+ ListMaterializedViewsResponse,
+ ListMaterializedViewsPagedResponse>
+ listMaterializedViewsSettings() {
+ return ((BigtableInstanceAdminStubSettings) getStubSettings()).listMaterializedViewsSettings();
+ }
+
+ /** Returns the object with the settings used for calls to updateMaterializedView. */
+ public UnaryCallSettings
+ updateMaterializedViewSettings() {
+ return ((BigtableInstanceAdminStubSettings) getStubSettings()).updateMaterializedViewSettings();
+ }
+
+ /** Returns the object with the settings used for calls to updateMaterializedView. */
+ public OperationCallSettings<
+ UpdateMaterializedViewRequest, MaterializedView, UpdateMaterializedViewMetadata>
+ updateMaterializedViewOperationSettings() {
+ return ((BigtableInstanceAdminStubSettings) getStubSettings())
+ .updateMaterializedViewOperationSettings();
+ }
+
+ /** Returns the object with the settings used for calls to deleteMaterializedView. */
+ public UnaryCallSettings deleteMaterializedViewSettings() {
+ return ((BigtableInstanceAdminStubSettings) getStubSettings()).deleteMaterializedViewSettings();
+ }
+
public static final BaseBigtableInstanceAdminSettings create(
BigtableInstanceAdminStubSettings stub) throws IOException {
return new BaseBigtableInstanceAdminSettings.Builder(stub.toBuilder()).build();
@@ -472,6 +581,96 @@ public UnaryCallSettings.Builder setIamPolicySettin
return getStubSettingsBuilder().listHotTabletsSettings();
}
+ /** Returns the builder for the settings used for calls to createLogicalView. */
+ public UnaryCallSettings.Builder
+ createLogicalViewSettings() {
+ return getStubSettingsBuilder().createLogicalViewSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to createLogicalView. */
+ public OperationCallSettings.Builder<
+ CreateLogicalViewRequest, LogicalView, CreateLogicalViewMetadata>
+ createLogicalViewOperationSettings() {
+ return getStubSettingsBuilder().createLogicalViewOperationSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to getLogicalView. */
+ public UnaryCallSettings.Builder getLogicalViewSettings() {
+ return getStubSettingsBuilder().getLogicalViewSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to listLogicalViews. */
+ public PagedCallSettings.Builder<
+ ListLogicalViewsRequest, ListLogicalViewsResponse, ListLogicalViewsPagedResponse>
+ listLogicalViewsSettings() {
+ return getStubSettingsBuilder().listLogicalViewsSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to updateLogicalView. */
+ public UnaryCallSettings.Builder
+ updateLogicalViewSettings() {
+ return getStubSettingsBuilder().updateLogicalViewSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to updateLogicalView. */
+ public OperationCallSettings.Builder<
+ UpdateLogicalViewRequest, LogicalView, UpdateLogicalViewMetadata>
+ updateLogicalViewOperationSettings() {
+ return getStubSettingsBuilder().updateLogicalViewOperationSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to deleteLogicalView. */
+ public UnaryCallSettings.Builder deleteLogicalViewSettings() {
+ return getStubSettingsBuilder().deleteLogicalViewSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to createMaterializedView. */
+ public UnaryCallSettings.Builder
+ createMaterializedViewSettings() {
+ return getStubSettingsBuilder().createMaterializedViewSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to createMaterializedView. */
+ public OperationCallSettings.Builder<
+ CreateMaterializedViewRequest, MaterializedView, CreateMaterializedViewMetadata>
+ createMaterializedViewOperationSettings() {
+ return getStubSettingsBuilder().createMaterializedViewOperationSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to getMaterializedView. */
+ public UnaryCallSettings.Builder
+ getMaterializedViewSettings() {
+ return getStubSettingsBuilder().getMaterializedViewSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to listMaterializedViews. */
+ public PagedCallSettings.Builder<
+ ListMaterializedViewsRequest,
+ ListMaterializedViewsResponse,
+ ListMaterializedViewsPagedResponse>
+ listMaterializedViewsSettings() {
+ return getStubSettingsBuilder().listMaterializedViewsSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to updateMaterializedView. */
+ public UnaryCallSettings.Builder
+ updateMaterializedViewSettings() {
+ return getStubSettingsBuilder().updateMaterializedViewSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to updateMaterializedView. */
+ public OperationCallSettings.Builder<
+ UpdateMaterializedViewRequest, MaterializedView, UpdateMaterializedViewMetadata>
+ updateMaterializedViewOperationSettings() {
+ return getStubSettingsBuilder().updateMaterializedViewOperationSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to deleteMaterializedView. */
+ public UnaryCallSettings.Builder
+ deleteMaterializedViewSettings() {
+ return getStubSettingsBuilder().deleteMaterializedViewSettings();
+ }
+
@Override
public BaseBigtableInstanceAdminSettings build() throws IOException {
return new BaseBigtableInstanceAdminSettings(this);
diff --git a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/gapic_metadata.json b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/gapic_metadata.json
index 4918b8f0b386..868657a3eaa8 100644
--- a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/gapic_metadata.json
+++ b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/gapic_metadata.json
@@ -19,6 +19,12 @@
"CreateInstance": {
"methods": ["createInstanceAsync", "createInstanceAsync", "createInstanceAsync", "createInstanceOperationCallable", "createInstanceCallable"]
},
+ "CreateLogicalView": {
+ "methods": ["createLogicalViewAsync", "createLogicalViewAsync", "createLogicalViewAsync", "createLogicalViewOperationCallable", "createLogicalViewCallable"]
+ },
+ "CreateMaterializedView": {
+ "methods": ["createMaterializedViewAsync", "createMaterializedViewAsync", "createMaterializedViewAsync", "createMaterializedViewOperationCallable", "createMaterializedViewCallable"]
+ },
"DeleteAppProfile": {
"methods": ["deleteAppProfile", "deleteAppProfile", "deleteAppProfile", "deleteAppProfile", "deleteAppProfile", "deleteAppProfileCallable"]
},
@@ -28,6 +34,12 @@
"DeleteInstance": {
"methods": ["deleteInstance", "deleteInstance", "deleteInstance", "deleteInstanceCallable"]
},
+ "DeleteLogicalView": {
+ "methods": ["deleteLogicalView", "deleteLogicalView", "deleteLogicalView", "deleteLogicalViewCallable"]
+ },
+ "DeleteMaterializedView": {
+ "methods": ["deleteMaterializedView", "deleteMaterializedView", "deleteMaterializedView", "deleteMaterializedViewCallable"]
+ },
"GetAppProfile": {
"methods": ["getAppProfile", "getAppProfile", "getAppProfile", "getAppProfileCallable"]
},
@@ -40,6 +52,12 @@
"GetInstance": {
"methods": ["getInstance", "getInstance", "getInstance", "getInstanceCallable"]
},
+ "GetLogicalView": {
+ "methods": ["getLogicalView", "getLogicalView", "getLogicalView", "getLogicalViewCallable"]
+ },
+ "GetMaterializedView": {
+ "methods": ["getMaterializedView", "getMaterializedView", "getMaterializedView", "getMaterializedViewCallable"]
+ },
"ListAppProfiles": {
"methods": ["listAppProfiles", "listAppProfiles", "listAppProfiles", "listAppProfilesPagedCallable", "listAppProfilesCallable"]
},
@@ -52,6 +70,12 @@
"ListInstances": {
"methods": ["listInstances", "listInstances", "listInstances", "listInstancesCallable"]
},
+ "ListLogicalViews": {
+ "methods": ["listLogicalViews", "listLogicalViews", "listLogicalViews", "listLogicalViewsPagedCallable", "listLogicalViewsCallable"]
+ },
+ "ListMaterializedViews": {
+ "methods": ["listMaterializedViews", "listMaterializedViews", "listMaterializedViews", "listMaterializedViewsPagedCallable", "listMaterializedViewsCallable"]
+ },
"PartialUpdateCluster": {
"methods": ["partialUpdateClusterAsync", "partialUpdateClusterAsync", "partialUpdateClusterOperationCallable", "partialUpdateClusterCallable"]
},
@@ -72,6 +96,12 @@
},
"UpdateInstance": {
"methods": ["updateInstance", "updateInstanceCallable"]
+ },
+ "UpdateLogicalView": {
+ "methods": ["updateLogicalViewAsync", "updateLogicalViewAsync", "updateLogicalViewOperationCallable", "updateLogicalViewCallable"]
+ },
+ "UpdateMaterializedView": {
+ "methods": ["updateMaterializedViewAsync", "updateMaterializedViewAsync", "updateMaterializedViewOperationCallable", "updateMaterializedViewCallable"]
}
}
}
diff --git a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/stub/BigtableInstanceAdminStub.java b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/stub/BigtableInstanceAdminStub.java
index 3a2add3e3497..51218575d9a5 100644
--- a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/stub/BigtableInstanceAdminStub.java
+++ b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/stub/BigtableInstanceAdminStub.java
@@ -18,6 +18,8 @@
import static com.google.cloud.bigtable.admin.v2.BaseBigtableInstanceAdminClient.ListAppProfilesPagedResponse;
import static com.google.cloud.bigtable.admin.v2.BaseBigtableInstanceAdminClient.ListHotTabletsPagedResponse;
+import static com.google.cloud.bigtable.admin.v2.BaseBigtableInstanceAdminClient.ListLogicalViewsPagedResponse;
+import static com.google.cloud.bigtable.admin.v2.BaseBigtableInstanceAdminClient.ListMaterializedViewsPagedResponse;
import com.google.api.core.InternalApi;
import com.google.api.gax.core.BackgroundResource;
@@ -30,12 +32,20 @@
import com.google.bigtable.admin.v2.CreateClusterRequest;
import com.google.bigtable.admin.v2.CreateInstanceMetadata;
import com.google.bigtable.admin.v2.CreateInstanceRequest;
+import com.google.bigtable.admin.v2.CreateLogicalViewMetadata;
+import com.google.bigtable.admin.v2.CreateLogicalViewRequest;
+import com.google.bigtable.admin.v2.CreateMaterializedViewMetadata;
+import com.google.bigtable.admin.v2.CreateMaterializedViewRequest;
import com.google.bigtable.admin.v2.DeleteAppProfileRequest;
import com.google.bigtable.admin.v2.DeleteClusterRequest;
import com.google.bigtable.admin.v2.DeleteInstanceRequest;
+import com.google.bigtable.admin.v2.DeleteLogicalViewRequest;
+import com.google.bigtable.admin.v2.DeleteMaterializedViewRequest;
import com.google.bigtable.admin.v2.GetAppProfileRequest;
import com.google.bigtable.admin.v2.GetClusterRequest;
import com.google.bigtable.admin.v2.GetInstanceRequest;
+import com.google.bigtable.admin.v2.GetLogicalViewRequest;
+import com.google.bigtable.admin.v2.GetMaterializedViewRequest;
import com.google.bigtable.admin.v2.Instance;
import com.google.bigtable.admin.v2.ListAppProfilesRequest;
import com.google.bigtable.admin.v2.ListAppProfilesResponse;
@@ -45,6 +55,12 @@
import com.google.bigtable.admin.v2.ListHotTabletsResponse;
import com.google.bigtable.admin.v2.ListInstancesRequest;
import com.google.bigtable.admin.v2.ListInstancesResponse;
+import com.google.bigtable.admin.v2.ListLogicalViewsRequest;
+import com.google.bigtable.admin.v2.ListLogicalViewsResponse;
+import com.google.bigtable.admin.v2.ListMaterializedViewsRequest;
+import com.google.bigtable.admin.v2.ListMaterializedViewsResponse;
+import com.google.bigtable.admin.v2.LogicalView;
+import com.google.bigtable.admin.v2.MaterializedView;
import com.google.bigtable.admin.v2.PartialUpdateClusterMetadata;
import com.google.bigtable.admin.v2.PartialUpdateClusterRequest;
import com.google.bigtable.admin.v2.PartialUpdateInstanceRequest;
@@ -52,6 +68,10 @@
import com.google.bigtable.admin.v2.UpdateAppProfileRequest;
import com.google.bigtable.admin.v2.UpdateClusterMetadata;
import com.google.bigtable.admin.v2.UpdateInstanceMetadata;
+import com.google.bigtable.admin.v2.UpdateLogicalViewMetadata;
+import com.google.bigtable.admin.v2.UpdateLogicalViewRequest;
+import com.google.bigtable.admin.v2.UpdateMaterializedViewMetadata;
+import com.google.bigtable.admin.v2.UpdateMaterializedViewRequest;
import com.google.iam.v1.GetIamPolicyRequest;
import com.google.iam.v1.Policy;
import com.google.iam.v1.SetIamPolicyRequest;
@@ -199,6 +219,85 @@ public UnaryCallable listHotTable
throw new UnsupportedOperationException("Not implemented: listHotTabletsCallable()");
}
+ public OperationCallable
+ createLogicalViewOperationCallable() {
+ throw new UnsupportedOperationException(
+ "Not implemented: createLogicalViewOperationCallable()");
+ }
+
+ public UnaryCallable createLogicalViewCallable() {
+ throw new UnsupportedOperationException("Not implemented: createLogicalViewCallable()");
+ }
+
+ public UnaryCallable getLogicalViewCallable() {
+ throw new UnsupportedOperationException("Not implemented: getLogicalViewCallable()");
+ }
+
+ public UnaryCallable
+ listLogicalViewsPagedCallable() {
+ throw new UnsupportedOperationException("Not implemented: listLogicalViewsPagedCallable()");
+ }
+
+ public UnaryCallable
+ listLogicalViewsCallable() {
+ throw new UnsupportedOperationException("Not implemented: listLogicalViewsCallable()");
+ }
+
+ public OperationCallable
+ updateLogicalViewOperationCallable() {
+ throw new UnsupportedOperationException(
+ "Not implemented: updateLogicalViewOperationCallable()");
+ }
+
+ public UnaryCallable updateLogicalViewCallable() {
+ throw new UnsupportedOperationException("Not implemented: updateLogicalViewCallable()");
+ }
+
+ public UnaryCallable deleteLogicalViewCallable() {
+ throw new UnsupportedOperationException("Not implemented: deleteLogicalViewCallable()");
+ }
+
+ public OperationCallable<
+ CreateMaterializedViewRequest, MaterializedView, CreateMaterializedViewMetadata>
+ createMaterializedViewOperationCallable() {
+ throw new UnsupportedOperationException(
+ "Not implemented: createMaterializedViewOperationCallable()");
+ }
+
+ public UnaryCallable createMaterializedViewCallable() {
+ throw new UnsupportedOperationException("Not implemented: createMaterializedViewCallable()");
+ }
+
+ public UnaryCallable getMaterializedViewCallable() {
+ throw new UnsupportedOperationException("Not implemented: getMaterializedViewCallable()");
+ }
+
+ public UnaryCallable
+ listMaterializedViewsPagedCallable() {
+ throw new UnsupportedOperationException(
+ "Not implemented: listMaterializedViewsPagedCallable()");
+ }
+
+ public UnaryCallable
+ listMaterializedViewsCallable() {
+ throw new UnsupportedOperationException("Not implemented: listMaterializedViewsCallable()");
+ }
+
+ public OperationCallable<
+ UpdateMaterializedViewRequest, MaterializedView, UpdateMaterializedViewMetadata>
+ updateMaterializedViewOperationCallable() {
+ throw new UnsupportedOperationException(
+ "Not implemented: updateMaterializedViewOperationCallable()");
+ }
+
+ public UnaryCallable updateMaterializedViewCallable() {
+ throw new UnsupportedOperationException("Not implemented: updateMaterializedViewCallable()");
+ }
+
+ public UnaryCallable deleteMaterializedViewCallable() {
+ throw new UnsupportedOperationException("Not implemented: deleteMaterializedViewCallable()");
+ }
+
@Override
public abstract void close();
}
diff --git a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/stub/BigtableInstanceAdminStubSettings.java b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/stub/BigtableInstanceAdminStubSettings.java
index 3951f178235a..6678392d3240 100644
--- a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/stub/BigtableInstanceAdminStubSettings.java
+++ b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/stub/BigtableInstanceAdminStubSettings.java
@@ -18,6 +18,8 @@
import static com.google.cloud.bigtable.admin.v2.BaseBigtableInstanceAdminClient.ListAppProfilesPagedResponse;
import static com.google.cloud.bigtable.admin.v2.BaseBigtableInstanceAdminClient.ListHotTabletsPagedResponse;
+import static com.google.cloud.bigtable.admin.v2.BaseBigtableInstanceAdminClient.ListLogicalViewsPagedResponse;
+import static com.google.cloud.bigtable.admin.v2.BaseBigtableInstanceAdminClient.ListMaterializedViewsPagedResponse;
import com.google.api.core.ApiFunction;
import com.google.api.core.ApiFuture;
@@ -52,12 +54,20 @@
import com.google.bigtable.admin.v2.CreateClusterRequest;
import com.google.bigtable.admin.v2.CreateInstanceMetadata;
import com.google.bigtable.admin.v2.CreateInstanceRequest;
+import com.google.bigtable.admin.v2.CreateLogicalViewMetadata;
+import com.google.bigtable.admin.v2.CreateLogicalViewRequest;
+import com.google.bigtable.admin.v2.CreateMaterializedViewMetadata;
+import com.google.bigtable.admin.v2.CreateMaterializedViewRequest;
import com.google.bigtable.admin.v2.DeleteAppProfileRequest;
import com.google.bigtable.admin.v2.DeleteClusterRequest;
import com.google.bigtable.admin.v2.DeleteInstanceRequest;
+import com.google.bigtable.admin.v2.DeleteLogicalViewRequest;
+import com.google.bigtable.admin.v2.DeleteMaterializedViewRequest;
import com.google.bigtable.admin.v2.GetAppProfileRequest;
import com.google.bigtable.admin.v2.GetClusterRequest;
import com.google.bigtable.admin.v2.GetInstanceRequest;
+import com.google.bigtable.admin.v2.GetLogicalViewRequest;
+import com.google.bigtable.admin.v2.GetMaterializedViewRequest;
import com.google.bigtable.admin.v2.HotTablet;
import com.google.bigtable.admin.v2.Instance;
import com.google.bigtable.admin.v2.ListAppProfilesRequest;
@@ -68,6 +78,12 @@
import com.google.bigtable.admin.v2.ListHotTabletsResponse;
import com.google.bigtable.admin.v2.ListInstancesRequest;
import com.google.bigtable.admin.v2.ListInstancesResponse;
+import com.google.bigtable.admin.v2.ListLogicalViewsRequest;
+import com.google.bigtable.admin.v2.ListLogicalViewsResponse;
+import com.google.bigtable.admin.v2.ListMaterializedViewsRequest;
+import com.google.bigtable.admin.v2.ListMaterializedViewsResponse;
+import com.google.bigtable.admin.v2.LogicalView;
+import com.google.bigtable.admin.v2.MaterializedView;
import com.google.bigtable.admin.v2.PartialUpdateClusterMetadata;
import com.google.bigtable.admin.v2.PartialUpdateClusterRequest;
import com.google.bigtable.admin.v2.PartialUpdateInstanceRequest;
@@ -75,6 +91,10 @@
import com.google.bigtable.admin.v2.UpdateAppProfileRequest;
import com.google.bigtable.admin.v2.UpdateClusterMetadata;
import com.google.bigtable.admin.v2.UpdateInstanceMetadata;
+import com.google.bigtable.admin.v2.UpdateLogicalViewMetadata;
+import com.google.bigtable.admin.v2.UpdateLogicalViewRequest;
+import com.google.bigtable.admin.v2.UpdateMaterializedViewMetadata;
+import com.google.bigtable.admin.v2.UpdateMaterializedViewRequest;
import com.google.common.collect.ImmutableList;
import com.google.common.collect.ImmutableMap;
import com.google.common.collect.ImmutableSet;
@@ -226,6 +246,38 @@ public class BigtableInstanceAdminStubSettings
private final PagedCallSettings<
ListHotTabletsRequest, ListHotTabletsResponse, ListHotTabletsPagedResponse>
listHotTabletsSettings;
+ private final UnaryCallSettings createLogicalViewSettings;
+ private final OperationCallSettings<
+ CreateLogicalViewRequest, LogicalView, CreateLogicalViewMetadata>
+ createLogicalViewOperationSettings;
+ private final UnaryCallSettings getLogicalViewSettings;
+ private final PagedCallSettings<
+ ListLogicalViewsRequest, ListLogicalViewsResponse, ListLogicalViewsPagedResponse>
+ listLogicalViewsSettings;
+ private final UnaryCallSettings updateLogicalViewSettings;
+ private final OperationCallSettings<
+ UpdateLogicalViewRequest, LogicalView, UpdateLogicalViewMetadata>
+ updateLogicalViewOperationSettings;
+ private final UnaryCallSettings deleteLogicalViewSettings;
+ private final UnaryCallSettings
+ createMaterializedViewSettings;
+ private final OperationCallSettings<
+ CreateMaterializedViewRequest, MaterializedView, CreateMaterializedViewMetadata>
+ createMaterializedViewOperationSettings;
+ private final UnaryCallSettings
+ getMaterializedViewSettings;
+ private final PagedCallSettings<
+ ListMaterializedViewsRequest,
+ ListMaterializedViewsResponse,
+ ListMaterializedViewsPagedResponse>
+ listMaterializedViewsSettings;
+ private final UnaryCallSettings
+ updateMaterializedViewSettings;
+ private final OperationCallSettings<
+ UpdateMaterializedViewRequest, MaterializedView, UpdateMaterializedViewMetadata>
+ updateMaterializedViewOperationSettings;
+ private final UnaryCallSettings
+ deleteMaterializedViewSettings;
private static final PagedListDescriptor<
ListAppProfilesRequest, ListAppProfilesResponse, AppProfile>
@@ -299,6 +351,83 @@ public Iterable extractResources(ListHotTabletsResponse payload) {
}
};
+ private static final PagedListDescriptor<
+ ListLogicalViewsRequest, ListLogicalViewsResponse, LogicalView>
+ LIST_LOGICAL_VIEWS_PAGE_STR_DESC =
+ new PagedListDescriptor<
+ ListLogicalViewsRequest, ListLogicalViewsResponse, LogicalView>() {
+ @Override
+ public String emptyToken() {
+ return "";
+ }
+
+ @Override
+ public ListLogicalViewsRequest injectToken(
+ ListLogicalViewsRequest payload, String token) {
+ return ListLogicalViewsRequest.newBuilder(payload).setPageToken(token).build();
+ }
+
+ @Override
+ public ListLogicalViewsRequest injectPageSize(
+ ListLogicalViewsRequest payload, int pageSize) {
+ return ListLogicalViewsRequest.newBuilder(payload).setPageSize(pageSize).build();
+ }
+
+ @Override
+ public Integer extractPageSize(ListLogicalViewsRequest payload) {
+ return payload.getPageSize();
+ }
+
+ @Override
+ public String extractNextToken(ListLogicalViewsResponse payload) {
+ return payload.getNextPageToken();
+ }
+
+ @Override
+ public Iterable extractResources(ListLogicalViewsResponse payload) {
+ return payload.getLogicalViewsList();
+ }
+ };
+
+ private static final PagedListDescriptor<
+ ListMaterializedViewsRequest, ListMaterializedViewsResponse, MaterializedView>
+ LIST_MATERIALIZED_VIEWS_PAGE_STR_DESC =
+ new PagedListDescriptor<
+ ListMaterializedViewsRequest, ListMaterializedViewsResponse, MaterializedView>() {
+ @Override
+ public String emptyToken() {
+ return "";
+ }
+
+ @Override
+ public ListMaterializedViewsRequest injectToken(
+ ListMaterializedViewsRequest payload, String token) {
+ return ListMaterializedViewsRequest.newBuilder(payload).setPageToken(token).build();
+ }
+
+ @Override
+ public ListMaterializedViewsRequest injectPageSize(
+ ListMaterializedViewsRequest payload, int pageSize) {
+ return ListMaterializedViewsRequest.newBuilder(payload).setPageSize(pageSize).build();
+ }
+
+ @Override
+ public Integer extractPageSize(ListMaterializedViewsRequest payload) {
+ return payload.getPageSize();
+ }
+
+ @Override
+ public String extractNextToken(ListMaterializedViewsResponse payload) {
+ return payload.getNextPageToken();
+ }
+
+ @Override
+ public Iterable extractResources(
+ ListMaterializedViewsResponse payload) {
+ return payload.getMaterializedViewsList();
+ }
+ };
+
private static final PagedListResponseFactory<
ListAppProfilesRequest, ListAppProfilesResponse, ListAppProfilesPagedResponse>
LIST_APP_PROFILES_PAGE_STR_FACT =
@@ -333,6 +462,49 @@ public ApiFuture getFuturePagedResponse(
}
};
+ private static final PagedListResponseFactory<
+ ListLogicalViewsRequest, ListLogicalViewsResponse, ListLogicalViewsPagedResponse>
+ LIST_LOGICAL_VIEWS_PAGE_STR_FACT =
+ new PagedListResponseFactory<
+ ListLogicalViewsRequest, ListLogicalViewsResponse, ListLogicalViewsPagedResponse>() {
+ @Override
+ public ApiFuture getFuturePagedResponse(
+ UnaryCallable callable,
+ ListLogicalViewsRequest request,
+ ApiCallContext context,
+ ApiFuture futureResponse) {
+ PageContext
+ pageContext =
+ PageContext.create(
+ callable, LIST_LOGICAL_VIEWS_PAGE_STR_DESC, request, context);
+ return ListLogicalViewsPagedResponse.createAsync(pageContext, futureResponse);
+ }
+ };
+
+ private static final PagedListResponseFactory<
+ ListMaterializedViewsRequest,
+ ListMaterializedViewsResponse,
+ ListMaterializedViewsPagedResponse>
+ LIST_MATERIALIZED_VIEWS_PAGE_STR_FACT =
+ new PagedListResponseFactory<
+ ListMaterializedViewsRequest,
+ ListMaterializedViewsResponse,
+ ListMaterializedViewsPagedResponse>() {
+ @Override
+ public ApiFuture getFuturePagedResponse(
+ UnaryCallable callable,
+ ListMaterializedViewsRequest request,
+ ApiCallContext context,
+ ApiFuture futureResponse) {
+ PageContext<
+ ListMaterializedViewsRequest, ListMaterializedViewsResponse, MaterializedView>
+ pageContext =
+ PageContext.create(
+ callable, LIST_MATERIALIZED_VIEWS_PAGE_STR_DESC, request, context);
+ return ListMaterializedViewsPagedResponse.createAsync(pageContext, futureResponse);
+ }
+ };
+
/** Returns the object with the settings used for calls to createInstance. */
public UnaryCallSettings createInstanceSettings() {
return createInstanceSettings;
@@ -480,6 +652,91 @@ public UnaryCallSettings setIamPolicySettings() {
return listHotTabletsSettings;
}
+ /** Returns the object with the settings used for calls to createLogicalView. */
+ public UnaryCallSettings createLogicalViewSettings() {
+ return createLogicalViewSettings;
+ }
+
+ /** Returns the object with the settings used for calls to createLogicalView. */
+ public OperationCallSettings
+ createLogicalViewOperationSettings() {
+ return createLogicalViewOperationSettings;
+ }
+
+ /** Returns the object with the settings used for calls to getLogicalView. */
+ public UnaryCallSettings getLogicalViewSettings() {
+ return getLogicalViewSettings;
+ }
+
+ /** Returns the object with the settings used for calls to listLogicalViews. */
+ public PagedCallSettings<
+ ListLogicalViewsRequest, ListLogicalViewsResponse, ListLogicalViewsPagedResponse>
+ listLogicalViewsSettings() {
+ return listLogicalViewsSettings;
+ }
+
+ /** Returns the object with the settings used for calls to updateLogicalView. */
+ public UnaryCallSettings updateLogicalViewSettings() {
+ return updateLogicalViewSettings;
+ }
+
+ /** Returns the object with the settings used for calls to updateLogicalView. */
+ public OperationCallSettings
+ updateLogicalViewOperationSettings() {
+ return updateLogicalViewOperationSettings;
+ }
+
+ /** Returns the object with the settings used for calls to deleteLogicalView. */
+ public UnaryCallSettings deleteLogicalViewSettings() {
+ return deleteLogicalViewSettings;
+ }
+
+ /** Returns the object with the settings used for calls to createMaterializedView. */
+ public UnaryCallSettings
+ createMaterializedViewSettings() {
+ return createMaterializedViewSettings;
+ }
+
+ /** Returns the object with the settings used for calls to createMaterializedView. */
+ public OperationCallSettings<
+ CreateMaterializedViewRequest, MaterializedView, CreateMaterializedViewMetadata>
+ createMaterializedViewOperationSettings() {
+ return createMaterializedViewOperationSettings;
+ }
+
+ /** Returns the object with the settings used for calls to getMaterializedView. */
+ public UnaryCallSettings
+ getMaterializedViewSettings() {
+ return getMaterializedViewSettings;
+ }
+
+ /** Returns the object with the settings used for calls to listMaterializedViews. */
+ public PagedCallSettings<
+ ListMaterializedViewsRequest,
+ ListMaterializedViewsResponse,
+ ListMaterializedViewsPagedResponse>
+ listMaterializedViewsSettings() {
+ return listMaterializedViewsSettings;
+ }
+
+ /** Returns the object with the settings used for calls to updateMaterializedView. */
+ public UnaryCallSettings
+ updateMaterializedViewSettings() {
+ return updateMaterializedViewSettings;
+ }
+
+ /** Returns the object with the settings used for calls to updateMaterializedView. */
+ public OperationCallSettings<
+ UpdateMaterializedViewRequest, MaterializedView, UpdateMaterializedViewMetadata>
+ updateMaterializedViewOperationSettings() {
+ return updateMaterializedViewOperationSettings;
+ }
+
+ /** Returns the object with the settings used for calls to deleteMaterializedView. */
+ public UnaryCallSettings deleteMaterializedViewSettings() {
+ return deleteMaterializedViewSettings;
+ }
+
public BigtableInstanceAdminStub createStub() throws IOException {
if (getTransportChannelProvider()
.getTransportName()
@@ -590,6 +847,24 @@ protected BigtableInstanceAdminStubSettings(Builder settingsBuilder) throws IOEx
setIamPolicySettings = settingsBuilder.setIamPolicySettings().build();
testIamPermissionsSettings = settingsBuilder.testIamPermissionsSettings().build();
listHotTabletsSettings = settingsBuilder.listHotTabletsSettings().build();
+ createLogicalViewSettings = settingsBuilder.createLogicalViewSettings().build();
+ createLogicalViewOperationSettings =
+ settingsBuilder.createLogicalViewOperationSettings().build();
+ getLogicalViewSettings = settingsBuilder.getLogicalViewSettings().build();
+ listLogicalViewsSettings = settingsBuilder.listLogicalViewsSettings().build();
+ updateLogicalViewSettings = settingsBuilder.updateLogicalViewSettings().build();
+ updateLogicalViewOperationSettings =
+ settingsBuilder.updateLogicalViewOperationSettings().build();
+ deleteLogicalViewSettings = settingsBuilder.deleteLogicalViewSettings().build();
+ createMaterializedViewSettings = settingsBuilder.createMaterializedViewSettings().build();
+ createMaterializedViewOperationSettings =
+ settingsBuilder.createMaterializedViewOperationSettings().build();
+ getMaterializedViewSettings = settingsBuilder.getMaterializedViewSettings().build();
+ listMaterializedViewsSettings = settingsBuilder.listMaterializedViewsSettings().build();
+ updateMaterializedViewSettings = settingsBuilder.updateMaterializedViewSettings().build();
+ updateMaterializedViewOperationSettings =
+ settingsBuilder.updateMaterializedViewOperationSettings().build();
+ deleteMaterializedViewSettings = settingsBuilder.deleteMaterializedViewSettings().build();
}
/** Builder for BigtableInstanceAdminStubSettings. */
@@ -647,6 +922,42 @@ public static class Builder
private final PagedCallSettings.Builder<
ListHotTabletsRequest, ListHotTabletsResponse, ListHotTabletsPagedResponse>
listHotTabletsSettings;
+ private final UnaryCallSettings.Builder
+ createLogicalViewSettings;
+ private final OperationCallSettings.Builder<
+ CreateLogicalViewRequest, LogicalView, CreateLogicalViewMetadata>
+ createLogicalViewOperationSettings;
+ private final UnaryCallSettings.Builder
+ getLogicalViewSettings;
+ private final PagedCallSettings.Builder<
+ ListLogicalViewsRequest, ListLogicalViewsResponse, ListLogicalViewsPagedResponse>
+ listLogicalViewsSettings;
+ private final UnaryCallSettings.Builder
+ updateLogicalViewSettings;
+ private final OperationCallSettings.Builder<
+ UpdateLogicalViewRequest, LogicalView, UpdateLogicalViewMetadata>
+ updateLogicalViewOperationSettings;
+ private final UnaryCallSettings.Builder
+ deleteLogicalViewSettings;
+ private final UnaryCallSettings.Builder
+ createMaterializedViewSettings;
+ private final OperationCallSettings.Builder<
+ CreateMaterializedViewRequest, MaterializedView, CreateMaterializedViewMetadata>
+ createMaterializedViewOperationSettings;
+ private final UnaryCallSettings.Builder
+ getMaterializedViewSettings;
+ private final PagedCallSettings.Builder<
+ ListMaterializedViewsRequest,
+ ListMaterializedViewsResponse,
+ ListMaterializedViewsPagedResponse>
+ listMaterializedViewsSettings;
+ private final UnaryCallSettings.Builder
+ updateMaterializedViewSettings;
+ private final OperationCallSettings.Builder<
+ UpdateMaterializedViewRequest, MaterializedView, UpdateMaterializedViewMetadata>
+ updateMaterializedViewOperationSettings;
+ private final UnaryCallSettings.Builder
+ deleteMaterializedViewSettings;
private static final ImmutableMap>
RETRYABLE_CODE_DEFINITIONS;
@@ -737,6 +1048,21 @@ protected Builder(ClientContext clientContext) {
setIamPolicySettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
testIamPermissionsSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
listHotTabletsSettings = PagedCallSettings.newBuilder(LIST_HOT_TABLETS_PAGE_STR_FACT);
+ createLogicalViewSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ createLogicalViewOperationSettings = OperationCallSettings.newBuilder();
+ getLogicalViewSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ listLogicalViewsSettings = PagedCallSettings.newBuilder(LIST_LOGICAL_VIEWS_PAGE_STR_FACT);
+ updateLogicalViewSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ updateLogicalViewOperationSettings = OperationCallSettings.newBuilder();
+ deleteLogicalViewSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ createMaterializedViewSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ createMaterializedViewOperationSettings = OperationCallSettings.newBuilder();
+ getMaterializedViewSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ listMaterializedViewsSettings =
+ PagedCallSettings.newBuilder(LIST_MATERIALIZED_VIEWS_PAGE_STR_FACT);
+ updateMaterializedViewSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ updateMaterializedViewOperationSettings = OperationCallSettings.newBuilder();
+ deleteMaterializedViewSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
unaryMethodSettingsBuilders =
ImmutableList.>of(
@@ -760,7 +1086,17 @@ protected Builder(ClientContext clientContext) {
getIamPolicySettings,
setIamPolicySettings,
testIamPermissionsSettings,
- listHotTabletsSettings);
+ listHotTabletsSettings,
+ createLogicalViewSettings,
+ getLogicalViewSettings,
+ listLogicalViewsSettings,
+ updateLogicalViewSettings,
+ deleteLogicalViewSettings,
+ createMaterializedViewSettings,
+ getMaterializedViewSettings,
+ listMaterializedViewsSettings,
+ updateMaterializedViewSettings,
+ deleteMaterializedViewSettings);
initDefaults(this);
}
@@ -796,6 +1132,22 @@ protected Builder(BigtableInstanceAdminStubSettings settings) {
setIamPolicySettings = settings.setIamPolicySettings.toBuilder();
testIamPermissionsSettings = settings.testIamPermissionsSettings.toBuilder();
listHotTabletsSettings = settings.listHotTabletsSettings.toBuilder();
+ createLogicalViewSettings = settings.createLogicalViewSettings.toBuilder();
+ createLogicalViewOperationSettings = settings.createLogicalViewOperationSettings.toBuilder();
+ getLogicalViewSettings = settings.getLogicalViewSettings.toBuilder();
+ listLogicalViewsSettings = settings.listLogicalViewsSettings.toBuilder();
+ updateLogicalViewSettings = settings.updateLogicalViewSettings.toBuilder();
+ updateLogicalViewOperationSettings = settings.updateLogicalViewOperationSettings.toBuilder();
+ deleteLogicalViewSettings = settings.deleteLogicalViewSettings.toBuilder();
+ createMaterializedViewSettings = settings.createMaterializedViewSettings.toBuilder();
+ createMaterializedViewOperationSettings =
+ settings.createMaterializedViewOperationSettings.toBuilder();
+ getMaterializedViewSettings = settings.getMaterializedViewSettings.toBuilder();
+ listMaterializedViewsSettings = settings.listMaterializedViewsSettings.toBuilder();
+ updateMaterializedViewSettings = settings.updateMaterializedViewSettings.toBuilder();
+ updateMaterializedViewOperationSettings =
+ settings.updateMaterializedViewOperationSettings.toBuilder();
+ deleteMaterializedViewSettings = settings.deleteMaterializedViewSettings.toBuilder();
unaryMethodSettingsBuilders =
ImmutableList.>of(
@@ -819,7 +1171,17 @@ protected Builder(BigtableInstanceAdminStubSettings settings) {
getIamPolicySettings,
setIamPolicySettings,
testIamPermissionsSettings,
- listHotTabletsSettings);
+ listHotTabletsSettings,
+ createLogicalViewSettings,
+ getLogicalViewSettings,
+ listLogicalViewsSettings,
+ updateLogicalViewSettings,
+ deleteLogicalViewSettings,
+ createMaterializedViewSettings,
+ getMaterializedViewSettings,
+ listMaterializedViewsSettings,
+ updateMaterializedViewSettings,
+ deleteMaterializedViewSettings);
}
private static Builder createDefault() {
@@ -940,6 +1302,56 @@ private static Builder initDefaults(Builder builder) {
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_6_codes"))
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_6_params"));
+ builder
+ .createLogicalViewSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
+
+ builder
+ .getLogicalViewSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
+
+ builder
+ .listLogicalViewsSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
+
+ builder
+ .updateLogicalViewSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
+
+ builder
+ .deleteLogicalViewSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
+
+ builder
+ .createMaterializedViewSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
+
+ builder
+ .getMaterializedViewSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
+
+ builder
+ .listMaterializedViewsSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
+
+ builder
+ .updateMaterializedViewSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
+
+ builder
+ .deleteMaterializedViewSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
+
builder
.createInstanceOperationSettings()
.setInitialCallSettings(
@@ -1084,6 +1496,106 @@ private static Builder initDefaults(Builder builder) {
.setTotalTimeoutDuration(Duration.ofMillis(600000L))
.build()));
+ builder
+ .createLogicalViewOperationSettings()
+ .setInitialCallSettings(
+ UnaryCallSettings
+ .newUnaryCallSettingsBuilder()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"))
+ .build())
+ .setResponseTransformer(
+ ProtoOperationTransformers.ResponseTransformer.create(LogicalView.class))
+ .setMetadataTransformer(
+ ProtoOperationTransformers.MetadataTransformer.create(
+ CreateLogicalViewMetadata.class))
+ .setPollingAlgorithm(
+ OperationTimedPollAlgorithm.create(
+ RetrySettings.newBuilder()
+ .setInitialRetryDelayDuration(Duration.ofMillis(5000L))
+ .setRetryDelayMultiplier(1.5)
+ .setMaxRetryDelayDuration(Duration.ofMillis(45000L))
+ .setInitialRpcTimeoutDuration(Duration.ZERO)
+ .setRpcTimeoutMultiplier(1.0)
+ .setMaxRpcTimeoutDuration(Duration.ZERO)
+ .setTotalTimeoutDuration(Duration.ofMillis(300000L))
+ .build()));
+
+ builder
+ .updateLogicalViewOperationSettings()
+ .setInitialCallSettings(
+ UnaryCallSettings
+ .newUnaryCallSettingsBuilder()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"))
+ .build())
+ .setResponseTransformer(
+ ProtoOperationTransformers.ResponseTransformer.create(LogicalView.class))
+ .setMetadataTransformer(
+ ProtoOperationTransformers.MetadataTransformer.create(
+ UpdateLogicalViewMetadata.class))
+ .setPollingAlgorithm(
+ OperationTimedPollAlgorithm.create(
+ RetrySettings.newBuilder()
+ .setInitialRetryDelayDuration(Duration.ofMillis(5000L))
+ .setRetryDelayMultiplier(1.5)
+ .setMaxRetryDelayDuration(Duration.ofMillis(45000L))
+ .setInitialRpcTimeoutDuration(Duration.ZERO)
+ .setRpcTimeoutMultiplier(1.0)
+ .setMaxRpcTimeoutDuration(Duration.ZERO)
+ .setTotalTimeoutDuration(Duration.ofMillis(300000L))
+ .build()));
+
+ builder
+ .createMaterializedViewOperationSettings()
+ .setInitialCallSettings(
+ UnaryCallSettings
+ .newUnaryCallSettingsBuilder()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"))
+ .build())
+ .setResponseTransformer(
+ ProtoOperationTransformers.ResponseTransformer.create(MaterializedView.class))
+ .setMetadataTransformer(
+ ProtoOperationTransformers.MetadataTransformer.create(
+ CreateMaterializedViewMetadata.class))
+ .setPollingAlgorithm(
+ OperationTimedPollAlgorithm.create(
+ RetrySettings.newBuilder()
+ .setInitialRetryDelayDuration(Duration.ofMillis(5000L))
+ .setRetryDelayMultiplier(1.5)
+ .setMaxRetryDelayDuration(Duration.ofMillis(45000L))
+ .setInitialRpcTimeoutDuration(Duration.ZERO)
+ .setRpcTimeoutMultiplier(1.0)
+ .setMaxRpcTimeoutDuration(Duration.ZERO)
+ .setTotalTimeoutDuration(Duration.ofMillis(300000L))
+ .build()));
+
+ builder
+ .updateMaterializedViewOperationSettings()
+ .setInitialCallSettings(
+ UnaryCallSettings
+ .newUnaryCallSettingsBuilder()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"))
+ .build())
+ .setResponseTransformer(
+ ProtoOperationTransformers.ResponseTransformer.create(MaterializedView.class))
+ .setMetadataTransformer(
+ ProtoOperationTransformers.MetadataTransformer.create(
+ UpdateMaterializedViewMetadata.class))
+ .setPollingAlgorithm(
+ OperationTimedPollAlgorithm.create(
+ RetrySettings.newBuilder()
+ .setInitialRetryDelayDuration(Duration.ofMillis(5000L))
+ .setRetryDelayMultiplier(1.5)
+ .setMaxRetryDelayDuration(Duration.ofMillis(45000L))
+ .setInitialRpcTimeoutDuration(Duration.ZERO)
+ .setRpcTimeoutMultiplier(1.0)
+ .setMaxRpcTimeoutDuration(Duration.ZERO)
+ .setTotalTimeoutDuration(Duration.ofMillis(300000L))
+ .build()));
+
return builder;
}
@@ -1257,6 +1769,96 @@ public UnaryCallSettings.Builder setIamPolicySettin
return listHotTabletsSettings;
}
+ /** Returns the builder for the settings used for calls to createLogicalView. */
+ public UnaryCallSettings.Builder
+ createLogicalViewSettings() {
+ return createLogicalViewSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to createLogicalView. */
+ public OperationCallSettings.Builder<
+ CreateLogicalViewRequest, LogicalView, CreateLogicalViewMetadata>
+ createLogicalViewOperationSettings() {
+ return createLogicalViewOperationSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to getLogicalView. */
+ public UnaryCallSettings.Builder getLogicalViewSettings() {
+ return getLogicalViewSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to listLogicalViews. */
+ public PagedCallSettings.Builder<
+ ListLogicalViewsRequest, ListLogicalViewsResponse, ListLogicalViewsPagedResponse>
+ listLogicalViewsSettings() {
+ return listLogicalViewsSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to updateLogicalView. */
+ public UnaryCallSettings.Builder
+ updateLogicalViewSettings() {
+ return updateLogicalViewSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to updateLogicalView. */
+ public OperationCallSettings.Builder<
+ UpdateLogicalViewRequest, LogicalView, UpdateLogicalViewMetadata>
+ updateLogicalViewOperationSettings() {
+ return updateLogicalViewOperationSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to deleteLogicalView. */
+ public UnaryCallSettings.Builder deleteLogicalViewSettings() {
+ return deleteLogicalViewSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to createMaterializedView. */
+ public UnaryCallSettings.Builder
+ createMaterializedViewSettings() {
+ return createMaterializedViewSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to createMaterializedView. */
+ public OperationCallSettings.Builder<
+ CreateMaterializedViewRequest, MaterializedView, CreateMaterializedViewMetadata>
+ createMaterializedViewOperationSettings() {
+ return createMaterializedViewOperationSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to getMaterializedView. */
+ public UnaryCallSettings.Builder
+ getMaterializedViewSettings() {
+ return getMaterializedViewSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to listMaterializedViews. */
+ public PagedCallSettings.Builder<
+ ListMaterializedViewsRequest,
+ ListMaterializedViewsResponse,
+ ListMaterializedViewsPagedResponse>
+ listMaterializedViewsSettings() {
+ return listMaterializedViewsSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to updateMaterializedView. */
+ public UnaryCallSettings.Builder
+ updateMaterializedViewSettings() {
+ return updateMaterializedViewSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to updateMaterializedView. */
+ public OperationCallSettings.Builder<
+ UpdateMaterializedViewRequest, MaterializedView, UpdateMaterializedViewMetadata>
+ updateMaterializedViewOperationSettings() {
+ return updateMaterializedViewOperationSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to deleteMaterializedView. */
+ public UnaryCallSettings.Builder
+ deleteMaterializedViewSettings() {
+ return deleteMaterializedViewSettings;
+ }
+
@Override
public BigtableInstanceAdminStubSettings build() throws IOException {
return new BigtableInstanceAdminStubSettings(this);
diff --git a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/stub/GrpcBigtableInstanceAdminStub.java b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/stub/GrpcBigtableInstanceAdminStub.java
index 8eb2aa4c8021..e6b2c733c306 100644
--- a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/stub/GrpcBigtableInstanceAdminStub.java
+++ b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/stub/GrpcBigtableInstanceAdminStub.java
@@ -18,6 +18,8 @@
import static com.google.cloud.bigtable.admin.v2.BaseBigtableInstanceAdminClient.ListAppProfilesPagedResponse;
import static com.google.cloud.bigtable.admin.v2.BaseBigtableInstanceAdminClient.ListHotTabletsPagedResponse;
+import static com.google.cloud.bigtable.admin.v2.BaseBigtableInstanceAdminClient.ListLogicalViewsPagedResponse;
+import static com.google.cloud.bigtable.admin.v2.BaseBigtableInstanceAdminClient.ListMaterializedViewsPagedResponse;
import com.google.api.core.InternalApi;
import com.google.api.gax.core.BackgroundResource;
@@ -35,12 +37,20 @@
import com.google.bigtable.admin.v2.CreateClusterRequest;
import com.google.bigtable.admin.v2.CreateInstanceMetadata;
import com.google.bigtable.admin.v2.CreateInstanceRequest;
+import com.google.bigtable.admin.v2.CreateLogicalViewMetadata;
+import com.google.bigtable.admin.v2.CreateLogicalViewRequest;
+import com.google.bigtable.admin.v2.CreateMaterializedViewMetadata;
+import com.google.bigtable.admin.v2.CreateMaterializedViewRequest;
import com.google.bigtable.admin.v2.DeleteAppProfileRequest;
import com.google.bigtable.admin.v2.DeleteClusterRequest;
import com.google.bigtable.admin.v2.DeleteInstanceRequest;
+import com.google.bigtable.admin.v2.DeleteLogicalViewRequest;
+import com.google.bigtable.admin.v2.DeleteMaterializedViewRequest;
import com.google.bigtable.admin.v2.GetAppProfileRequest;
import com.google.bigtable.admin.v2.GetClusterRequest;
import com.google.bigtable.admin.v2.GetInstanceRequest;
+import com.google.bigtable.admin.v2.GetLogicalViewRequest;
+import com.google.bigtable.admin.v2.GetMaterializedViewRequest;
import com.google.bigtable.admin.v2.Instance;
import com.google.bigtable.admin.v2.ListAppProfilesRequest;
import com.google.bigtable.admin.v2.ListAppProfilesResponse;
@@ -50,6 +60,12 @@
import com.google.bigtable.admin.v2.ListHotTabletsResponse;
import com.google.bigtable.admin.v2.ListInstancesRequest;
import com.google.bigtable.admin.v2.ListInstancesResponse;
+import com.google.bigtable.admin.v2.ListLogicalViewsRequest;
+import com.google.bigtable.admin.v2.ListLogicalViewsResponse;
+import com.google.bigtable.admin.v2.ListMaterializedViewsRequest;
+import com.google.bigtable.admin.v2.ListMaterializedViewsResponse;
+import com.google.bigtable.admin.v2.LogicalView;
+import com.google.bigtable.admin.v2.MaterializedView;
import com.google.bigtable.admin.v2.PartialUpdateClusterMetadata;
import com.google.bigtable.admin.v2.PartialUpdateClusterRequest;
import com.google.bigtable.admin.v2.PartialUpdateInstanceRequest;
@@ -57,6 +73,10 @@
import com.google.bigtable.admin.v2.UpdateAppProfileRequest;
import com.google.bigtable.admin.v2.UpdateClusterMetadata;
import com.google.bigtable.admin.v2.UpdateInstanceMetadata;
+import com.google.bigtable.admin.v2.UpdateLogicalViewMetadata;
+import com.google.bigtable.admin.v2.UpdateLogicalViewRequest;
+import com.google.bigtable.admin.v2.UpdateMaterializedViewMetadata;
+import com.google.bigtable.admin.v2.UpdateMaterializedViewRequest;
import com.google.iam.v1.GetIamPolicyRequest;
import com.google.iam.v1.Policy;
import com.google.iam.v1.SetIamPolicyRequest;
@@ -279,6 +299,113 @@ public class GrpcBigtableInstanceAdminStub extends BigtableInstanceAdminStub {
ProtoUtils.marshaller(ListHotTabletsResponse.getDefaultInstance()))
.build();
+ private static final MethodDescriptor
+ createLogicalViewMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName("google.bigtable.admin.v2.BigtableInstanceAdmin/CreateLogicalView")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(CreateLogicalViewRequest.getDefaultInstance()))
+ .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance()))
+ .build();
+
+ private static final MethodDescriptor
+ getLogicalViewMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName("google.bigtable.admin.v2.BigtableInstanceAdmin/GetLogicalView")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(GetLogicalViewRequest.getDefaultInstance()))
+ .setResponseMarshaller(ProtoUtils.marshaller(LogicalView.getDefaultInstance()))
+ .build();
+
+ private static final MethodDescriptor
+ listLogicalViewsMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName("google.bigtable.admin.v2.BigtableInstanceAdmin/ListLogicalViews")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(ListLogicalViewsRequest.getDefaultInstance()))
+ .setResponseMarshaller(
+ ProtoUtils.marshaller(ListLogicalViewsResponse.getDefaultInstance()))
+ .build();
+
+ private static final MethodDescriptor
+ updateLogicalViewMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName("google.bigtable.admin.v2.BigtableInstanceAdmin/UpdateLogicalView")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(UpdateLogicalViewRequest.getDefaultInstance()))
+ .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance()))
+ .build();
+
+ private static final MethodDescriptor
+ deleteLogicalViewMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName("google.bigtable.admin.v2.BigtableInstanceAdmin/DeleteLogicalView")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(DeleteLogicalViewRequest.getDefaultInstance()))
+ .setResponseMarshaller(ProtoUtils.marshaller(Empty.getDefaultInstance()))
+ .build();
+
+ private static final MethodDescriptor
+ createMaterializedViewMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(
+ "google.bigtable.admin.v2.BigtableInstanceAdmin/CreateMaterializedView")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(CreateMaterializedViewRequest.getDefaultInstance()))
+ .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance()))
+ .build();
+
+ private static final MethodDescriptor
+ getMaterializedViewMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(
+ "google.bigtable.admin.v2.BigtableInstanceAdmin/GetMaterializedView")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(GetMaterializedViewRequest.getDefaultInstance()))
+ .setResponseMarshaller(ProtoUtils.marshaller(MaterializedView.getDefaultInstance()))
+ .build();
+
+ private static final MethodDescriptor
+ listMaterializedViewsMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(
+ "google.bigtable.admin.v2.BigtableInstanceAdmin/ListMaterializedViews")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(ListMaterializedViewsRequest.getDefaultInstance()))
+ .setResponseMarshaller(
+ ProtoUtils.marshaller(ListMaterializedViewsResponse.getDefaultInstance()))
+ .build();
+
+ private static final MethodDescriptor
+ updateMaterializedViewMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(
+ "google.bigtable.admin.v2.BigtableInstanceAdmin/UpdateMaterializedView")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(UpdateMaterializedViewRequest.getDefaultInstance()))
+ .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance()))
+ .build();
+
+ private static final MethodDescriptor
+ deleteMaterializedViewMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(
+ "google.bigtable.admin.v2.BigtableInstanceAdmin/DeleteMaterializedView")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(DeleteMaterializedViewRequest.getDefaultInstance()))
+ .setResponseMarshaller(ProtoUtils.marshaller(Empty.getDefaultInstance()))
+ .build();
+
private final UnaryCallable createInstanceCallable;
private final OperationCallable
createInstanceOperationCallable;
@@ -320,6 +447,35 @@ public class GrpcBigtableInstanceAdminStub extends BigtableInstanceAdminStub {
private final UnaryCallable listHotTabletsCallable;
private final UnaryCallable
listHotTabletsPagedCallable;
+ private final UnaryCallable createLogicalViewCallable;
+ private final OperationCallable
+ createLogicalViewOperationCallable;
+ private final UnaryCallable getLogicalViewCallable;
+ private final UnaryCallable
+ listLogicalViewsCallable;
+ private final UnaryCallable
+ listLogicalViewsPagedCallable;
+ private final UnaryCallable updateLogicalViewCallable;
+ private final OperationCallable
+ updateLogicalViewOperationCallable;
+ private final UnaryCallable deleteLogicalViewCallable;
+ private final UnaryCallable
+ createMaterializedViewCallable;
+ private final OperationCallable<
+ CreateMaterializedViewRequest, MaterializedView, CreateMaterializedViewMetadata>
+ createMaterializedViewOperationCallable;
+ private final UnaryCallable
+ getMaterializedViewCallable;
+ private final UnaryCallable
+ listMaterializedViewsCallable;
+ private final UnaryCallable
+ listMaterializedViewsPagedCallable;
+ private final UnaryCallable
+ updateMaterializedViewCallable;
+ private final OperationCallable<
+ UpdateMaterializedViewRequest, MaterializedView, UpdateMaterializedViewMetadata>
+ updateMaterializedViewOperationCallable;
+ private final UnaryCallable deleteMaterializedViewCallable;
private final BackgroundResource backgroundResources;
private final GrpcOperationsStub operationsStub;
@@ -580,6 +736,115 @@ protected GrpcBigtableInstanceAdminStub(
return builder.build();
})
.build();
+ GrpcCallSettings createLogicalViewTransportSettings =
+ GrpcCallSettings.newBuilder()
+ .setMethodDescriptor(createLogicalViewMethodDescriptor)
+ .setParamsExtractor(
+ request -> {
+ RequestParamsBuilder builder = RequestParamsBuilder.create();
+ builder.add("parent", String.valueOf(request.getParent()));
+ return builder.build();
+ })
+ .build();
+ GrpcCallSettings getLogicalViewTransportSettings =
+ GrpcCallSettings.newBuilder()
+ .setMethodDescriptor(getLogicalViewMethodDescriptor)
+ .setParamsExtractor(
+ request -> {
+ RequestParamsBuilder builder = RequestParamsBuilder.create();
+ builder.add("name", String.valueOf(request.getName()));
+ return builder.build();
+ })
+ .build();
+ GrpcCallSettings
+ listLogicalViewsTransportSettings =
+ GrpcCallSettings.newBuilder()
+ .setMethodDescriptor(listLogicalViewsMethodDescriptor)
+ .setParamsExtractor(
+ request -> {
+ RequestParamsBuilder builder = RequestParamsBuilder.create();
+ builder.add("parent", String.valueOf(request.getParent()));
+ return builder.build();
+ })
+ .build();
+ GrpcCallSettings updateLogicalViewTransportSettings =
+ GrpcCallSettings.newBuilder()
+ .setMethodDescriptor(updateLogicalViewMethodDescriptor)
+ .setParamsExtractor(
+ request -> {
+ RequestParamsBuilder builder = RequestParamsBuilder.create();
+ builder.add(
+ "logical_view.name", String.valueOf(request.getLogicalView().getName()));
+ return builder.build();
+ })
+ .build();
+ GrpcCallSettings deleteLogicalViewTransportSettings =
+ GrpcCallSettings.newBuilder()
+ .setMethodDescriptor(deleteLogicalViewMethodDescriptor)
+ .setParamsExtractor(
+ request -> {
+ RequestParamsBuilder builder = RequestParamsBuilder.create();
+ builder.add("name", String.valueOf(request.getName()));
+ return builder.build();
+ })
+ .build();
+ GrpcCallSettings
+ createMaterializedViewTransportSettings =
+ GrpcCallSettings.newBuilder()
+ .setMethodDescriptor(createMaterializedViewMethodDescriptor)
+ .setParamsExtractor(
+ request -> {
+ RequestParamsBuilder builder = RequestParamsBuilder.create();
+ builder.add("parent", String.valueOf(request.getParent()));
+ return builder.build();
+ })
+ .build();
+ GrpcCallSettings
+ getMaterializedViewTransportSettings =
+ GrpcCallSettings.newBuilder()
+ .setMethodDescriptor(getMaterializedViewMethodDescriptor)
+ .setParamsExtractor(
+ request -> {
+ RequestParamsBuilder builder = RequestParamsBuilder.create();
+ builder.add("name", String.valueOf(request.getName()));
+ return builder.build();
+ })
+ .build();
+ GrpcCallSettings
+ listMaterializedViewsTransportSettings =
+ GrpcCallSettings
+ .newBuilder()
+ .setMethodDescriptor(listMaterializedViewsMethodDescriptor)
+ .setParamsExtractor(
+ request -> {
+ RequestParamsBuilder builder = RequestParamsBuilder.create();
+ builder.add("parent", String.valueOf(request.getParent()));
+ return builder.build();
+ })
+ .build();
+ GrpcCallSettings
+ updateMaterializedViewTransportSettings =
+ GrpcCallSettings.newBuilder()
+ .setMethodDescriptor(updateMaterializedViewMethodDescriptor)
+ .setParamsExtractor(
+ request -> {
+ RequestParamsBuilder builder = RequestParamsBuilder.create();
+ builder.add(
+ "materialized_view.name",
+ String.valueOf(request.getMaterializedView().getName()));
+ return builder.build();
+ })
+ .build();
+ GrpcCallSettings deleteMaterializedViewTransportSettings =
+ GrpcCallSettings.newBuilder()
+ .setMethodDescriptor(deleteMaterializedViewMethodDescriptor)
+ .setParamsExtractor(
+ request -> {
+ RequestParamsBuilder builder = RequestParamsBuilder.create();
+ builder.add("name", String.valueOf(request.getName()));
+ return builder.build();
+ })
+ .build();
this.createInstanceCallable =
callableFactory.createUnaryCallable(
@@ -692,6 +957,84 @@ protected GrpcBigtableInstanceAdminStub(
this.listHotTabletsPagedCallable =
callableFactory.createPagedCallable(
listHotTabletsTransportSettings, settings.listHotTabletsSettings(), clientContext);
+ this.createLogicalViewCallable =
+ callableFactory.createUnaryCallable(
+ createLogicalViewTransportSettings,
+ settings.createLogicalViewSettings(),
+ clientContext);
+ this.createLogicalViewOperationCallable =
+ callableFactory.createOperationCallable(
+ createLogicalViewTransportSettings,
+ settings.createLogicalViewOperationSettings(),
+ clientContext,
+ operationsStub);
+ this.getLogicalViewCallable =
+ callableFactory.createUnaryCallable(
+ getLogicalViewTransportSettings, settings.getLogicalViewSettings(), clientContext);
+ this.listLogicalViewsCallable =
+ callableFactory.createUnaryCallable(
+ listLogicalViewsTransportSettings, settings.listLogicalViewsSettings(), clientContext);
+ this.listLogicalViewsPagedCallable =
+ callableFactory.createPagedCallable(
+ listLogicalViewsTransportSettings, settings.listLogicalViewsSettings(), clientContext);
+ this.updateLogicalViewCallable =
+ callableFactory.createUnaryCallable(
+ updateLogicalViewTransportSettings,
+ settings.updateLogicalViewSettings(),
+ clientContext);
+ this.updateLogicalViewOperationCallable =
+ callableFactory.createOperationCallable(
+ updateLogicalViewTransportSettings,
+ settings.updateLogicalViewOperationSettings(),
+ clientContext,
+ operationsStub);
+ this.deleteLogicalViewCallable =
+ callableFactory.createUnaryCallable(
+ deleteLogicalViewTransportSettings,
+ settings.deleteLogicalViewSettings(),
+ clientContext);
+ this.createMaterializedViewCallable =
+ callableFactory.createUnaryCallable(
+ createMaterializedViewTransportSettings,
+ settings.createMaterializedViewSettings(),
+ clientContext);
+ this.createMaterializedViewOperationCallable =
+ callableFactory.createOperationCallable(
+ createMaterializedViewTransportSettings,
+ settings.createMaterializedViewOperationSettings(),
+ clientContext,
+ operationsStub);
+ this.getMaterializedViewCallable =
+ callableFactory.createUnaryCallable(
+ getMaterializedViewTransportSettings,
+ settings.getMaterializedViewSettings(),
+ clientContext);
+ this.listMaterializedViewsCallable =
+ callableFactory.createUnaryCallable(
+ listMaterializedViewsTransportSettings,
+ settings.listMaterializedViewsSettings(),
+ clientContext);
+ this.listMaterializedViewsPagedCallable =
+ callableFactory.createPagedCallable(
+ listMaterializedViewsTransportSettings,
+ settings.listMaterializedViewsSettings(),
+ clientContext);
+ this.updateMaterializedViewCallable =
+ callableFactory.createUnaryCallable(
+ updateMaterializedViewTransportSettings,
+ settings.updateMaterializedViewSettings(),
+ clientContext);
+ this.updateMaterializedViewOperationCallable =
+ callableFactory.createOperationCallable(
+ updateMaterializedViewTransportSettings,
+ settings.updateMaterializedViewOperationSettings(),
+ clientContext,
+ operationsStub);
+ this.deleteMaterializedViewCallable =
+ callableFactory.createUnaryCallable(
+ deleteMaterializedViewTransportSettings,
+ settings.deleteMaterializedViewSettings(),
+ clientContext);
this.backgroundResources =
new BackgroundResourceAggregation(clientContext.getBackgroundResources());
@@ -855,6 +1198,96 @@ public UnaryCallable listHotTable
return listHotTabletsPagedCallable;
}
+ @Override
+ public UnaryCallable createLogicalViewCallable() {
+ return createLogicalViewCallable;
+ }
+
+ @Override
+ public OperationCallable
+ createLogicalViewOperationCallable() {
+ return createLogicalViewOperationCallable;
+ }
+
+ @Override
+ public UnaryCallable getLogicalViewCallable() {
+ return getLogicalViewCallable;
+ }
+
+ @Override
+ public UnaryCallable
+ listLogicalViewsCallable() {
+ return listLogicalViewsCallable;
+ }
+
+ @Override
+ public UnaryCallable
+ listLogicalViewsPagedCallable() {
+ return listLogicalViewsPagedCallable;
+ }
+
+ @Override
+ public UnaryCallable updateLogicalViewCallable() {
+ return updateLogicalViewCallable;
+ }
+
+ @Override
+ public OperationCallable
+ updateLogicalViewOperationCallable() {
+ return updateLogicalViewOperationCallable;
+ }
+
+ @Override
+ public UnaryCallable deleteLogicalViewCallable() {
+ return deleteLogicalViewCallable;
+ }
+
+ @Override
+ public UnaryCallable createMaterializedViewCallable() {
+ return createMaterializedViewCallable;
+ }
+
+ @Override
+ public OperationCallable<
+ CreateMaterializedViewRequest, MaterializedView, CreateMaterializedViewMetadata>
+ createMaterializedViewOperationCallable() {
+ return createMaterializedViewOperationCallable;
+ }
+
+ @Override
+ public UnaryCallable getMaterializedViewCallable() {
+ return getMaterializedViewCallable;
+ }
+
+ @Override
+ public UnaryCallable
+ listMaterializedViewsCallable() {
+ return listMaterializedViewsCallable;
+ }
+
+ @Override
+ public UnaryCallable
+ listMaterializedViewsPagedCallable() {
+ return listMaterializedViewsPagedCallable;
+ }
+
+ @Override
+ public UnaryCallable updateMaterializedViewCallable() {
+ return updateMaterializedViewCallable;
+ }
+
+ @Override
+ public OperationCallable<
+ UpdateMaterializedViewRequest, MaterializedView, UpdateMaterializedViewMetadata>
+ updateMaterializedViewOperationCallable() {
+ return updateMaterializedViewOperationCallable;
+ }
+
+ @Override
+ public UnaryCallable deleteMaterializedViewCallable() {
+ return deleteMaterializedViewCallable;
+ }
+
@Override
public final void close() {
try {
diff --git a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/gapic_metadata.json b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/gapic_metadata.json
index 1134631db20a..5bc262fb5c9d 100644
--- a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/gapic_metadata.json
+++ b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/gapic_metadata.json
@@ -28,6 +28,9 @@
"PingAndWarm": {
"methods": ["pingAndWarm", "pingAndWarm", "pingAndWarm", "pingAndWarm", "pingAndWarm", "pingAndWarmCallable"]
},
+ "PrepareQuery": {
+ "methods": ["prepareQuery", "prepareQuery", "prepareQuery", "prepareQuery", "prepareQuery", "prepareQueryCallable"]
+ },
"ReadChangeStream": {
"methods": ["readChangeStreamCallable"]
},
diff --git a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/BigtableStub.java b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/BigtableStub.java
index e9df27b43ae3..bd97b79d3711 100644
--- a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/BigtableStub.java
+++ b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/BigtableStub.java
@@ -32,6 +32,8 @@
import com.google.bigtable.v2.MutateRowsResponse;
import com.google.bigtable.v2.PingAndWarmRequest;
import com.google.bigtable.v2.PingAndWarmResponse;
+import com.google.bigtable.v2.PrepareQueryRequest;
+import com.google.bigtable.v2.PrepareQueryResponse;
import com.google.bigtable.v2.ReadChangeStreamRequest;
import com.google.bigtable.v2.ReadChangeStreamResponse;
import com.google.bigtable.v2.ReadModifyWriteRowRequest;
@@ -92,6 +94,10 @@ public UnaryCallable pingAndWarmCallabl
throw new UnsupportedOperationException("Not implemented: readChangeStreamCallable()");
}
+ public UnaryCallable prepareQueryCallable() {
+ throw new UnsupportedOperationException("Not implemented: prepareQueryCallable()");
+ }
+
public ServerStreamingCallable executeQueryCallable() {
throw new UnsupportedOperationException("Not implemented: executeQueryCallable()");
}
diff --git a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/BigtableStubSettings.java b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/BigtableStubSettings.java
index ce408a1b3149..8ac3f4118524 100644
--- a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/BigtableStubSettings.java
+++ b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/BigtableStubSettings.java
@@ -45,6 +45,8 @@
import com.google.bigtable.v2.MutateRowsResponse;
import com.google.bigtable.v2.PingAndWarmRequest;
import com.google.bigtable.v2.PingAndWarmResponse;
+import com.google.bigtable.v2.PrepareQueryRequest;
+import com.google.bigtable.v2.PrepareQueryResponse;
import com.google.bigtable.v2.ReadChangeStreamRequest;
import com.google.bigtable.v2.ReadChangeStreamResponse;
import com.google.bigtable.v2.ReadModifyWriteRowRequest;
@@ -95,6 +97,7 @@ public class BigtableStubSettings extends StubSettings {
generateInitialChangeStreamPartitionsSettings;
private final ServerStreamingCallSettings
readChangeStreamSettings;
+ private final UnaryCallSettings prepareQuerySettings;
private final ServerStreamingCallSettings
executeQuerySettings;
@@ -152,6 +155,11 @@ public UnaryCallSettings pingAndWarmSet
return readChangeStreamSettings;
}
+ /** Returns the object with the settings used for calls to prepareQuery. */
+ public UnaryCallSettings prepareQuerySettings() {
+ return prepareQuerySettings;
+ }
+
/** Returns the object with the settings used for calls to executeQuery. */
public ServerStreamingCallSettings
executeQuerySettings() {
@@ -248,6 +256,7 @@ protected BigtableStubSettings(Builder settingsBuilder) throws IOException {
generateInitialChangeStreamPartitionsSettings =
settingsBuilder.generateInitialChangeStreamPartitionsSettings().build();
readChangeStreamSettings = settingsBuilder.readChangeStreamSettings().build();
+ prepareQuerySettings = settingsBuilder.prepareQuerySettings().build();
executeQuerySettings = settingsBuilder.executeQuerySettings().build();
}
@@ -274,6 +283,8 @@ public static class Builder extends StubSettings.Builder
readChangeStreamSettings;
+ private final UnaryCallSettings.Builder
+ prepareQuerySettings;
private final ServerStreamingCallSettings.Builder
executeQuerySettings;
private static final ImmutableMap>
@@ -404,6 +415,7 @@ protected Builder(ClientContext clientContext) {
readModifyWriteRowSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
generateInitialChangeStreamPartitionsSettings = ServerStreamingCallSettings.newBuilder();
readChangeStreamSettings = ServerStreamingCallSettings.newBuilder();
+ prepareQuerySettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
executeQuerySettings = ServerStreamingCallSettings.newBuilder();
unaryMethodSettingsBuilders =
@@ -411,7 +423,8 @@ protected Builder(ClientContext clientContext) {
mutateRowSettings,
checkAndMutateRowSettings,
pingAndWarmSettings,
- readModifyWriteRowSettings);
+ readModifyWriteRowSettings,
+ prepareQuerySettings);
initDefaults(this);
}
@@ -428,6 +441,7 @@ protected Builder(BigtableStubSettings settings) {
generateInitialChangeStreamPartitionsSettings =
settings.generateInitialChangeStreamPartitionsSettings.toBuilder();
readChangeStreamSettings = settings.readChangeStreamSettings.toBuilder();
+ prepareQuerySettings = settings.prepareQuerySettings.toBuilder();
executeQuerySettings = settings.executeQuerySettings.toBuilder();
unaryMethodSettingsBuilders =
@@ -435,7 +449,8 @@ protected Builder(BigtableStubSettings settings) {
mutateRowSettings,
checkAndMutateRowSettings,
pingAndWarmSettings,
- readModifyWriteRowSettings);
+ readModifyWriteRowSettings,
+ prepareQuerySettings);
}
private static Builder createDefault() {
@@ -496,6 +511,11 @@ private static Builder initDefaults(Builder builder) {
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_7_codes"))
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_7_params"));
+ builder
+ .prepareQuerySettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
+
builder
.executeQuerySettings()
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_4_codes"))
@@ -576,6 +596,12 @@ public UnaryCallSettings.Builder mutateRowS
return readChangeStreamSettings;
}
+ /** Returns the builder for the settings used for calls to prepareQuery. */
+ public UnaryCallSettings.Builder
+ prepareQuerySettings() {
+ return prepareQuerySettings;
+ }
+
/** Returns the builder for the settings used for calls to executeQuery. */
public ServerStreamingCallSettings.Builder
executeQuerySettings() {
diff --git a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/GrpcBigtableStub.java b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/GrpcBigtableStub.java
index cf215b4582a3..fc37c0c49c43 100644
--- a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/GrpcBigtableStub.java
+++ b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/GrpcBigtableStub.java
@@ -38,6 +38,8 @@
import com.google.bigtable.v2.MutateRowsResponse;
import com.google.bigtable.v2.PingAndWarmRequest;
import com.google.bigtable.v2.PingAndWarmResponse;
+import com.google.bigtable.v2.PrepareQueryRequest;
+import com.google.bigtable.v2.PrepareQueryResponse;
import com.google.bigtable.v2.ReadChangeStreamRequest;
import com.google.bigtable.v2.ReadChangeStreamResponse;
import com.google.bigtable.v2.ReadModifyWriteRowRequest;
@@ -158,6 +160,16 @@ public class GrpcBigtableStub extends BigtableStub {
ProtoUtils.marshaller(ReadChangeStreamResponse.getDefaultInstance()))
.build();
+ private static final MethodDescriptor
+ prepareQueryMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName("google.bigtable.v2.Bigtable/PrepareQuery")
+ .setRequestMarshaller(ProtoUtils.marshaller(PrepareQueryRequest.getDefaultInstance()))
+ .setResponseMarshaller(
+ ProtoUtils.marshaller(PrepareQueryResponse.getDefaultInstance()))
+ .build();
+
private static final MethodDescriptor
executeQueryMethodDescriptor =
MethodDescriptor.newBuilder()
@@ -184,6 +196,7 @@ public class GrpcBigtableStub extends BigtableStub {
generateInitialChangeStreamPartitionsCallable;
private final ServerStreamingCallable
readChangeStreamCallable;
+ private final UnaryCallable prepareQueryCallable;
private final ServerStreamingCallable
executeQueryCallable;
@@ -237,6 +250,10 @@ public class GrpcBigtableStub extends BigtableStub {
private static final PathTemplate READ_MODIFY_WRITE_ROW_2_PATH_TEMPLATE =
PathTemplate.create(
"{authorized_view_name=projects/*/instances/*/tables/*/authorizedViews/*}");
+ private static final PathTemplate PREPARE_QUERY_0_PATH_TEMPLATE =
+ PathTemplate.create("{name=projects/*/instances/*}");
+ private static final PathTemplate PREPARE_QUERY_1_PATH_TEMPLATE =
+ PathTemplate.create("{app_profile_id=**}");
private static final PathTemplate EXECUTE_QUERY_0_PATH_TEMPLATE =
PathTemplate.create("{name=projects/*/instances/*}");
private static final PathTemplate EXECUTE_QUERY_1_PATH_TEMPLATE =
@@ -425,6 +442,18 @@ protected GrpcBigtableStub(
return builder.build();
})
.build();
+ GrpcCallSettings prepareQueryTransportSettings =
+ GrpcCallSettings.newBuilder()
+ .setMethodDescriptor(prepareQueryMethodDescriptor)
+ .setParamsExtractor(
+ request -> {
+ RequestParamsBuilder builder = RequestParamsBuilder.create();
+ builder.add(request.getInstanceName(), "name", PREPARE_QUERY_0_PATH_TEMPLATE);
+ builder.add(
+ request.getAppProfileId(), "app_profile_id", PREPARE_QUERY_1_PATH_TEMPLATE);
+ return builder.build();
+ })
+ .build();
GrpcCallSettings executeQueryTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(executeQueryMethodDescriptor)
@@ -471,6 +500,9 @@ protected GrpcBigtableStub(
this.readChangeStreamCallable =
callableFactory.createServerStreamingCallable(
readChangeStreamTransportSettings, settings.readChangeStreamSettings(), clientContext);
+ this.prepareQueryCallable =
+ callableFactory.createUnaryCallable(
+ prepareQueryTransportSettings, settings.prepareQuerySettings(), clientContext);
this.executeQueryCallable =
callableFactory.createServerStreamingCallable(
executeQueryTransportSettings, settings.executeQuerySettings(), clientContext);
@@ -535,6 +567,11 @@ public UnaryCallable pingAndWarmCallabl
return readChangeStreamCallable;
}
+ @Override
+ public UnaryCallable prepareQueryCallable() {
+ return prepareQueryCallable;
+ }
+
@Override
public ServerStreamingCallable executeQueryCallable() {
return executeQueryCallable;
diff --git a/google-cloud-bigtable/src/main/resources/META-INF/native-image/com.google.cloud.bigtable.admin.v2/reflect-config.json b/google-cloud-bigtable/src/main/resources/META-INF/native-image/com.google.cloud.bigtable.admin.v2/reflect-config.json
index baae18a33747..e94385446d80 100644
--- a/google-cloud-bigtable/src/main/resources/META-INF/native-image/com.google.cloud.bigtable.admin.v2/reflect-config.json
+++ b/google-cloud-bigtable/src/main/resources/META-INF/native-image/com.google.cloud.bigtable.admin.v2/reflect-config.json
@@ -1331,6 +1331,42 @@
"allDeclaredClasses": true,
"allPublicClasses": true
},
+ {
+ "name": "com.google.bigtable.admin.v2.DeleteLogicalViewRequest",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.bigtable.admin.v2.DeleteLogicalViewRequest$Builder",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.bigtable.admin.v2.DeleteMaterializedViewRequest",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.bigtable.admin.v2.DeleteMaterializedViewRequest$Builder",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
{
"name": "com.google.bigtable.admin.v2.DeleteSnapshotRequest",
"queryAllDeclaredConstructors": true,
@@ -1592,6 +1628,42 @@
"allDeclaredClasses": true,
"allPublicClasses": true
},
+ {
+ "name": "com.google.bigtable.admin.v2.GetLogicalViewRequest",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.bigtable.admin.v2.GetLogicalViewRequest$Builder",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.bigtable.admin.v2.GetMaterializedViewRequest",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.bigtable.admin.v2.GetMaterializedViewRequest$Builder",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
{
"name": "com.google.bigtable.admin.v2.GetSnapshotRequest",
"queryAllDeclaredConstructors": true,
@@ -1898,6 +1970,78 @@
"allDeclaredClasses": true,
"allPublicClasses": true
},
+ {
+ "name": "com.google.bigtable.admin.v2.ListLogicalViewsRequest",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.bigtable.admin.v2.ListLogicalViewsRequest$Builder",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.bigtable.admin.v2.ListLogicalViewsResponse",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.bigtable.admin.v2.ListLogicalViewsResponse$Builder",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.bigtable.admin.v2.ListMaterializedViewsRequest",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.bigtable.admin.v2.ListMaterializedViewsRequest$Builder",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.bigtable.admin.v2.ListMaterializedViewsResponse",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.bigtable.admin.v2.ListMaterializedViewsResponse$Builder",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
{
"name": "com.google.bigtable.admin.v2.ListSnapshotsRequest",
"queryAllDeclaredConstructors": true,
@@ -3122,6 +3266,42 @@
"allDeclaredClasses": true,
"allPublicClasses": true
},
+ {
+ "name": "com.google.bigtable.admin.v2.UpdateMaterializedViewMetadata",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.bigtable.admin.v2.UpdateMaterializedViewMetadata$Builder",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.bigtable.admin.v2.UpdateMaterializedViewRequest",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.bigtable.admin.v2.UpdateMaterializedViewRequest$Builder",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
{
"name": "com.google.bigtable.admin.v2.UpdateTableMetadata",
"queryAllDeclaredConstructors": true,
diff --git a/google-cloud-bigtable/src/main/resources/META-INF/native-image/com.google.cloud.bigtable.data.v2/reflect-config.json b/google-cloud-bigtable/src/main/resources/META-INF/native-image/com.google.cloud.bigtable.data.v2/reflect-config.json
index 4b89db83f8e7..808e3272aaeb 100644
--- a/google-cloud-bigtable/src/main/resources/META-INF/native-image/com.google.cloud.bigtable.data.v2/reflect-config.json
+++ b/google-cloud-bigtable/src/main/resources/META-INF/native-image/com.google.cloud.bigtable.data.v2/reflect-config.json
@@ -989,6 +989,42 @@
"allDeclaredClasses": true,
"allPublicClasses": true
},
+ {
+ "name": "com.google.bigtable.v2.PrepareQueryRequest",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.bigtable.v2.PrepareQueryRequest$Builder",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.bigtable.v2.PrepareQueryResponse",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.bigtable.v2.PrepareQueryResponse$Builder",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
{
"name": "com.google.bigtable.v2.ProtoFormat",
"queryAllDeclaredConstructors": true,
diff --git a/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/admin/v2/BaseBigtableInstanceAdminClientTest.java b/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/admin/v2/BaseBigtableInstanceAdminClientTest.java
index d603431b3662..2f54d670b99d 100644
--- a/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/admin/v2/BaseBigtableInstanceAdminClientTest.java
+++ b/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/admin/v2/BaseBigtableInstanceAdminClientTest.java
@@ -18,6 +18,8 @@
import static com.google.cloud.bigtable.admin.v2.BaseBigtableInstanceAdminClient.ListAppProfilesPagedResponse;
import static com.google.cloud.bigtable.admin.v2.BaseBigtableInstanceAdminClient.ListHotTabletsPagedResponse;
+import static com.google.cloud.bigtable.admin.v2.BaseBigtableInstanceAdminClient.ListLogicalViewsPagedResponse;
+import static com.google.cloud.bigtable.admin.v2.BaseBigtableInstanceAdminClient.ListMaterializedViewsPagedResponse;
import com.google.api.gax.core.NoCredentialsProvider;
import com.google.api.gax.grpc.GaxGrpcProperties;
@@ -35,12 +37,18 @@
import com.google.bigtable.admin.v2.CreateAppProfileRequest;
import com.google.bigtable.admin.v2.CreateClusterRequest;
import com.google.bigtable.admin.v2.CreateInstanceRequest;
+import com.google.bigtable.admin.v2.CreateLogicalViewRequest;
+import com.google.bigtable.admin.v2.CreateMaterializedViewRequest;
import com.google.bigtable.admin.v2.DeleteAppProfileRequest;
import com.google.bigtable.admin.v2.DeleteClusterRequest;
import com.google.bigtable.admin.v2.DeleteInstanceRequest;
+import com.google.bigtable.admin.v2.DeleteLogicalViewRequest;
+import com.google.bigtable.admin.v2.DeleteMaterializedViewRequest;
import com.google.bigtable.admin.v2.GetAppProfileRequest;
import com.google.bigtable.admin.v2.GetClusterRequest;
import com.google.bigtable.admin.v2.GetInstanceRequest;
+import com.google.bigtable.admin.v2.GetLogicalViewRequest;
+import com.google.bigtable.admin.v2.GetMaterializedViewRequest;
import com.google.bigtable.admin.v2.HotTablet;
import com.google.bigtable.admin.v2.Instance;
import com.google.bigtable.admin.v2.InstanceName;
@@ -52,12 +60,22 @@
import com.google.bigtable.admin.v2.ListHotTabletsResponse;
import com.google.bigtable.admin.v2.ListInstancesRequest;
import com.google.bigtable.admin.v2.ListInstancesResponse;
+import com.google.bigtable.admin.v2.ListLogicalViewsRequest;
+import com.google.bigtable.admin.v2.ListLogicalViewsResponse;
+import com.google.bigtable.admin.v2.ListMaterializedViewsRequest;
+import com.google.bigtable.admin.v2.ListMaterializedViewsResponse;
import com.google.bigtable.admin.v2.LocationName;
+import com.google.bigtable.admin.v2.LogicalView;
+import com.google.bigtable.admin.v2.LogicalViewName;
+import com.google.bigtable.admin.v2.MaterializedView;
+import com.google.bigtable.admin.v2.MaterializedViewName;
import com.google.bigtable.admin.v2.PartialUpdateClusterRequest;
import com.google.bigtable.admin.v2.PartialUpdateInstanceRequest;
import com.google.bigtable.admin.v2.ProjectName;
import com.google.bigtable.admin.v2.StorageType;
import com.google.bigtable.admin.v2.UpdateAppProfileRequest;
+import com.google.bigtable.admin.v2.UpdateLogicalViewRequest;
+import com.google.bigtable.admin.v2.UpdateMaterializedViewRequest;
import com.google.common.collect.Lists;
import com.google.iam.v1.AuditConfig;
import com.google.iam.v1.Binding;
@@ -1863,4 +1881,825 @@ public void listHotTabletsExceptionTest2() throws Exception {
// Expected exception.
}
}
+
+ @Test
+ public void createLogicalViewTest() throws Exception {
+ LogicalView expectedResponse =
+ LogicalView.newBuilder()
+ .setName(LogicalViewName.of("[PROJECT]", "[INSTANCE]", "[LOGICAL_VIEW]").toString())
+ .setQuery("query107944136")
+ .setEtag("etag3123477")
+ .build();
+ Operation resultOperation =
+ Operation.newBuilder()
+ .setName("createLogicalViewTest")
+ .setDone(true)
+ .setResponse(Any.pack(expectedResponse))
+ .build();
+ mockBigtableInstanceAdmin.addResponse(resultOperation);
+
+ InstanceName parent = InstanceName.of("[PROJECT]", "[INSTANCE]");
+ LogicalView logicalView = LogicalView.newBuilder().build();
+ String logicalViewId = "logicalViewId-1408054263";
+
+ LogicalView actualResponse =
+ client.createLogicalViewAsync(parent, logicalView, logicalViewId).get();
+ Assert.assertEquals(expectedResponse, actualResponse);
+
+ List actualRequests = mockBigtableInstanceAdmin.getRequests();
+ Assert.assertEquals(1, actualRequests.size());
+ CreateLogicalViewRequest actualRequest = ((CreateLogicalViewRequest) actualRequests.get(0));
+
+ Assert.assertEquals(parent.toString(), actualRequest.getParent());
+ Assert.assertEquals(logicalView, actualRequest.getLogicalView());
+ Assert.assertEquals(logicalViewId, actualRequest.getLogicalViewId());
+ Assert.assertTrue(
+ channelProvider.isHeaderSent(
+ ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
+ GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
+ }
+
+ @Test
+ public void createLogicalViewExceptionTest() throws Exception {
+ StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
+ mockBigtableInstanceAdmin.addException(exception);
+
+ try {
+ InstanceName parent = InstanceName.of("[PROJECT]", "[INSTANCE]");
+ LogicalView logicalView = LogicalView.newBuilder().build();
+ String logicalViewId = "logicalViewId-1408054263";
+ client.createLogicalViewAsync(parent, logicalView, logicalViewId).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 createLogicalViewTest2() throws Exception {
+ LogicalView expectedResponse =
+ LogicalView.newBuilder()
+ .setName(LogicalViewName.of("[PROJECT]", "[INSTANCE]", "[LOGICAL_VIEW]").toString())
+ .setQuery("query107944136")
+ .setEtag("etag3123477")
+ .build();
+ Operation resultOperation =
+ Operation.newBuilder()
+ .setName("createLogicalViewTest")
+ .setDone(true)
+ .setResponse(Any.pack(expectedResponse))
+ .build();
+ mockBigtableInstanceAdmin.addResponse(resultOperation);
+
+ String parent = "parent-995424086";
+ LogicalView logicalView = LogicalView.newBuilder().build();
+ String logicalViewId = "logicalViewId-1408054263";
+
+ LogicalView actualResponse =
+ client.createLogicalViewAsync(parent, logicalView, logicalViewId).get();
+ Assert.assertEquals(expectedResponse, actualResponse);
+
+ List actualRequests = mockBigtableInstanceAdmin.getRequests();
+ Assert.assertEquals(1, actualRequests.size());
+ CreateLogicalViewRequest actualRequest = ((CreateLogicalViewRequest) actualRequests.get(0));
+
+ Assert.assertEquals(parent, actualRequest.getParent());
+ Assert.assertEquals(logicalView, actualRequest.getLogicalView());
+ Assert.assertEquals(logicalViewId, actualRequest.getLogicalViewId());
+ Assert.assertTrue(
+ channelProvider.isHeaderSent(
+ ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
+ GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
+ }
+
+ @Test
+ public void createLogicalViewExceptionTest2() throws Exception {
+ StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
+ mockBigtableInstanceAdmin.addException(exception);
+
+ try {
+ String parent = "parent-995424086";
+ LogicalView logicalView = LogicalView.newBuilder().build();
+ String logicalViewId = "logicalViewId-1408054263";
+ client.createLogicalViewAsync(parent, logicalView, logicalViewId).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 getLogicalViewTest() throws Exception {
+ LogicalView expectedResponse =
+ LogicalView.newBuilder()
+ .setName(LogicalViewName.of("[PROJECT]", "[INSTANCE]", "[LOGICAL_VIEW]").toString())
+ .setQuery("query107944136")
+ .setEtag("etag3123477")
+ .build();
+ mockBigtableInstanceAdmin.addResponse(expectedResponse);
+
+ LogicalViewName name = LogicalViewName.of("[PROJECT]", "[INSTANCE]", "[LOGICAL_VIEW]");
+
+ LogicalView actualResponse = client.getLogicalView(name);
+ Assert.assertEquals(expectedResponse, actualResponse);
+
+ List actualRequests = mockBigtableInstanceAdmin.getRequests();
+ Assert.assertEquals(1, actualRequests.size());
+ GetLogicalViewRequest actualRequest = ((GetLogicalViewRequest) actualRequests.get(0));
+
+ Assert.assertEquals(name.toString(), actualRequest.getName());
+ Assert.assertTrue(
+ channelProvider.isHeaderSent(
+ ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
+ GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
+ }
+
+ @Test
+ public void getLogicalViewExceptionTest() throws Exception {
+ StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
+ mockBigtableInstanceAdmin.addException(exception);
+
+ try {
+ LogicalViewName name = LogicalViewName.of("[PROJECT]", "[INSTANCE]", "[LOGICAL_VIEW]");
+ client.getLogicalView(name);
+ Assert.fail("No exception raised");
+ } catch (InvalidArgumentException e) {
+ // Expected exception.
+ }
+ }
+
+ @Test
+ public void getLogicalViewTest2() throws Exception {
+ LogicalView expectedResponse =
+ LogicalView.newBuilder()
+ .setName(LogicalViewName.of("[PROJECT]", "[INSTANCE]", "[LOGICAL_VIEW]").toString())
+ .setQuery("query107944136")
+ .setEtag("etag3123477")
+ .build();
+ mockBigtableInstanceAdmin.addResponse(expectedResponse);
+
+ String name = "name3373707";
+
+ LogicalView actualResponse = client.getLogicalView(name);
+ Assert.assertEquals(expectedResponse, actualResponse);
+
+ List actualRequests = mockBigtableInstanceAdmin.getRequests();
+ Assert.assertEquals(1, actualRequests.size());
+ GetLogicalViewRequest actualRequest = ((GetLogicalViewRequest) actualRequests.get(0));
+
+ Assert.assertEquals(name, actualRequest.getName());
+ Assert.assertTrue(
+ channelProvider.isHeaderSent(
+ ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
+ GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
+ }
+
+ @Test
+ public void getLogicalViewExceptionTest2() throws Exception {
+ StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
+ mockBigtableInstanceAdmin.addException(exception);
+
+ try {
+ String name = "name3373707";
+ client.getLogicalView(name);
+ Assert.fail("No exception raised");
+ } catch (InvalidArgumentException e) {
+ // Expected exception.
+ }
+ }
+
+ @Test
+ public void listLogicalViewsTest() throws Exception {
+ LogicalView responsesElement = LogicalView.newBuilder().build();
+ ListLogicalViewsResponse expectedResponse =
+ ListLogicalViewsResponse.newBuilder()
+ .setNextPageToken("")
+ .addAllLogicalViews(Arrays.asList(responsesElement))
+ .build();
+ mockBigtableInstanceAdmin.addResponse(expectedResponse);
+
+ InstanceName parent = InstanceName.of("[PROJECT]", "[INSTANCE]");
+
+ ListLogicalViewsPagedResponse pagedListResponse = client.listLogicalViews(parent);
+
+ List resources = Lists.newArrayList(pagedListResponse.iterateAll());
+
+ Assert.assertEquals(1, resources.size());
+ Assert.assertEquals(expectedResponse.getLogicalViewsList().get(0), resources.get(0));
+
+ List actualRequests = mockBigtableInstanceAdmin.getRequests();
+ Assert.assertEquals(1, actualRequests.size());
+ ListLogicalViewsRequest actualRequest = ((ListLogicalViewsRequest) actualRequests.get(0));
+
+ Assert.assertEquals(parent.toString(), actualRequest.getParent());
+ Assert.assertTrue(
+ channelProvider.isHeaderSent(
+ ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
+ GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
+ }
+
+ @Test
+ public void listLogicalViewsExceptionTest() throws Exception {
+ StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
+ mockBigtableInstanceAdmin.addException(exception);
+
+ try {
+ InstanceName parent = InstanceName.of("[PROJECT]", "[INSTANCE]");
+ client.listLogicalViews(parent);
+ Assert.fail("No exception raised");
+ } catch (InvalidArgumentException e) {
+ // Expected exception.
+ }
+ }
+
+ @Test
+ public void listLogicalViewsTest2() throws Exception {
+ LogicalView responsesElement = LogicalView.newBuilder().build();
+ ListLogicalViewsResponse expectedResponse =
+ ListLogicalViewsResponse.newBuilder()
+ .setNextPageToken("")
+ .addAllLogicalViews(Arrays.asList(responsesElement))
+ .build();
+ mockBigtableInstanceAdmin.addResponse(expectedResponse);
+
+ String parent = "parent-995424086";
+
+ ListLogicalViewsPagedResponse pagedListResponse = client.listLogicalViews(parent);
+
+ List resources = Lists.newArrayList(pagedListResponse.iterateAll());
+
+ Assert.assertEquals(1, resources.size());
+ Assert.assertEquals(expectedResponse.getLogicalViewsList().get(0), resources.get(0));
+
+ List actualRequests = mockBigtableInstanceAdmin.getRequests();
+ Assert.assertEquals(1, actualRequests.size());
+ ListLogicalViewsRequest actualRequest = ((ListLogicalViewsRequest) actualRequests.get(0));
+
+ Assert.assertEquals(parent, actualRequest.getParent());
+ Assert.assertTrue(
+ channelProvider.isHeaderSent(
+ ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
+ GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
+ }
+
+ @Test
+ public void listLogicalViewsExceptionTest2() throws Exception {
+ StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
+ mockBigtableInstanceAdmin.addException(exception);
+
+ try {
+ String parent = "parent-995424086";
+ client.listLogicalViews(parent);
+ Assert.fail("No exception raised");
+ } catch (InvalidArgumentException e) {
+ // Expected exception.
+ }
+ }
+
+ @Test
+ public void updateLogicalViewTest() throws Exception {
+ LogicalView expectedResponse =
+ LogicalView.newBuilder()
+ .setName(LogicalViewName.of("[PROJECT]", "[INSTANCE]", "[LOGICAL_VIEW]").toString())
+ .setQuery("query107944136")
+ .setEtag("etag3123477")
+ .build();
+ Operation resultOperation =
+ Operation.newBuilder()
+ .setName("updateLogicalViewTest")
+ .setDone(true)
+ .setResponse(Any.pack(expectedResponse))
+ .build();
+ mockBigtableInstanceAdmin.addResponse(resultOperation);
+
+ LogicalView logicalView = LogicalView.newBuilder().build();
+ FieldMask updateMask = FieldMask.newBuilder().build();
+
+ LogicalView actualResponse = client.updateLogicalViewAsync(logicalView, updateMask).get();
+ Assert.assertEquals(expectedResponse, actualResponse);
+
+ List actualRequests = mockBigtableInstanceAdmin.getRequests();
+ Assert.assertEquals(1, actualRequests.size());
+ UpdateLogicalViewRequest actualRequest = ((UpdateLogicalViewRequest) actualRequests.get(0));
+
+ Assert.assertEquals(logicalView, actualRequest.getLogicalView());
+ Assert.assertEquals(updateMask, actualRequest.getUpdateMask());
+ Assert.assertTrue(
+ channelProvider.isHeaderSent(
+ ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
+ GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
+ }
+
+ @Test
+ public void updateLogicalViewExceptionTest() throws Exception {
+ StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
+ mockBigtableInstanceAdmin.addException(exception);
+
+ try {
+ LogicalView logicalView = LogicalView.newBuilder().build();
+ FieldMask updateMask = FieldMask.newBuilder().build();
+ client.updateLogicalViewAsync(logicalView, updateMask).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 deleteLogicalViewTest() throws Exception {
+ Empty expectedResponse = Empty.newBuilder().build();
+ mockBigtableInstanceAdmin.addResponse(expectedResponse);
+
+ LogicalViewName name = LogicalViewName.of("[PROJECT]", "[INSTANCE]", "[LOGICAL_VIEW]");
+
+ client.deleteLogicalView(name);
+
+ List actualRequests = mockBigtableInstanceAdmin.getRequests();
+ Assert.assertEquals(1, actualRequests.size());
+ DeleteLogicalViewRequest actualRequest = ((DeleteLogicalViewRequest) actualRequests.get(0));
+
+ Assert.assertEquals(name.toString(), actualRequest.getName());
+ Assert.assertTrue(
+ channelProvider.isHeaderSent(
+ ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
+ GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
+ }
+
+ @Test
+ public void deleteLogicalViewExceptionTest() throws Exception {
+ StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
+ mockBigtableInstanceAdmin.addException(exception);
+
+ try {
+ LogicalViewName name = LogicalViewName.of("[PROJECT]", "[INSTANCE]", "[LOGICAL_VIEW]");
+ client.deleteLogicalView(name);
+ Assert.fail("No exception raised");
+ } catch (InvalidArgumentException e) {
+ // Expected exception.
+ }
+ }
+
+ @Test
+ public void deleteLogicalViewTest2() throws Exception {
+ Empty expectedResponse = Empty.newBuilder().build();
+ mockBigtableInstanceAdmin.addResponse(expectedResponse);
+
+ String name = "name3373707";
+
+ client.deleteLogicalView(name);
+
+ List actualRequests = mockBigtableInstanceAdmin.getRequests();
+ Assert.assertEquals(1, actualRequests.size());
+ DeleteLogicalViewRequest actualRequest = ((DeleteLogicalViewRequest) actualRequests.get(0));
+
+ Assert.assertEquals(name, actualRequest.getName());
+ Assert.assertTrue(
+ channelProvider.isHeaderSent(
+ ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
+ GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
+ }
+
+ @Test
+ public void deleteLogicalViewExceptionTest2() throws Exception {
+ StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
+ mockBigtableInstanceAdmin.addException(exception);
+
+ try {
+ String name = "name3373707";
+ client.deleteLogicalView(name);
+ Assert.fail("No exception raised");
+ } catch (InvalidArgumentException e) {
+ // Expected exception.
+ }
+ }
+
+ @Test
+ public void createMaterializedViewTest() throws Exception {
+ MaterializedView expectedResponse =
+ MaterializedView.newBuilder()
+ .setName(
+ MaterializedViewName.of("[PROJECT]", "[INSTANCE]", "[MATERIALIZED_VIEW]")
+ .toString())
+ .setQuery("query107944136")
+ .setEtag("etag3123477")
+ .setDeletionProtection(true)
+ .build();
+ Operation resultOperation =
+ Operation.newBuilder()
+ .setName("createMaterializedViewTest")
+ .setDone(true)
+ .setResponse(Any.pack(expectedResponse))
+ .build();
+ mockBigtableInstanceAdmin.addResponse(resultOperation);
+
+ InstanceName parent = InstanceName.of("[PROJECT]", "[INSTANCE]");
+ MaterializedView materializedView = MaterializedView.newBuilder().build();
+ String materializedViewId = "materializedViewId682270903";
+
+ MaterializedView actualResponse =
+ client.createMaterializedViewAsync(parent, materializedView, materializedViewId).get();
+ Assert.assertEquals(expectedResponse, actualResponse);
+
+ List actualRequests = mockBigtableInstanceAdmin.getRequests();
+ Assert.assertEquals(1, actualRequests.size());
+ CreateMaterializedViewRequest actualRequest =
+ ((CreateMaterializedViewRequest) actualRequests.get(0));
+
+ Assert.assertEquals(parent.toString(), actualRequest.getParent());
+ Assert.assertEquals(materializedView, actualRequest.getMaterializedView());
+ Assert.assertEquals(materializedViewId, actualRequest.getMaterializedViewId());
+ Assert.assertTrue(
+ channelProvider.isHeaderSent(
+ ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
+ GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
+ }
+
+ @Test
+ public void createMaterializedViewExceptionTest() throws Exception {
+ StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
+ mockBigtableInstanceAdmin.addException(exception);
+
+ try {
+ InstanceName parent = InstanceName.of("[PROJECT]", "[INSTANCE]");
+ MaterializedView materializedView = MaterializedView.newBuilder().build();
+ String materializedViewId = "materializedViewId682270903";
+ client.createMaterializedViewAsync(parent, materializedView, materializedViewId).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 createMaterializedViewTest2() throws Exception {
+ MaterializedView expectedResponse =
+ MaterializedView.newBuilder()
+ .setName(
+ MaterializedViewName.of("[PROJECT]", "[INSTANCE]", "[MATERIALIZED_VIEW]")
+ .toString())
+ .setQuery("query107944136")
+ .setEtag("etag3123477")
+ .setDeletionProtection(true)
+ .build();
+ Operation resultOperation =
+ Operation.newBuilder()
+ .setName("createMaterializedViewTest")
+ .setDone(true)
+ .setResponse(Any.pack(expectedResponse))
+ .build();
+ mockBigtableInstanceAdmin.addResponse(resultOperation);
+
+ String parent = "parent-995424086";
+ MaterializedView materializedView = MaterializedView.newBuilder().build();
+ String materializedViewId = "materializedViewId682270903";
+
+ MaterializedView actualResponse =
+ client.createMaterializedViewAsync(parent, materializedView, materializedViewId).get();
+ Assert.assertEquals(expectedResponse, actualResponse);
+
+ List