Skip to content
Permalink
Browse files
feat: update the Dataproc V1 API client library (#497)
This PR was generated using Autosynth. 🌈

Synth log will be available here:
https://source.cloud.google.com/results/invocations/910f143f-7dd7-4a06-8fca-74558edd8e86/targets

- [ ] To automatically regenerate this PR, check this box. (May take up to 24 hours.)

PiperOrigin-RevId: 367518225
Source-Link: googleapis/googleapis@439f098
  • Loading branch information
yoshi-automation committed Apr 9, 2021
1 parent 7064178 commit 3c78a971133b3809ac3c962a1c07951480047c31
Showing with 15,700 additions and 1,034 deletions.
  1. +166 −0 google-cloud-dataproc/src/main/java/com/google/cloud/dataproc/v1/ClusterControllerClient.java
  2. +44 −0 google-cloud-dataproc/src/main/java/com/google/cloud/dataproc/v1/ClusterControllerSettings.java
  3. +2 −2 google-cloud-dataproc/src/main/java/com/google/cloud/dataproc/v1/WorkflowTemplateServiceClient.java
  4. +6 −0 google-cloud-dataproc/src/main/java/com/google/cloud/dataproc/v1/gapic_metadata.json
  5. +20 −0 google-cloud-dataproc/src/main/java/com/google/cloud/dataproc/v1/stub/ClusterControllerStub.java
  6. +140 −0 ...cloud-dataproc/src/main/java/com/google/cloud/dataproc/v1/stub/ClusterControllerStubSettings.java
  7. +95 −0 google-cloud-dataproc/src/main/java/com/google/cloud/dataproc/v1/stub/GrpcClusterControllerStub.java
  8. +142 −0 google-cloud-dataproc/src/test/java/com/google/cloud/dataproc/v1/ClusterControllerClientTest.java
  9. +41 −0 google-cloud-dataproc/src/test/java/com/google/cloud/dataproc/v1/MockClusterControllerImpl.java
  10. +7 −0 ...-cloud-dataproc/src/test/java/com/google/cloud/dataproc/v1/WorkflowTemplateServiceClientTest.java
  11. +227 −4 grpc-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/ClusterControllerGrpc.java
  12. +8 −4 ...gle-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/WorkflowTemplateServiceGrpc.java
  13. +668 −0 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/ClusterConfig.java
  14. +99 −0 ...o-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/ClusterConfigOrBuilder.java
  15. +223 −0 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/ClusterName.java
  16. +66 −0 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/ClusterStatus.java
  17. +411 −231 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/ClustersProto.java
  18. +143 −2 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/Component.java
  19. +21 −21 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/CreateClusterRequest.java
  20. +6 −6 ...e-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/CreateClusterRequestOrBuilder.java
  21. +21 −14 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/DeleteClusterRequest.java
  22. +6 −4 ...e-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/DeleteClusterRequestOrBuilder.java
  23. +28 −14 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/DiskConfig.java
  24. +8 −4 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/DiskConfigOrBuilder.java
  25. +1,012 −13 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/GceClusterConfig.java
  26. +115 −0 ...oogle-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/GceClusterConfigOrBuilder.java
  27. +1,690 −0 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/GkeClusterConfig.java
  28. +68 −0 ...oogle-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/GkeClusterConfigOrBuilder.java
  29. +829 −0 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/IdentityConfig.java
  30. +90 −0 ...-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/IdentityConfigOrBuilder.java
  31. +20 −4 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/InstanceGroupConfig.java
  32. +5 −1 ...le-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/InstanceGroupConfigOrBuilder.java
  33. +11 −11 ...ud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/InstantiateWorkflowTemplateRequest.java
  34. +5 −5 ...oc-v1/src/main/java/com/google/cloud/dataproc/v1/InstantiateWorkflowTemplateRequestOrBuilder.java
  35. +8 −8 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/Job.java
  36. +2 −2 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/JobOrBuilder.java
  37. +356 −0 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/JobPlacement.java
  38. +64 −0 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/JobPlacementOrBuilder.java
  39. +14 −14 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/JobReference.java
  40. +4 −4 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/JobReferenceOrBuilder.java
  41. +102 −4 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/JobScheduling.java
  42. +16 −1 ...o-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/JobSchedulingOrBuilder.java
  43. +140 −124 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/JobsProto.java
  44. +28 −28 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/KerberosConfig.java
  45. +8 −8 ...-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/KerberosConfigOrBuilder.java
  46. +24 −24 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/LifecycleConfig.java
  47. +6 −6 ...google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/LifecycleConfigOrBuilder.java
  48. +663 −0 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/MetastoreConfig.java
  49. +58 −0 ...google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/MetastoreConfigOrBuilder.java
  50. +683 −0 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/NodeGroupAffinity.java
  51. +64 −0 ...ogle-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/NodeGroupAffinityOrBuilder.java
  52. +14 −14 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/OrderedJob.java
  53. +4 −4 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/OrderedJobOrBuilder.java
  54. +39 −39 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/QueryList.java
  55. +12 −12 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/QueryListOrBuilder.java
  56. +364 −26 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/SecurityConfig.java
  57. +56 −6 ...-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/SecurityConfigOrBuilder.java
  58. +223 −0 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/ServiceName.java
  59. +12 −7 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/SharedProto.java
  60. +728 −0 ...o-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/ShieldedInstanceConfig.java
  61. +64 −0 ...cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/ShieldedInstanceConfigOrBuilder.java
  62. +1,428 −0 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/StartClusterRequest.java
  63. +172 −0 ...le-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/StartClusterRequestOrBuilder.java
  64. +1,428 −0 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/StopClusterRequest.java
  65. +172 −0 ...gle-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/StopClusterRequestOrBuilder.java
  66. +21 −14 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/SubmitJobRequest.java
  67. +6 −4 ...oogle-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/SubmitJobRequestOrBuilder.java
  68. +52 −52 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/TemplateParameter.java
  69. +16 −16 ...ogle-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/TemplateParameterOrBuilder.java
  70. +21 −14 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/UpdateClusterRequest.java
  71. +6 −4 ...e-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/UpdateClusterRequestOrBuilder.java
  72. +961 −0 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/WorkflowMetadata.java
  73. +138 −0 ...oogle-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/WorkflowMetadataOrBuilder.java
  74. +392 −0 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/WorkflowTemplate.java
  75. +65 −0 ...oogle-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/WorkflowTemplateOrBuilder.java
  76. +195 −183 ...o-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/WorkflowTemplatesProto.java
  77. +253 −19 proto-google-cloud-dataproc-v1/src/main/proto/google/cloud/dataproc/v1/clusters.proto
  78. +47 −23 proto-google-cloud-dataproc-v1/src/main/proto/google/cloud/dataproc/v1/jobs.proto
  79. +25 −1 proto-google-cloud-dataproc-v1/src/main/proto/google/cloud/dataproc/v1/shared.proto
  80. +82 −28 proto-google-cloud-dataproc-v1/src/main/proto/google/cloud/dataproc/v1/workflow_templates.proto
  81. +21 −5 synth.metadata
@@ -448,6 +448,172 @@ public final UnaryCallable<UpdateClusterRequest, Operation> updateClusterCallabl
return stub.updateClusterCallable();
}

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Stops a cluster in a project.
*
* <p>Sample code:
*
* <pre>{@code
* try (ClusterControllerClient clusterControllerClient = ClusterControllerClient.create()) {
* StopClusterRequest request =
* StopClusterRequest.newBuilder()
* .setProjectId("projectId-894832108")
* .setRegion("region-934795532")
* .setClusterName("clusterName-1141738587")
* .setClusterUuid("clusterUuid-1141510955")
* .setRequestId("requestId693933066")
* .build();
* Cluster response = clusterControllerClient.stopClusterAsync(request).get();
* }
* }</pre>
*
* @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<Cluster, ClusterOperationMetadata> stopClusterAsync(
StopClusterRequest request) {
return stopClusterOperationCallable().futureCall(request);
}

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Stops a cluster in a project.
*
* <p>Sample code:
*
* <pre>{@code
* try (ClusterControllerClient clusterControllerClient = ClusterControllerClient.create()) {
* StopClusterRequest request =
* StopClusterRequest.newBuilder()
* .setProjectId("projectId-894832108")
* .setRegion("region-934795532")
* .setClusterName("clusterName-1141738587")
* .setClusterUuid("clusterUuid-1141510955")
* .setRequestId("requestId693933066")
* .build();
* OperationFuture<Cluster, ClusterOperationMetadata> future =
* clusterControllerClient.stopClusterOperationCallable().futureCall(request);
* // Do something.
* Cluster response = future.get();
* }
* }</pre>
*/
public final OperationCallable<StopClusterRequest, Cluster, ClusterOperationMetadata>
stopClusterOperationCallable() {
return stub.stopClusterOperationCallable();
}

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Stops a cluster in a project.
*
* <p>Sample code:
*
* <pre>{@code
* try (ClusterControllerClient clusterControllerClient = ClusterControllerClient.create()) {
* StopClusterRequest request =
* StopClusterRequest.newBuilder()
* .setProjectId("projectId-894832108")
* .setRegion("region-934795532")
* .setClusterName("clusterName-1141738587")
* .setClusterUuid("clusterUuid-1141510955")
* .setRequestId("requestId693933066")
* .build();
* ApiFuture<Operation> future =
* clusterControllerClient.stopClusterCallable().futureCall(request);
* // Do something.
* Operation response = future.get();
* }
* }</pre>
*/
public final UnaryCallable<StopClusterRequest, Operation> stopClusterCallable() {
return stub.stopClusterCallable();
}

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Starts a cluster in a project.
*
* <p>Sample code:
*
* <pre>{@code
* try (ClusterControllerClient clusterControllerClient = ClusterControllerClient.create()) {
* StartClusterRequest request =
* StartClusterRequest.newBuilder()
* .setProjectId("projectId-894832108")
* .setRegion("region-934795532")
* .setClusterName("clusterName-1141738587")
* .setClusterUuid("clusterUuid-1141510955")
* .setRequestId("requestId693933066")
* .build();
* Cluster response = clusterControllerClient.startClusterAsync(request).get();
* }
* }</pre>
*
* @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<Cluster, ClusterOperationMetadata> startClusterAsync(
StartClusterRequest request) {
return startClusterOperationCallable().futureCall(request);
}

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Starts a cluster in a project.
*
* <p>Sample code:
*
* <pre>{@code
* try (ClusterControllerClient clusterControllerClient = ClusterControllerClient.create()) {
* StartClusterRequest request =
* StartClusterRequest.newBuilder()
* .setProjectId("projectId-894832108")
* .setRegion("region-934795532")
* .setClusterName("clusterName-1141738587")
* .setClusterUuid("clusterUuid-1141510955")
* .setRequestId("requestId693933066")
* .build();
* OperationFuture<Cluster, ClusterOperationMetadata> future =
* clusterControllerClient.startClusterOperationCallable().futureCall(request);
* // Do something.
* Cluster response = future.get();
* }
* }</pre>
*/
public final OperationCallable<StartClusterRequest, Cluster, ClusterOperationMetadata>
startClusterOperationCallable() {
return stub.startClusterOperationCallable();
}

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Starts a cluster in a project.
*
* <p>Sample code:
*
* <pre>{@code
* try (ClusterControllerClient clusterControllerClient = ClusterControllerClient.create()) {
* StartClusterRequest request =
* StartClusterRequest.newBuilder()
* .setProjectId("projectId-894832108")
* .setRegion("region-934795532")
* .setClusterName("clusterName-1141738587")
* .setClusterUuid("clusterUuid-1141510955")
* .setRequestId("requestId693933066")
* .build();
* ApiFuture<Operation> future =
* clusterControllerClient.startClusterCallable().futureCall(request);
* // Do something.
* Operation response = future.get();
* }
* }</pre>
*/
public final UnaryCallable<StartClusterRequest, Operation> startClusterCallable() {
return stub.startClusterCallable();
}

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Deletes a cluster in a project. The returned
@@ -94,6 +94,28 @@ public UnaryCallSettings<UpdateClusterRequest, Operation> updateClusterSettings(
return ((ClusterControllerStubSettings) getStubSettings()).updateClusterOperationSettings();
}

