From 2e458a9d657f9a3dbc1d7bc51dd23901eaace09a Mon Sep 17 00:00:00 2001 From: "gcf-owl-bot[bot]" <78513119+gcf-owl-bot[bot]@users.noreply.github.com> Date: Wed, 4 Aug 2021 23:16:41 +0000 Subject: [PATCH] feat!: release gapic-generator-java v2.0.0 (#47) Committer: @miraleung PiperOrigin-RevId: 388535346 Source-Link: https://github.com/googleapis/googleapis/commit/d9eaf41de44d953458b18712a3f240bb4c564e48 Source-Link: https://github.com/googleapis/googleapis-gen/commit/976c5ab6f24b58c91fe04847ead1953f99d19e6a --- .../com/google/cloud/tpu/v1/TpuClient.java | 24 +--- .../com/google/cloud/tpu/v1/TpuSettings.java | 3 +- .../google/cloud/tpu/v1/stub/GrpcTpuStub.java | 123 +++++++----------- .../cloud/tpu/v1/stub/TpuStubSettings.java | 3 +- 4 files changed, 49 insertions(+), 104 deletions(-) diff --git a/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v1/TpuClient.java b/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v1/TpuClient.java index 880b0bec..d87eb29b 100644 --- a/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v1/TpuClient.java +++ b/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v1/TpuClient.java @@ -16,7 +16,6 @@ package com.google.cloud.tpu.v1; -import com.google.api.core.ApiFunction; import com.google.api.core.ApiFuture; import com.google.api.core.ApiFutures; import com.google.api.core.BetaApi; @@ -1369,14 +1368,7 @@ public static ApiFuture createAsync( ApiFuture futurePage = ListNodesPage.createEmptyPage().createPageAsync(context, futureResponse); return ApiFutures.transform( - futurePage, - new ApiFunction() { - @Override - public ListNodesPagedResponse apply(ListNodesPage input) { - return new ListNodesPagedResponse(input); - } - }, - MoreExecutors.directExecutor()); + futurePage, input -> new ListNodesPagedResponse(input), MoreExecutors.directExecutor()); } private ListNodesPagedResponse(ListNodesPage page) { @@ -1448,12 +1440,7 @@ public static ApiFuture createAsync( ListTensorFlowVersionsPage.createEmptyPage().createPageAsync(context, futureResponse); return ApiFutures.transform( futurePage, - new ApiFunction() { - @Override - public ListTensorFlowVersionsPagedResponse apply(ListTensorFlowVersionsPage input) { - return new ListTensorFlowVersionsPagedResponse(input); - } - }, + input -> new ListTensorFlowVersionsPagedResponse(input), MoreExecutors.directExecutor()); } @@ -1540,12 +1527,7 @@ public static ApiFuture createAsync( ListAcceleratorTypesPage.createEmptyPage().createPageAsync(context, futureResponse); return ApiFutures.transform( futurePage, - new ApiFunction() { - @Override - public ListAcceleratorTypesPagedResponse apply(ListAcceleratorTypesPage input) { - return new ListAcceleratorTypesPagedResponse(input); - } - }, + input -> new ListAcceleratorTypesPagedResponse(input), MoreExecutors.directExecutor()); } diff --git a/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v1/TpuSettings.java b/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v1/TpuSettings.java index 5b652300..10af0696 100644 --- a/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v1/TpuSettings.java +++ b/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v1/TpuSettings.java @@ -252,14 +252,13 @@ public TpuStubSettings.Builder getStubSettingsBuilder() { return ((TpuStubSettings.Builder) getStubSettings()); } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods( getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater); return this; diff --git a/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v1/stub/GrpcTpuStub.java b/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v1/stub/GrpcTpuStub.java index 89da76bf..f0ba63a2 100644 --- a/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v1/stub/GrpcTpuStub.java +++ b/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v1/stub/GrpcTpuStub.java @@ -26,7 +26,6 @@ import com.google.api.gax.grpc.GrpcStubCallableFactory; import com.google.api.gax.rpc.ClientContext; import com.google.api.gax.rpc.OperationCallable; -import com.google.api.gax.rpc.RequestParamsExtractor; import com.google.api.gax.rpc.UnaryCallable; import com.google.cloud.tpu.v1.AcceleratorType; import com.google.cloud.tpu.v1.CreateNodeRequest; @@ -52,7 +51,6 @@ import io.grpc.MethodDescriptor; import io.grpc.protobuf.ProtoUtils; import java.io.IOException; -import java.util.Map; import java.util.concurrent.TimeUnit; import javax.annotation.Generated; @@ -237,91 +235,70 @@ protected GrpcTpuStub( GrpcCallSettings.newBuilder() .setMethodDescriptor(listNodesMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(ListNodesRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings getNodeTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(getNodeMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(GetNodeRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings createNodeTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(createNodeMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(CreateNodeRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings deleteNodeTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(deleteNodeMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(DeleteNodeRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings reimageNodeTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(reimageNodeMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(ReimageNodeRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings stopNodeTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(stopNodeMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(StopNodeRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings startNodeTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(startNodeMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(StartNodeRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings @@ -330,13 +307,10 @@ public Map extract(StartNodeRequest request) { .newBuilder() .setMethodDescriptor(listTensorFlowVersionsMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(ListTensorFlowVersionsRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings @@ -344,13 +318,10 @@ public Map extract(ListTensorFlowVersionsRequest request) { GrpcCallSettings.newBuilder() .setMethodDescriptor(getTensorFlowVersionMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(GetTensorFlowVersionRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings @@ -358,13 +329,10 @@ public Map extract(GetTensorFlowVersionRequest request) { GrpcCallSettings.newBuilder() .setMethodDescriptor(listAcceleratorTypesMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(ListAcceleratorTypesRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings @@ -372,13 +340,10 @@ public Map extract(ListAcceleratorTypesRequest request) { GrpcCallSettings.newBuilder() .setMethodDescriptor(getAcceleratorTypeMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(GetAcceleratorTypeRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); diff --git a/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v1/stub/TpuStubSettings.java b/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v1/stub/TpuStubSettings.java index e74c2dd3..4866067d 100644 --- a/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v1/stub/TpuStubSettings.java +++ b/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v1/stub/TpuStubSettings.java @@ -841,14 +841,13 @@ private static Builder initDefaults(Builder builder) { return builder; } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods(unaryMethodSettingsBuilders, settingsUpdater); return this; }