diff --git a/google-cloud-clients/google-cloud-dataproc/src/main/java/com/google/cloud/dataproc/v1/stub/GrpcWorkflowTemplateServiceStub.java b/google-cloud-clients/google-cloud-dataproc/src/main/java/com/google/cloud/dataproc/v1/stub/GrpcWorkflowTemplateServiceStub.java index 5097a73e8e0f..f38098de40e5 100644 --- a/google-cloud-clients/google-cloud-dataproc/src/main/java/com/google/cloud/dataproc/v1/stub/GrpcWorkflowTemplateServiceStub.java +++ b/google-cloud-clients/google-cloud-dataproc/src/main/java/com/google/cloud/dataproc/v1/stub/GrpcWorkflowTemplateServiceStub.java @@ -24,6 +24,7 @@ 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.dataproc.v1.CreateWorkflowTemplateRequest; import com.google.cloud.dataproc.v1.DeleteWorkflowTemplateRequest; @@ -35,12 +36,14 @@ import com.google.cloud.dataproc.v1.UpdateWorkflowTemplateRequest; import com.google.cloud.dataproc.v1.WorkflowMetadata; import com.google.cloud.dataproc.v1.WorkflowTemplate; +import com.google.common.collect.ImmutableMap; import com.google.longrunning.Operation; import com.google.longrunning.stub.GrpcOperationsStub; import com.google.protobuf.Empty; import io.grpc.MethodDescriptor; import io.grpc.protobuf.ProtoUtils; import java.io.IOException; +import java.util.Map; import java.util.concurrent.TimeUnit; import javax.annotation.Generated; @@ -197,36 +200,102 @@ protected GrpcWorkflowTemplateServiceStub( createWorkflowTemplateTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(createWorkflowTemplateMethodDescriptor) + .setParamsExtractor( + new RequestParamsExtractor() { + @Override + public Map extract(CreateWorkflowTemplateRequest request) { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); + } + }) .build(); GrpcCallSettings getWorkflowTemplateTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(getWorkflowTemplateMethodDescriptor) + .setParamsExtractor( + new RequestParamsExtractor() { + @Override + public Map extract(GetWorkflowTemplateRequest request) { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); + } + }) .build(); GrpcCallSettings instantiateWorkflowTemplateTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(instantiateWorkflowTemplateMethodDescriptor) + .setParamsExtractor( + new RequestParamsExtractor() { + @Override + public Map extract( + InstantiateWorkflowTemplateRequest request) { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); + } + }) .build(); GrpcCallSettings instantiateInlineWorkflowTemplateTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(instantiateInlineWorkflowTemplateMethodDescriptor) + .setParamsExtractor( + new RequestParamsExtractor() { + @Override + public Map extract( + InstantiateInlineWorkflowTemplateRequest request) { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); + } + }) .build(); GrpcCallSettings updateWorkflowTemplateTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(updateWorkflowTemplateMethodDescriptor) + .setParamsExtractor( + new RequestParamsExtractor() { + @Override + public Map extract(UpdateWorkflowTemplateRequest request) { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put( + "template.name", String.valueOf(request.getTemplate().getName())); + return params.build(); + } + }) .build(); GrpcCallSettings listWorkflowTemplatesTransportSettings = GrpcCallSettings .newBuilder() .setMethodDescriptor(listWorkflowTemplatesMethodDescriptor) + .setParamsExtractor( + new RequestParamsExtractor() { + @Override + public Map extract(ListWorkflowTemplatesRequest request) { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); + } + }) .build(); GrpcCallSettings deleteWorkflowTemplateTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(deleteWorkflowTemplateMethodDescriptor) + .setParamsExtractor( + new RequestParamsExtractor() { + @Override + public Map extract(DeleteWorkflowTemplateRequest request) { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); + } + }) .build(); this.createWorkflowTemplateCallable = diff --git a/google-cloud-clients/google-cloud-dataproc/src/main/java/com/google/cloud/dataproc/v1beta2/stub/GrpcWorkflowTemplateServiceStub.java b/google-cloud-clients/google-cloud-dataproc/src/main/java/com/google/cloud/dataproc/v1beta2/stub/GrpcWorkflowTemplateServiceStub.java index b6b5bea2c846..e4072948a8ac 100644 --- a/google-cloud-clients/google-cloud-dataproc/src/main/java/com/google/cloud/dataproc/v1beta2/stub/GrpcWorkflowTemplateServiceStub.java +++ b/google-cloud-clients/google-cloud-dataproc/src/main/java/com/google/cloud/dataproc/v1beta2/stub/GrpcWorkflowTemplateServiceStub.java @@ -24,6 +24,7 @@ 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.dataproc.v1beta2.CreateWorkflowTemplateRequest; import com.google.cloud.dataproc.v1beta2.DeleteWorkflowTemplateRequest; @@ -35,12 +36,14 @@ import com.google.cloud.dataproc.v1beta2.UpdateWorkflowTemplateRequest; import com.google.cloud.dataproc.v1beta2.WorkflowMetadata; import com.google.cloud.dataproc.v1beta2.WorkflowTemplate; +import com.google.common.collect.ImmutableMap; import com.google.longrunning.Operation; import com.google.longrunning.stub.GrpcOperationsStub; import com.google.protobuf.Empty; import io.grpc.MethodDescriptor; import io.grpc.protobuf.ProtoUtils; import java.io.IOException; +import java.util.Map; import java.util.concurrent.TimeUnit; import javax.annotation.Generated; @@ -197,36 +200,102 @@ protected GrpcWorkflowTemplateServiceStub( createWorkflowTemplateTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(createWorkflowTemplateMethodDescriptor) + .setParamsExtractor( + new RequestParamsExtractor() { + @Override + public Map extract(CreateWorkflowTemplateRequest request) { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); + } + }) .build(); GrpcCallSettings getWorkflowTemplateTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(getWorkflowTemplateMethodDescriptor) + .setParamsExtractor( + new RequestParamsExtractor() { + @Override + public Map extract(GetWorkflowTemplateRequest request) { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); + } + }) .build(); GrpcCallSettings instantiateWorkflowTemplateTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(instantiateWorkflowTemplateMethodDescriptor) + .setParamsExtractor( + new RequestParamsExtractor() { + @Override + public Map extract( + InstantiateWorkflowTemplateRequest request) { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); + } + }) .build(); GrpcCallSettings instantiateInlineWorkflowTemplateTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(instantiateInlineWorkflowTemplateMethodDescriptor) + .setParamsExtractor( + new RequestParamsExtractor() { + @Override + public Map extract( + InstantiateInlineWorkflowTemplateRequest request) { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); + } + }) .build(); GrpcCallSettings updateWorkflowTemplateTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(updateWorkflowTemplateMethodDescriptor) + .setParamsExtractor( + new RequestParamsExtractor() { + @Override + public Map extract(UpdateWorkflowTemplateRequest request) { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put( + "template.name", String.valueOf(request.getTemplate().getName())); + return params.build(); + } + }) .build(); GrpcCallSettings listWorkflowTemplatesTransportSettings = GrpcCallSettings .newBuilder() .setMethodDescriptor(listWorkflowTemplatesMethodDescriptor) + .setParamsExtractor( + new RequestParamsExtractor() { + @Override + public Map extract(ListWorkflowTemplatesRequest request) { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); + } + }) .build(); GrpcCallSettings deleteWorkflowTemplateTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(deleteWorkflowTemplateMethodDescriptor) + .setParamsExtractor( + new RequestParamsExtractor() { + @Override + public Map extract(DeleteWorkflowTemplateRequest request) { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); + } + }) .build(); this.createWorkflowTemplateCallable = diff --git a/google-cloud-clients/google-cloud-dataproc/synth.metadata b/google-cloud-clients/google-cloud-dataproc/synth.metadata index 451bf17b8513..615106587195 100644 --- a/google-cloud-clients/google-cloud-dataproc/synth.metadata +++ b/google-cloud-clients/google-cloud-dataproc/synth.metadata @@ -1,19 +1,19 @@ { - "updateTime": "2019-03-06T08:39:37.112446Z", + "updateTime": "2019-03-28T07:40:42.469988Z", "sources": [ { "generator": { "name": "artman", - "version": "0.16.15", - "dockerImage": "googleapis/artman@sha256:9caadfa59d48224cba5f3217eb9d61a155b78ccf31e628abef385bc5b7ed3bd2" + "version": "0.16.20", + "dockerImage": "googleapis/artman@sha256:e3c054a2fb85a12481c722af616c7fb6f1d02d862248385eecbec3e4240ebd1e" } }, { "git": { "name": "googleapis", "remote": "https://github.com/googleapis/googleapis.git", - "sha": "856117505ff9075b3e9c0b5674113667b6cf9e00", - "internalRef": "236931378" + "sha": "6a84b3267b0a95e922608b9891219075047eee29", + "internalRef": "240640999" } } ],