/** Returns the object with the settings used for calls to stopCluster. */
public UnaryCallSettings<StopClusterRequest, Operation> stopClusterSettings() {
return ((ClusterControllerStubSettings) getStubSettings()).stopClusterSettings();
}

/** Returns the object with the settings used for calls to stopCluster. */
public OperationCallSettings<StopClusterRequest, Cluster, ClusterOperationMetadata>
stopClusterOperationSettings() {
return ((ClusterControllerStubSettings) getStubSettings()).stopClusterOperationSettings();
}

/** Returns the object with the settings used for calls to startCluster. */
public UnaryCallSettings<StartClusterRequest, Operation> startClusterSettings() {
return ((ClusterControllerStubSettings) getStubSettings()).startClusterSettings();
}

/** Returns the object with the settings used for calls to startCluster. */
public OperationCallSettings<StartClusterRequest, Cluster, ClusterOperationMetadata>
startClusterOperationSettings() {
return ((ClusterControllerStubSettings) getStubSettings()).startClusterOperationSettings();
}

/** Returns the object with the settings used for calls to deleteCluster. */
public UnaryCallSettings<DeleteClusterRequest, Operation> deleteClusterSettings() {
return ((ClusterControllerStubSettings) getStubSettings()).deleteClusterSettings();
@@ -248,6 +270,28 @@ public UnaryCallSettings.Builder<UpdateClusterRequest, Operation> updateClusterS
return getStubSettingsBuilder().updateClusterOperationSettings();
}

/** Returns the builder for the settings used for calls to stopCluster. */
public UnaryCallSettings.Builder<StopClusterRequest, Operation> stopClusterSettings() {
return getStubSettingsBuilder().stopClusterSettings();
}

/** Returns the builder for the settings used for calls to stopCluster. */
public OperationCallSettings.Builder<StopClusterRequest, Cluster, ClusterOperationMetadata>
stopClusterOperationSettings() {
return getStubSettingsBuilder().stopClusterOperationSettings();
}

/** Returns the builder for the settings used for calls to startCluster. */
public UnaryCallSettings.Builder<StartClusterRequest, Operation> startClusterSettings() {
return getStubSettingsBuilder().startClusterSettings();
}

/** Returns the builder for the settings used for calls to startCluster. */
public OperationCallSettings.Builder<StartClusterRequest, Cluster, ClusterOperationMetadata>
startClusterOperationSettings() {
return getStubSettingsBuilder().startClusterOperationSettings();
}

/** Returns the builder for the settings used for calls to deleteCluster. */
public UnaryCallSettings.Builder<DeleteClusterRequest, Operation> deleteClusterSettings() {
return getStubSettingsBuilder().deleteClusterSettings();
@@ -647,7 +647,7 @@ public final OperationFuture<Empty, WorkflowMetadata> instantiateWorkflowTemplat
* </ul>
*
* @param parameters Optional. Map from parameter names to values that should be used for those
* parameters. Values may not exceed 100 characters.
* parameters. Values may not exceed 1000 characters.
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
public final OperationFuture<Empty, WorkflowMetadata> instantiateWorkflowTemplateAsync(
@@ -708,7 +708,7 @@ public final OperationFuture<Empty, WorkflowMetadata> instantiateWorkflowTemplat
* </ul>
*
* @param parameters Optional. Map from parameter names to values that should be used for those
* parameters. Values may not exceed 100 characters.
* parameters. Values may not exceed 1000 characters.
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
public final OperationFuture<Empty, WorkflowMetadata> instantiateWorkflowTemplateAsync(
@@ -49,6 +49,12 @@
"ListClusters": {
"methods": ["listClusters", "listClusters", "listClusters", "listClustersPagedCallable", "listClustersCallable"]
},
"StartCluster": {
"methods": ["startClusterAsync", "startClusterOperationCallable", "startClusterCallable"]
},
"StopCluster": {
"methods": ["stopClusterAsync", "stopClusterOperationCallable", "stopClusterCallable"]
},
"UpdateCluster": {
"methods": ["updateClusterAsync", "updateClusterAsync", "updateClusterOperationCallable", "updateClusterCallable"]
}
@@ -30,6 +30,8 @@
import com.google.cloud.dataproc.v1.GetClusterRequest;
import com.google.cloud.dataproc.v1.ListClustersRequest;
import com.google.cloud.dataproc.v1.ListClustersResponse;
import com.google.cloud.dataproc.v1.StartClusterRequest;
import com.google.cloud.dataproc.v1.StopClusterRequest;
import com.google.cloud.dataproc.v1.UpdateClusterRequest;
import com.google.longrunning.Operation;
import com.google.longrunning.stub.OperationsStub;
@@ -67,6 +69,24 @@ public UnaryCallable<UpdateClusterRequest, Operation> updateClusterCallable() {
throw new UnsupportedOperationException("Not implemented: updateClusterCallable()");
}

public OperationCallable<StopClusterRequest, Cluster, ClusterOperationMetadata>
stopClusterOperationCallable() {
throw new UnsupportedOperationException("Not implemented: stopClusterOperationCallable()");
}

public UnaryCallable<StopClusterRequest, Operation> stopClusterCallable() {
throw new UnsupportedOperationException("Not implemented: stopClusterCallable()");
}

public OperationCallable<StartClusterRequest, Cluster, ClusterOperationMetadata>
startClusterOperationCallable() {
throw new UnsupportedOperationException("Not implemented: startClusterOperationCallable()");
}

public UnaryCallable<StartClusterRequest, Operation> startClusterCallable() {
throw new UnsupportedOperationException("Not implemented: startClusterCallable()");
}

public OperationCallable<DeleteClusterRequest, Empty, ClusterOperationMetadata>
deleteClusterOperationCallable() {
throw new UnsupportedOperationException("Not implemented: deleteClusterOperationCallable()");

0 comments on commit 3c78a97

Please sign in to comment.