• Home
  • Line#
  • Scopes#
  • Navigate#
  • Raw
  • Download
1 /*
2  * Copyright 2020 Google LLC
3  *
4  * Licensed under the Apache License, Version 2.0 (the "License");
5  * you may not use this file except in compliance with the License.
6  * You may obtain a copy of the License at
7  *
8  *     https://www.apache.org/licenses/LICENSE-2.0
9  *
10  * Unless required by applicable law or agreed to in writing, software
11  * distributed under the License is distributed on an "AS IS" BASIS,
12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13  * See the License for the specific language governing permissions and
14  * limitations under the License.
15  */
16 package com.google.cloud.aiplatform.v1;
17 
18 import static io.grpc.MethodDescriptor.generateFullMethodName;
19 
20 /**
21  *
22  *
23  * <pre>
24  * A service for creating and managing Vertex AI's jobs.
25  * </pre>
26  */
27 @javax.annotation.Generated(
28     value = "by gRPC proto compiler",
29     comments = "Source: google/cloud/aiplatform/v1/job_service.proto")
30 @io.grpc.stub.annotations.GrpcGenerated
31 public final class JobServiceGrpc {
32 
JobServiceGrpc()33   private JobServiceGrpc() {}
34 
35   public static final String SERVICE_NAME = "google.cloud.aiplatform.v1.JobService";
36 
37   // Static method descriptors that strictly reflect the proto.
38   private static volatile io.grpc.MethodDescriptor<
39           com.google.cloud.aiplatform.v1.CreateCustomJobRequest,
40           com.google.cloud.aiplatform.v1.CustomJob>
41       getCreateCustomJobMethod;
42 
43   @io.grpc.stub.annotations.RpcMethod(
44       fullMethodName = SERVICE_NAME + '/' + "CreateCustomJob",
45       requestType = com.google.cloud.aiplatform.v1.CreateCustomJobRequest.class,
46       responseType = com.google.cloud.aiplatform.v1.CustomJob.class,
47       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
48   public static io.grpc.MethodDescriptor<
49           com.google.cloud.aiplatform.v1.CreateCustomJobRequest,
50           com.google.cloud.aiplatform.v1.CustomJob>
getCreateCustomJobMethod()51       getCreateCustomJobMethod() {
52     io.grpc.MethodDescriptor<
53             com.google.cloud.aiplatform.v1.CreateCustomJobRequest,
54             com.google.cloud.aiplatform.v1.CustomJob>
55         getCreateCustomJobMethod;
56     if ((getCreateCustomJobMethod = JobServiceGrpc.getCreateCustomJobMethod) == null) {
57       synchronized (JobServiceGrpc.class) {
58         if ((getCreateCustomJobMethod = JobServiceGrpc.getCreateCustomJobMethod) == null) {
59           JobServiceGrpc.getCreateCustomJobMethod =
60               getCreateCustomJobMethod =
61                   io.grpc.MethodDescriptor
62                       .<com.google.cloud.aiplatform.v1.CreateCustomJobRequest,
63                           com.google.cloud.aiplatform.v1.CustomJob>
64                           newBuilder()
65                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
66                       .setFullMethodName(generateFullMethodName(SERVICE_NAME, "CreateCustomJob"))
67                       .setSampledToLocalTracing(true)
68                       .setRequestMarshaller(
69                           io.grpc.protobuf.ProtoUtils.marshaller(
70                               com.google.cloud.aiplatform.v1.CreateCustomJobRequest
71                                   .getDefaultInstance()))
72                       .setResponseMarshaller(
73                           io.grpc.protobuf.ProtoUtils.marshaller(
74                               com.google.cloud.aiplatform.v1.CustomJob.getDefaultInstance()))
75                       .setSchemaDescriptor(
76                           new JobServiceMethodDescriptorSupplier("CreateCustomJob"))
77                       .build();
78         }
79       }
80     }
81     return getCreateCustomJobMethod;
82   }
83 
84   private static volatile io.grpc.MethodDescriptor<
85           com.google.cloud.aiplatform.v1.GetCustomJobRequest,
86           com.google.cloud.aiplatform.v1.CustomJob>
87       getGetCustomJobMethod;
88 
89   @io.grpc.stub.annotations.RpcMethod(
90       fullMethodName = SERVICE_NAME + '/' + "GetCustomJob",
91       requestType = com.google.cloud.aiplatform.v1.GetCustomJobRequest.class,
92       responseType = com.google.cloud.aiplatform.v1.CustomJob.class,
93       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
94   public static io.grpc.MethodDescriptor<
95           com.google.cloud.aiplatform.v1.GetCustomJobRequest,
96           com.google.cloud.aiplatform.v1.CustomJob>
getGetCustomJobMethod()97       getGetCustomJobMethod() {
98     io.grpc.MethodDescriptor<
99             com.google.cloud.aiplatform.v1.GetCustomJobRequest,
100             com.google.cloud.aiplatform.v1.CustomJob>
101         getGetCustomJobMethod;
102     if ((getGetCustomJobMethod = JobServiceGrpc.getGetCustomJobMethod) == null) {
103       synchronized (JobServiceGrpc.class) {
104         if ((getGetCustomJobMethod = JobServiceGrpc.getGetCustomJobMethod) == null) {
105           JobServiceGrpc.getGetCustomJobMethod =
106               getGetCustomJobMethod =
107                   io.grpc.MethodDescriptor
108                       .<com.google.cloud.aiplatform.v1.GetCustomJobRequest,
109                           com.google.cloud.aiplatform.v1.CustomJob>
110                           newBuilder()
111                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
112                       .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetCustomJob"))
113                       .setSampledToLocalTracing(true)
114                       .setRequestMarshaller(
115                           io.grpc.protobuf.ProtoUtils.marshaller(
116                               com.google.cloud.aiplatform.v1.GetCustomJobRequest
117                                   .getDefaultInstance()))
118                       .setResponseMarshaller(
119                           io.grpc.protobuf.ProtoUtils.marshaller(
120                               com.google.cloud.aiplatform.v1.CustomJob.getDefaultInstance()))
121                       .setSchemaDescriptor(new JobServiceMethodDescriptorSupplier("GetCustomJob"))
122                       .build();
123         }
124       }
125     }
126     return getGetCustomJobMethod;
127   }
128 
129   private static volatile io.grpc.MethodDescriptor<
130           com.google.cloud.aiplatform.v1.ListCustomJobsRequest,
131           com.google.cloud.aiplatform.v1.ListCustomJobsResponse>
132       getListCustomJobsMethod;
133 
134   @io.grpc.stub.annotations.RpcMethod(
135       fullMethodName = SERVICE_NAME + '/' + "ListCustomJobs",
136       requestType = com.google.cloud.aiplatform.v1.ListCustomJobsRequest.class,
137       responseType = com.google.cloud.aiplatform.v1.ListCustomJobsResponse.class,
138       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
139   public static io.grpc.MethodDescriptor<
140           com.google.cloud.aiplatform.v1.ListCustomJobsRequest,
141           com.google.cloud.aiplatform.v1.ListCustomJobsResponse>
getListCustomJobsMethod()142       getListCustomJobsMethod() {
143     io.grpc.MethodDescriptor<
144             com.google.cloud.aiplatform.v1.ListCustomJobsRequest,
145             com.google.cloud.aiplatform.v1.ListCustomJobsResponse>
146         getListCustomJobsMethod;
147     if ((getListCustomJobsMethod = JobServiceGrpc.getListCustomJobsMethod) == null) {
148       synchronized (JobServiceGrpc.class) {
149         if ((getListCustomJobsMethod = JobServiceGrpc.getListCustomJobsMethod) == null) {
150           JobServiceGrpc.getListCustomJobsMethod =
151               getListCustomJobsMethod =
152                   io.grpc.MethodDescriptor
153                       .<com.google.cloud.aiplatform.v1.ListCustomJobsRequest,
154                           com.google.cloud.aiplatform.v1.ListCustomJobsResponse>
155                           newBuilder()
156                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
157                       .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListCustomJobs"))
158                       .setSampledToLocalTracing(true)
159                       .setRequestMarshaller(
160                           io.grpc.protobuf.ProtoUtils.marshaller(
161                               com.google.cloud.aiplatform.v1.ListCustomJobsRequest
162                                   .getDefaultInstance()))
163                       .setResponseMarshaller(
164                           io.grpc.protobuf.ProtoUtils.marshaller(
165                               com.google.cloud.aiplatform.v1.ListCustomJobsResponse
166                                   .getDefaultInstance()))
167                       .setSchemaDescriptor(new JobServiceMethodDescriptorSupplier("ListCustomJobs"))
168                       .build();
169         }
170       }
171     }
172     return getListCustomJobsMethod;
173   }
174 
175   private static volatile io.grpc.MethodDescriptor<
176           com.google.cloud.aiplatform.v1.DeleteCustomJobRequest, com.google.longrunning.Operation>
177       getDeleteCustomJobMethod;
178 
179   @io.grpc.stub.annotations.RpcMethod(
180       fullMethodName = SERVICE_NAME + '/' + "DeleteCustomJob",
181       requestType = com.google.cloud.aiplatform.v1.DeleteCustomJobRequest.class,
182       responseType = com.google.longrunning.Operation.class,
183       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
184   public static io.grpc.MethodDescriptor<
185           com.google.cloud.aiplatform.v1.DeleteCustomJobRequest, com.google.longrunning.Operation>
getDeleteCustomJobMethod()186       getDeleteCustomJobMethod() {
187     io.grpc.MethodDescriptor<
188             com.google.cloud.aiplatform.v1.DeleteCustomJobRequest, com.google.longrunning.Operation>
189         getDeleteCustomJobMethod;
190     if ((getDeleteCustomJobMethod = JobServiceGrpc.getDeleteCustomJobMethod) == null) {
191       synchronized (JobServiceGrpc.class) {
192         if ((getDeleteCustomJobMethod = JobServiceGrpc.getDeleteCustomJobMethod) == null) {
193           JobServiceGrpc.getDeleteCustomJobMethod =
194               getDeleteCustomJobMethod =
195                   io.grpc.MethodDescriptor
196                       .<com.google.cloud.aiplatform.v1.DeleteCustomJobRequest,
197                           com.google.longrunning.Operation>
198                           newBuilder()
199                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
200                       .setFullMethodName(generateFullMethodName(SERVICE_NAME, "DeleteCustomJob"))
201                       .setSampledToLocalTracing(true)
202                       .setRequestMarshaller(
203                           io.grpc.protobuf.ProtoUtils.marshaller(
204                               com.google.cloud.aiplatform.v1.DeleteCustomJobRequest
205                                   .getDefaultInstance()))
206                       .setResponseMarshaller(
207                           io.grpc.protobuf.ProtoUtils.marshaller(
208                               com.google.longrunning.Operation.getDefaultInstance()))
209                       .setSchemaDescriptor(
210                           new JobServiceMethodDescriptorSupplier("DeleteCustomJob"))
211                       .build();
212         }
213       }
214     }
215     return getDeleteCustomJobMethod;
216   }
217 
218   private static volatile io.grpc.MethodDescriptor<
219           com.google.cloud.aiplatform.v1.CancelCustomJobRequest, com.google.protobuf.Empty>
220       getCancelCustomJobMethod;
221 
222   @io.grpc.stub.annotations.RpcMethod(
223       fullMethodName = SERVICE_NAME + '/' + "CancelCustomJob",
224       requestType = com.google.cloud.aiplatform.v1.CancelCustomJobRequest.class,
225       responseType = com.google.protobuf.Empty.class,
226       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
227   public static io.grpc.MethodDescriptor<
228           com.google.cloud.aiplatform.v1.CancelCustomJobRequest, com.google.protobuf.Empty>
getCancelCustomJobMethod()229       getCancelCustomJobMethod() {
230     io.grpc.MethodDescriptor<
231             com.google.cloud.aiplatform.v1.CancelCustomJobRequest, com.google.protobuf.Empty>
232         getCancelCustomJobMethod;
233     if ((getCancelCustomJobMethod = JobServiceGrpc.getCancelCustomJobMethod) == null) {
234       synchronized (JobServiceGrpc.class) {
235         if ((getCancelCustomJobMethod = JobServiceGrpc.getCancelCustomJobMethod) == null) {
236           JobServiceGrpc.getCancelCustomJobMethod =
237               getCancelCustomJobMethod =
238                   io.grpc.MethodDescriptor
239                       .<com.google.cloud.aiplatform.v1.CancelCustomJobRequest,
240                           com.google.protobuf.Empty>
241                           newBuilder()
242                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
243                       .setFullMethodName(generateFullMethodName(SERVICE_NAME, "CancelCustomJob"))
244                       .setSampledToLocalTracing(true)
245                       .setRequestMarshaller(
246                           io.grpc.protobuf.ProtoUtils.marshaller(
247                               com.google.cloud.aiplatform.v1.CancelCustomJobRequest
248                                   .getDefaultInstance()))
249                       .setResponseMarshaller(
250                           io.grpc.protobuf.ProtoUtils.marshaller(
251                               com.google.protobuf.Empty.getDefaultInstance()))
252                       .setSchemaDescriptor(
253                           new JobServiceMethodDescriptorSupplier("CancelCustomJob"))
254                       .build();
255         }
256       }
257     }
258     return getCancelCustomJobMethod;
259   }
260 
261   private static volatile io.grpc.MethodDescriptor<
262           com.google.cloud.aiplatform.v1.CreateDataLabelingJobRequest,
263           com.google.cloud.aiplatform.v1.DataLabelingJob>
264       getCreateDataLabelingJobMethod;
265 
266   @io.grpc.stub.annotations.RpcMethod(
267       fullMethodName = SERVICE_NAME + '/' + "CreateDataLabelingJob",
268       requestType = com.google.cloud.aiplatform.v1.CreateDataLabelingJobRequest.class,
269       responseType = com.google.cloud.aiplatform.v1.DataLabelingJob.class,
270       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
271   public static io.grpc.MethodDescriptor<
272           com.google.cloud.aiplatform.v1.CreateDataLabelingJobRequest,
273           com.google.cloud.aiplatform.v1.DataLabelingJob>
getCreateDataLabelingJobMethod()274       getCreateDataLabelingJobMethod() {
275     io.grpc.MethodDescriptor<
276             com.google.cloud.aiplatform.v1.CreateDataLabelingJobRequest,
277             com.google.cloud.aiplatform.v1.DataLabelingJob>
278         getCreateDataLabelingJobMethod;
279     if ((getCreateDataLabelingJobMethod = JobServiceGrpc.getCreateDataLabelingJobMethod) == null) {
280       synchronized (JobServiceGrpc.class) {
281         if ((getCreateDataLabelingJobMethod = JobServiceGrpc.getCreateDataLabelingJobMethod)
282             == null) {
283           JobServiceGrpc.getCreateDataLabelingJobMethod =
284               getCreateDataLabelingJobMethod =
285                   io.grpc.MethodDescriptor
286                       .<com.google.cloud.aiplatform.v1.CreateDataLabelingJobRequest,
287                           com.google.cloud.aiplatform.v1.DataLabelingJob>
288                           newBuilder()
289                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
290                       .setFullMethodName(
291                           generateFullMethodName(SERVICE_NAME, "CreateDataLabelingJob"))
292                       .setSampledToLocalTracing(true)
293                       .setRequestMarshaller(
294                           io.grpc.protobuf.ProtoUtils.marshaller(
295                               com.google.cloud.aiplatform.v1.CreateDataLabelingJobRequest
296                                   .getDefaultInstance()))
297                       .setResponseMarshaller(
298                           io.grpc.protobuf.ProtoUtils.marshaller(
299                               com.google.cloud.aiplatform.v1.DataLabelingJob.getDefaultInstance()))
300                       .setSchemaDescriptor(
301                           new JobServiceMethodDescriptorSupplier("CreateDataLabelingJob"))
302                       .build();
303         }
304       }
305     }
306     return getCreateDataLabelingJobMethod;
307   }
308 
309   private static volatile io.grpc.MethodDescriptor<
310           com.google.cloud.aiplatform.v1.GetDataLabelingJobRequest,
311           com.google.cloud.aiplatform.v1.DataLabelingJob>
312       getGetDataLabelingJobMethod;
313 
314   @io.grpc.stub.annotations.RpcMethod(
315       fullMethodName = SERVICE_NAME + '/' + "GetDataLabelingJob",
316       requestType = com.google.cloud.aiplatform.v1.GetDataLabelingJobRequest.class,
317       responseType = com.google.cloud.aiplatform.v1.DataLabelingJob.class,
318       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
319   public static io.grpc.MethodDescriptor<
320           com.google.cloud.aiplatform.v1.GetDataLabelingJobRequest,
321           com.google.cloud.aiplatform.v1.DataLabelingJob>
getGetDataLabelingJobMethod()322       getGetDataLabelingJobMethod() {
323     io.grpc.MethodDescriptor<
324             com.google.cloud.aiplatform.v1.GetDataLabelingJobRequest,
325             com.google.cloud.aiplatform.v1.DataLabelingJob>
326         getGetDataLabelingJobMethod;
327     if ((getGetDataLabelingJobMethod = JobServiceGrpc.getGetDataLabelingJobMethod) == null) {
328       synchronized (JobServiceGrpc.class) {
329         if ((getGetDataLabelingJobMethod = JobServiceGrpc.getGetDataLabelingJobMethod) == null) {
330           JobServiceGrpc.getGetDataLabelingJobMethod =
331               getGetDataLabelingJobMethod =
332                   io.grpc.MethodDescriptor
333                       .<com.google.cloud.aiplatform.v1.GetDataLabelingJobRequest,
334                           com.google.cloud.aiplatform.v1.DataLabelingJob>
335                           newBuilder()
336                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
337                       .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetDataLabelingJob"))
338                       .setSampledToLocalTracing(true)
339                       .setRequestMarshaller(
340                           io.grpc.protobuf.ProtoUtils.marshaller(
341                               com.google.cloud.aiplatform.v1.GetDataLabelingJobRequest
342                                   .getDefaultInstance()))
343                       .setResponseMarshaller(
344                           io.grpc.protobuf.ProtoUtils.marshaller(
345                               com.google.cloud.aiplatform.v1.DataLabelingJob.getDefaultInstance()))
346                       .setSchemaDescriptor(
347                           new JobServiceMethodDescriptorSupplier("GetDataLabelingJob"))
348                       .build();
349         }
350       }
351     }
352     return getGetDataLabelingJobMethod;
353   }
354 
355   private static volatile io.grpc.MethodDescriptor<
356           com.google.cloud.aiplatform.v1.ListDataLabelingJobsRequest,
357           com.google.cloud.aiplatform.v1.ListDataLabelingJobsResponse>
358       getListDataLabelingJobsMethod;
359 
360   @io.grpc.stub.annotations.RpcMethod(
361       fullMethodName = SERVICE_NAME + '/' + "ListDataLabelingJobs",
362       requestType = com.google.cloud.aiplatform.v1.ListDataLabelingJobsRequest.class,
363       responseType = com.google.cloud.aiplatform.v1.ListDataLabelingJobsResponse.class,
364       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
365   public static io.grpc.MethodDescriptor<
366           com.google.cloud.aiplatform.v1.ListDataLabelingJobsRequest,
367           com.google.cloud.aiplatform.v1.ListDataLabelingJobsResponse>
getListDataLabelingJobsMethod()368       getListDataLabelingJobsMethod() {
369     io.grpc.MethodDescriptor<
370             com.google.cloud.aiplatform.v1.ListDataLabelingJobsRequest,
371             com.google.cloud.aiplatform.v1.ListDataLabelingJobsResponse>
372         getListDataLabelingJobsMethod;
373     if ((getListDataLabelingJobsMethod = JobServiceGrpc.getListDataLabelingJobsMethod) == null) {
374       synchronized (JobServiceGrpc.class) {
375         if ((getListDataLabelingJobsMethod = JobServiceGrpc.getListDataLabelingJobsMethod)
376             == null) {
377           JobServiceGrpc.getListDataLabelingJobsMethod =
378               getListDataLabelingJobsMethod =
379                   io.grpc.MethodDescriptor
380                       .<com.google.cloud.aiplatform.v1.ListDataLabelingJobsRequest,
381                           com.google.cloud.aiplatform.v1.ListDataLabelingJobsResponse>
382                           newBuilder()
383                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
384                       .setFullMethodName(
385                           generateFullMethodName(SERVICE_NAME, "ListDataLabelingJobs"))
386                       .setSampledToLocalTracing(true)
387                       .setRequestMarshaller(
388                           io.grpc.protobuf.ProtoUtils.marshaller(
389                               com.google.cloud.aiplatform.v1.ListDataLabelingJobsRequest
390                                   .getDefaultInstance()))
391                       .setResponseMarshaller(
392                           io.grpc.protobuf.ProtoUtils.marshaller(
393                               com.google.cloud.aiplatform.v1.ListDataLabelingJobsResponse
394                                   .getDefaultInstance()))
395                       .setSchemaDescriptor(
396                           new JobServiceMethodDescriptorSupplier("ListDataLabelingJobs"))
397                       .build();
398         }
399       }
400     }
401     return getListDataLabelingJobsMethod;
402   }
403 
404   private static volatile io.grpc.MethodDescriptor<
405           com.google.cloud.aiplatform.v1.DeleteDataLabelingJobRequest,
406           com.google.longrunning.Operation>
407       getDeleteDataLabelingJobMethod;
408 
409   @io.grpc.stub.annotations.RpcMethod(
410       fullMethodName = SERVICE_NAME + '/' + "DeleteDataLabelingJob",
411       requestType = com.google.cloud.aiplatform.v1.DeleteDataLabelingJobRequest.class,
412       responseType = com.google.longrunning.Operation.class,
413       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
414   public static io.grpc.MethodDescriptor<
415           com.google.cloud.aiplatform.v1.DeleteDataLabelingJobRequest,
416           com.google.longrunning.Operation>
getDeleteDataLabelingJobMethod()417       getDeleteDataLabelingJobMethod() {
418     io.grpc.MethodDescriptor<
419             com.google.cloud.aiplatform.v1.DeleteDataLabelingJobRequest,
420             com.google.longrunning.Operation>
421         getDeleteDataLabelingJobMethod;
422     if ((getDeleteDataLabelingJobMethod = JobServiceGrpc.getDeleteDataLabelingJobMethod) == null) {
423       synchronized (JobServiceGrpc.class) {
424         if ((getDeleteDataLabelingJobMethod = JobServiceGrpc.getDeleteDataLabelingJobMethod)
425             == null) {
426           JobServiceGrpc.getDeleteDataLabelingJobMethod =
427               getDeleteDataLabelingJobMethod =
428                   io.grpc.MethodDescriptor
429                       .<com.google.cloud.aiplatform.v1.DeleteDataLabelingJobRequest,
430                           com.google.longrunning.Operation>
431                           newBuilder()
432                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
433                       .setFullMethodName(
434                           generateFullMethodName(SERVICE_NAME, "DeleteDataLabelingJob"))
435                       .setSampledToLocalTracing(true)
436                       .setRequestMarshaller(
437                           io.grpc.protobuf.ProtoUtils.marshaller(
438                               com.google.cloud.aiplatform.v1.DeleteDataLabelingJobRequest
439                                   .getDefaultInstance()))
440                       .setResponseMarshaller(
441                           io.grpc.protobuf.ProtoUtils.marshaller(
442                               com.google.longrunning.Operation.getDefaultInstance()))
443                       .setSchemaDescriptor(
444                           new JobServiceMethodDescriptorSupplier("DeleteDataLabelingJob"))
445                       .build();
446         }
447       }
448     }
449     return getDeleteDataLabelingJobMethod;
450   }
451 
452   private static volatile io.grpc.MethodDescriptor<
453           com.google.cloud.aiplatform.v1.CancelDataLabelingJobRequest, com.google.protobuf.Empty>
454       getCancelDataLabelingJobMethod;
455 
456   @io.grpc.stub.annotations.RpcMethod(
457       fullMethodName = SERVICE_NAME + '/' + "CancelDataLabelingJob",
458       requestType = com.google.cloud.aiplatform.v1.CancelDataLabelingJobRequest.class,
459       responseType = com.google.protobuf.Empty.class,
460       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
461   public static io.grpc.MethodDescriptor<
462           com.google.cloud.aiplatform.v1.CancelDataLabelingJobRequest, com.google.protobuf.Empty>
getCancelDataLabelingJobMethod()463       getCancelDataLabelingJobMethod() {
464     io.grpc.MethodDescriptor<
465             com.google.cloud.aiplatform.v1.CancelDataLabelingJobRequest, com.google.protobuf.Empty>
466         getCancelDataLabelingJobMethod;
467     if ((getCancelDataLabelingJobMethod = JobServiceGrpc.getCancelDataLabelingJobMethod) == null) {
468       synchronized (JobServiceGrpc.class) {
469         if ((getCancelDataLabelingJobMethod = JobServiceGrpc.getCancelDataLabelingJobMethod)
470             == null) {
471           JobServiceGrpc.getCancelDataLabelingJobMethod =
472               getCancelDataLabelingJobMethod =
473                   io.grpc.MethodDescriptor
474                       .<com.google.cloud.aiplatform.v1.CancelDataLabelingJobRequest,
475                           com.google.protobuf.Empty>
476                           newBuilder()
477                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
478                       .setFullMethodName(
479                           generateFullMethodName(SERVICE_NAME, "CancelDataLabelingJob"))
480                       .setSampledToLocalTracing(true)
481                       .setRequestMarshaller(
482                           io.grpc.protobuf.ProtoUtils.marshaller(
483                               com.google.cloud.aiplatform.v1.CancelDataLabelingJobRequest
484                                   .getDefaultInstance()))
485                       .setResponseMarshaller(
486                           io.grpc.protobuf.ProtoUtils.marshaller(
487                               com.google.protobuf.Empty.getDefaultInstance()))
488                       .setSchemaDescriptor(
489                           new JobServiceMethodDescriptorSupplier("CancelDataLabelingJob"))
490                       .build();
491         }
492       }
493     }
494     return getCancelDataLabelingJobMethod;
495   }
496 
497   private static volatile io.grpc.MethodDescriptor<
498           com.google.cloud.aiplatform.v1.CreateHyperparameterTuningJobRequest,
499           com.google.cloud.aiplatform.v1.HyperparameterTuningJob>
500       getCreateHyperparameterTuningJobMethod;
501 
502   @io.grpc.stub.annotations.RpcMethod(
503       fullMethodName = SERVICE_NAME + '/' + "CreateHyperparameterTuningJob",
504       requestType = com.google.cloud.aiplatform.v1.CreateHyperparameterTuningJobRequest.class,
505       responseType = com.google.cloud.aiplatform.v1.HyperparameterTuningJob.class,
506       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
507   public static io.grpc.MethodDescriptor<
508           com.google.cloud.aiplatform.v1.CreateHyperparameterTuningJobRequest,
509           com.google.cloud.aiplatform.v1.HyperparameterTuningJob>
getCreateHyperparameterTuningJobMethod()510       getCreateHyperparameterTuningJobMethod() {
511     io.grpc.MethodDescriptor<
512             com.google.cloud.aiplatform.v1.CreateHyperparameterTuningJobRequest,
513             com.google.cloud.aiplatform.v1.HyperparameterTuningJob>
514         getCreateHyperparameterTuningJobMethod;
515     if ((getCreateHyperparameterTuningJobMethod =
516             JobServiceGrpc.getCreateHyperparameterTuningJobMethod)
517         == null) {
518       synchronized (JobServiceGrpc.class) {
519         if ((getCreateHyperparameterTuningJobMethod =
520                 JobServiceGrpc.getCreateHyperparameterTuningJobMethod)
521             == null) {
522           JobServiceGrpc.getCreateHyperparameterTuningJobMethod =
523               getCreateHyperparameterTuningJobMethod =
524                   io.grpc.MethodDescriptor
525                       .<com.google.cloud.aiplatform.v1.CreateHyperparameterTuningJobRequest,
526                           com.google.cloud.aiplatform.v1.HyperparameterTuningJob>
527                           newBuilder()
528                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
529                       .setFullMethodName(
530                           generateFullMethodName(SERVICE_NAME, "CreateHyperparameterTuningJob"))
531                       .setSampledToLocalTracing(true)
532                       .setRequestMarshaller(
533                           io.grpc.protobuf.ProtoUtils.marshaller(
534                               com.google.cloud.aiplatform.v1.CreateHyperparameterTuningJobRequest
535                                   .getDefaultInstance()))
536                       .setResponseMarshaller(
537                           io.grpc.protobuf.ProtoUtils.marshaller(
538                               com.google.cloud.aiplatform.v1.HyperparameterTuningJob
539                                   .getDefaultInstance()))
540                       .setSchemaDescriptor(
541                           new JobServiceMethodDescriptorSupplier("CreateHyperparameterTuningJob"))
542                       .build();
543         }
544       }
545     }
546     return getCreateHyperparameterTuningJobMethod;
547   }
548 
549   private static volatile io.grpc.MethodDescriptor<
550           com.google.cloud.aiplatform.v1.GetHyperparameterTuningJobRequest,
551           com.google.cloud.aiplatform.v1.HyperparameterTuningJob>
552       getGetHyperparameterTuningJobMethod;
553 
554   @io.grpc.stub.annotations.RpcMethod(
555       fullMethodName = SERVICE_NAME + '/' + "GetHyperparameterTuningJob",
556       requestType = com.google.cloud.aiplatform.v1.GetHyperparameterTuningJobRequest.class,
557       responseType = com.google.cloud.aiplatform.v1.HyperparameterTuningJob.class,
558       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
559   public static io.grpc.MethodDescriptor<
560           com.google.cloud.aiplatform.v1.GetHyperparameterTuningJobRequest,
561           com.google.cloud.aiplatform.v1.HyperparameterTuningJob>
getGetHyperparameterTuningJobMethod()562       getGetHyperparameterTuningJobMethod() {
563     io.grpc.MethodDescriptor<
564             com.google.cloud.aiplatform.v1.GetHyperparameterTuningJobRequest,
565             com.google.cloud.aiplatform.v1.HyperparameterTuningJob>
566         getGetHyperparameterTuningJobMethod;
567     if ((getGetHyperparameterTuningJobMethod = JobServiceGrpc.getGetHyperparameterTuningJobMethod)
568         == null) {
569       synchronized (JobServiceGrpc.class) {
570         if ((getGetHyperparameterTuningJobMethod =
571                 JobServiceGrpc.getGetHyperparameterTuningJobMethod)
572             == null) {
573           JobServiceGrpc.getGetHyperparameterTuningJobMethod =
574               getGetHyperparameterTuningJobMethod =
575                   io.grpc.MethodDescriptor
576                       .<com.google.cloud.aiplatform.v1.GetHyperparameterTuningJobRequest,
577                           com.google.cloud.aiplatform.v1.HyperparameterTuningJob>
578                           newBuilder()
579                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
580                       .setFullMethodName(
581                           generateFullMethodName(SERVICE_NAME, "GetHyperparameterTuningJob"))
582                       .setSampledToLocalTracing(true)
583                       .setRequestMarshaller(
584                           io.grpc.protobuf.ProtoUtils.marshaller(
585                               com.google.cloud.aiplatform.v1.GetHyperparameterTuningJobRequest
586                                   .getDefaultInstance()))
587                       .setResponseMarshaller(
588                           io.grpc.protobuf.ProtoUtils.marshaller(
589                               com.google.cloud.aiplatform.v1.HyperparameterTuningJob
590                                   .getDefaultInstance()))
591                       .setSchemaDescriptor(
592                           new JobServiceMethodDescriptorSupplier("GetHyperparameterTuningJob"))
593                       .build();
594         }
595       }
596     }
597     return getGetHyperparameterTuningJobMethod;
598   }
599 
600   private static volatile io.grpc.MethodDescriptor<
601           com.google.cloud.aiplatform.v1.ListHyperparameterTuningJobsRequest,
602           com.google.cloud.aiplatform.v1.ListHyperparameterTuningJobsResponse>
603       getListHyperparameterTuningJobsMethod;
604 
605   @io.grpc.stub.annotations.RpcMethod(
606       fullMethodName = SERVICE_NAME + '/' + "ListHyperparameterTuningJobs",
607       requestType = com.google.cloud.aiplatform.v1.ListHyperparameterTuningJobsRequest.class,
608       responseType = com.google.cloud.aiplatform.v1.ListHyperparameterTuningJobsResponse.class,
609       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
610   public static io.grpc.MethodDescriptor<
611           com.google.cloud.aiplatform.v1.ListHyperparameterTuningJobsRequest,
612           com.google.cloud.aiplatform.v1.ListHyperparameterTuningJobsResponse>
getListHyperparameterTuningJobsMethod()613       getListHyperparameterTuningJobsMethod() {
614     io.grpc.MethodDescriptor<
615             com.google.cloud.aiplatform.v1.ListHyperparameterTuningJobsRequest,
616             com.google.cloud.aiplatform.v1.ListHyperparameterTuningJobsResponse>
617         getListHyperparameterTuningJobsMethod;
618     if ((getListHyperparameterTuningJobsMethod =
619             JobServiceGrpc.getListHyperparameterTuningJobsMethod)
620         == null) {
621       synchronized (JobServiceGrpc.class) {
622         if ((getListHyperparameterTuningJobsMethod =
623                 JobServiceGrpc.getListHyperparameterTuningJobsMethod)
624             == null) {
625           JobServiceGrpc.getListHyperparameterTuningJobsMethod =
626               getListHyperparameterTuningJobsMethod =
627                   io.grpc.MethodDescriptor
628                       .<com.google.cloud.aiplatform.v1.ListHyperparameterTuningJobsRequest,
629                           com.google.cloud.aiplatform.v1.ListHyperparameterTuningJobsResponse>
630                           newBuilder()
631                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
632                       .setFullMethodName(
633                           generateFullMethodName(SERVICE_NAME, "ListHyperparameterTuningJobs"))
634                       .setSampledToLocalTracing(true)
635                       .setRequestMarshaller(
636                           io.grpc.protobuf.ProtoUtils.marshaller(
637                               com.google.cloud.aiplatform.v1.ListHyperparameterTuningJobsRequest
638                                   .getDefaultInstance()))
639                       .setResponseMarshaller(
640                           io.grpc.protobuf.ProtoUtils.marshaller(
641                               com.google.cloud.aiplatform.v1.ListHyperparameterTuningJobsResponse
642                                   .getDefaultInstance()))
643                       .setSchemaDescriptor(
644                           new JobServiceMethodDescriptorSupplier("ListHyperparameterTuningJobs"))
645                       .build();
646         }
647       }
648     }
649     return getListHyperparameterTuningJobsMethod;
650   }
651 
652   private static volatile io.grpc.MethodDescriptor<
653           com.google.cloud.aiplatform.v1.DeleteHyperparameterTuningJobRequest,
654           com.google.longrunning.Operation>
655       getDeleteHyperparameterTuningJobMethod;
656 
657   @io.grpc.stub.annotations.RpcMethod(
658       fullMethodName = SERVICE_NAME + '/' + "DeleteHyperparameterTuningJob",
659       requestType = com.google.cloud.aiplatform.v1.DeleteHyperparameterTuningJobRequest.class,
660       responseType = com.google.longrunning.Operation.class,
661       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
662   public static io.grpc.MethodDescriptor<
663           com.google.cloud.aiplatform.v1.DeleteHyperparameterTuningJobRequest,
664           com.google.longrunning.Operation>
getDeleteHyperparameterTuningJobMethod()665       getDeleteHyperparameterTuningJobMethod() {
666     io.grpc.MethodDescriptor<
667             com.google.cloud.aiplatform.v1.DeleteHyperparameterTuningJobRequest,
668             com.google.longrunning.Operation>
669         getDeleteHyperparameterTuningJobMethod;
670     if ((getDeleteHyperparameterTuningJobMethod =
671             JobServiceGrpc.getDeleteHyperparameterTuningJobMethod)
672         == null) {
673       synchronized (JobServiceGrpc.class) {
674         if ((getDeleteHyperparameterTuningJobMethod =
675                 JobServiceGrpc.getDeleteHyperparameterTuningJobMethod)
676             == null) {
677           JobServiceGrpc.getDeleteHyperparameterTuningJobMethod =
678               getDeleteHyperparameterTuningJobMethod =
679                   io.grpc.MethodDescriptor
680                       .<com.google.cloud.aiplatform.v1.DeleteHyperparameterTuningJobRequest,
681                           com.google.longrunning.Operation>
682                           newBuilder()
683                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
684                       .setFullMethodName(
685                           generateFullMethodName(SERVICE_NAME, "DeleteHyperparameterTuningJob"))
686                       .setSampledToLocalTracing(true)
687                       .setRequestMarshaller(
688                           io.grpc.protobuf.ProtoUtils.marshaller(
689                               com.google.cloud.aiplatform.v1.DeleteHyperparameterTuningJobRequest
690                                   .getDefaultInstance()))
691                       .setResponseMarshaller(
692                           io.grpc.protobuf.ProtoUtils.marshaller(
693                               com.google.longrunning.Operation.getDefaultInstance()))
694                       .setSchemaDescriptor(
695                           new JobServiceMethodDescriptorSupplier("DeleteHyperparameterTuningJob"))
696                       .build();
697         }
698       }
699     }
700     return getDeleteHyperparameterTuningJobMethod;
701   }
702 
703   private static volatile io.grpc.MethodDescriptor<
704           com.google.cloud.aiplatform.v1.CancelHyperparameterTuningJobRequest,
705           com.google.protobuf.Empty>
706       getCancelHyperparameterTuningJobMethod;
707 
708   @io.grpc.stub.annotations.RpcMethod(
709       fullMethodName = SERVICE_NAME + '/' + "CancelHyperparameterTuningJob",
710       requestType = com.google.cloud.aiplatform.v1.CancelHyperparameterTuningJobRequest.class,
711       responseType = com.google.protobuf.Empty.class,
712       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
713   public static io.grpc.MethodDescriptor<
714           com.google.cloud.aiplatform.v1.CancelHyperparameterTuningJobRequest,
715           com.google.protobuf.Empty>
getCancelHyperparameterTuningJobMethod()716       getCancelHyperparameterTuningJobMethod() {
717     io.grpc.MethodDescriptor<
718             com.google.cloud.aiplatform.v1.CancelHyperparameterTuningJobRequest,
719             com.google.protobuf.Empty>
720         getCancelHyperparameterTuningJobMethod;
721     if ((getCancelHyperparameterTuningJobMethod =
722             JobServiceGrpc.getCancelHyperparameterTuningJobMethod)
723         == null) {
724       synchronized (JobServiceGrpc.class) {
725         if ((getCancelHyperparameterTuningJobMethod =
726                 JobServiceGrpc.getCancelHyperparameterTuningJobMethod)
727             == null) {
728           JobServiceGrpc.getCancelHyperparameterTuningJobMethod =
729               getCancelHyperparameterTuningJobMethod =
730                   io.grpc.MethodDescriptor
731                       .<com.google.cloud.aiplatform.v1.CancelHyperparameterTuningJobRequest,
732                           com.google.protobuf.Empty>
733                           newBuilder()
734                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
735                       .setFullMethodName(
736                           generateFullMethodName(SERVICE_NAME, "CancelHyperparameterTuningJob"))
737                       .setSampledToLocalTracing(true)
738                       .setRequestMarshaller(
739                           io.grpc.protobuf.ProtoUtils.marshaller(
740                               com.google.cloud.aiplatform.v1.CancelHyperparameterTuningJobRequest
741                                   .getDefaultInstance()))
742                       .setResponseMarshaller(
743                           io.grpc.protobuf.ProtoUtils.marshaller(
744                               com.google.protobuf.Empty.getDefaultInstance()))
745                       .setSchemaDescriptor(
746                           new JobServiceMethodDescriptorSupplier("CancelHyperparameterTuningJob"))
747                       .build();
748         }
749       }
750     }
751     return getCancelHyperparameterTuningJobMethod;
752   }
753 
754   private static volatile io.grpc.MethodDescriptor<
755           com.google.cloud.aiplatform.v1.CreateNasJobRequest, com.google.cloud.aiplatform.v1.NasJob>
756       getCreateNasJobMethod;
757 
758   @io.grpc.stub.annotations.RpcMethod(
759       fullMethodName = SERVICE_NAME + '/' + "CreateNasJob",
760       requestType = com.google.cloud.aiplatform.v1.CreateNasJobRequest.class,
761       responseType = com.google.cloud.aiplatform.v1.NasJob.class,
762       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
763   public static io.grpc.MethodDescriptor<
764           com.google.cloud.aiplatform.v1.CreateNasJobRequest, com.google.cloud.aiplatform.v1.NasJob>
getCreateNasJobMethod()765       getCreateNasJobMethod() {
766     io.grpc.MethodDescriptor<
767             com.google.cloud.aiplatform.v1.CreateNasJobRequest,
768             com.google.cloud.aiplatform.v1.NasJob>
769         getCreateNasJobMethod;
770     if ((getCreateNasJobMethod = JobServiceGrpc.getCreateNasJobMethod) == null) {
771       synchronized (JobServiceGrpc.class) {
772         if ((getCreateNasJobMethod = JobServiceGrpc.getCreateNasJobMethod) == null) {
773           JobServiceGrpc.getCreateNasJobMethod =
774               getCreateNasJobMethod =
775                   io.grpc.MethodDescriptor
776                       .<com.google.cloud.aiplatform.v1.CreateNasJobRequest,
777                           com.google.cloud.aiplatform.v1.NasJob>
778                           newBuilder()
779                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
780                       .setFullMethodName(generateFullMethodName(SERVICE_NAME, "CreateNasJob"))
781                       .setSampledToLocalTracing(true)
782                       .setRequestMarshaller(
783                           io.grpc.protobuf.ProtoUtils.marshaller(
784                               com.google.cloud.aiplatform.v1.CreateNasJobRequest
785                                   .getDefaultInstance()))
786                       .setResponseMarshaller(
787                           io.grpc.protobuf.ProtoUtils.marshaller(
788                               com.google.cloud.aiplatform.v1.NasJob.getDefaultInstance()))
789                       .setSchemaDescriptor(new JobServiceMethodDescriptorSupplier("CreateNasJob"))
790                       .build();
791         }
792       }
793     }
794     return getCreateNasJobMethod;
795   }
796 
797   private static volatile io.grpc.MethodDescriptor<
798           com.google.cloud.aiplatform.v1.GetNasJobRequest, com.google.cloud.aiplatform.v1.NasJob>
799       getGetNasJobMethod;
800 
801   @io.grpc.stub.annotations.RpcMethod(
802       fullMethodName = SERVICE_NAME + '/' + "GetNasJob",
803       requestType = com.google.cloud.aiplatform.v1.GetNasJobRequest.class,
804       responseType = com.google.cloud.aiplatform.v1.NasJob.class,
805       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
806   public static io.grpc.MethodDescriptor<
807           com.google.cloud.aiplatform.v1.GetNasJobRequest, com.google.cloud.aiplatform.v1.NasJob>
getGetNasJobMethod()808       getGetNasJobMethod() {
809     io.grpc.MethodDescriptor<
810             com.google.cloud.aiplatform.v1.GetNasJobRequest, com.google.cloud.aiplatform.v1.NasJob>
811         getGetNasJobMethod;
812     if ((getGetNasJobMethod = JobServiceGrpc.getGetNasJobMethod) == null) {
813       synchronized (JobServiceGrpc.class) {
814         if ((getGetNasJobMethod = JobServiceGrpc.getGetNasJobMethod) == null) {
815           JobServiceGrpc.getGetNasJobMethod =
816               getGetNasJobMethod =
817                   io.grpc.MethodDescriptor
818                       .<com.google.cloud.aiplatform.v1.GetNasJobRequest,
819                           com.google.cloud.aiplatform.v1.NasJob>
820                           newBuilder()
821                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
822                       .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetNasJob"))
823                       .setSampledToLocalTracing(true)
824                       .setRequestMarshaller(
825                           io.grpc.protobuf.ProtoUtils.marshaller(
826                               com.google.cloud.aiplatform.v1.GetNasJobRequest.getDefaultInstance()))
827                       .setResponseMarshaller(
828                           io.grpc.protobuf.ProtoUtils.marshaller(
829                               com.google.cloud.aiplatform.v1.NasJob.getDefaultInstance()))
830                       .setSchemaDescriptor(new JobServiceMethodDescriptorSupplier("GetNasJob"))
831                       .build();
832         }
833       }
834     }
835     return getGetNasJobMethod;
836   }
837 
838   private static volatile io.grpc.MethodDescriptor<
839           com.google.cloud.aiplatform.v1.ListNasJobsRequest,
840           com.google.cloud.aiplatform.v1.ListNasJobsResponse>
841       getListNasJobsMethod;
842 
843   @io.grpc.stub.annotations.RpcMethod(
844       fullMethodName = SERVICE_NAME + '/' + "ListNasJobs",
845       requestType = com.google.cloud.aiplatform.v1.ListNasJobsRequest.class,
846       responseType = com.google.cloud.aiplatform.v1.ListNasJobsResponse.class,
847       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
848   public static io.grpc.MethodDescriptor<
849           com.google.cloud.aiplatform.v1.ListNasJobsRequest,
850           com.google.cloud.aiplatform.v1.ListNasJobsResponse>
getListNasJobsMethod()851       getListNasJobsMethod() {
852     io.grpc.MethodDescriptor<
853             com.google.cloud.aiplatform.v1.ListNasJobsRequest,
854             com.google.cloud.aiplatform.v1.ListNasJobsResponse>
855         getListNasJobsMethod;
856     if ((getListNasJobsMethod = JobServiceGrpc.getListNasJobsMethod) == null) {
857       synchronized (JobServiceGrpc.class) {
858         if ((getListNasJobsMethod = JobServiceGrpc.getListNasJobsMethod) == null) {
859           JobServiceGrpc.getListNasJobsMethod =
860               getListNasJobsMethod =
861                   io.grpc.MethodDescriptor
862                       .<com.google.cloud.aiplatform.v1.ListNasJobsRequest,
863                           com.google.cloud.aiplatform.v1.ListNasJobsResponse>
864                           newBuilder()
865                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
866                       .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListNasJobs"))
867                       .setSampledToLocalTracing(true)
868                       .setRequestMarshaller(
869                           io.grpc.protobuf.ProtoUtils.marshaller(
870                               com.google.cloud.aiplatform.v1.ListNasJobsRequest
871                                   .getDefaultInstance()))
872                       .setResponseMarshaller(
873                           io.grpc.protobuf.ProtoUtils.marshaller(
874                               com.google.cloud.aiplatform.v1.ListNasJobsResponse
875                                   .getDefaultInstance()))
876                       .setSchemaDescriptor(new JobServiceMethodDescriptorSupplier("ListNasJobs"))
877                       .build();
878         }
879       }
880     }
881     return getListNasJobsMethod;
882   }
883 
884   private static volatile io.grpc.MethodDescriptor<
885           com.google.cloud.aiplatform.v1.DeleteNasJobRequest, com.google.longrunning.Operation>
886       getDeleteNasJobMethod;
887 
888   @io.grpc.stub.annotations.RpcMethod(
889       fullMethodName = SERVICE_NAME + '/' + "DeleteNasJob",
890       requestType = com.google.cloud.aiplatform.v1.DeleteNasJobRequest.class,
891       responseType = com.google.longrunning.Operation.class,
892       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
893   public static io.grpc.MethodDescriptor<
894           com.google.cloud.aiplatform.v1.DeleteNasJobRequest, com.google.longrunning.Operation>
getDeleteNasJobMethod()895       getDeleteNasJobMethod() {
896     io.grpc.MethodDescriptor<
897             com.google.cloud.aiplatform.v1.DeleteNasJobRequest, com.google.longrunning.Operation>
898         getDeleteNasJobMethod;
899     if ((getDeleteNasJobMethod = JobServiceGrpc.getDeleteNasJobMethod) == null) {
900       synchronized (JobServiceGrpc.class) {
901         if ((getDeleteNasJobMethod = JobServiceGrpc.getDeleteNasJobMethod) == null) {
902           JobServiceGrpc.getDeleteNasJobMethod =
903               getDeleteNasJobMethod =
904                   io.grpc.MethodDescriptor
905                       .<com.google.cloud.aiplatform.v1.DeleteNasJobRequest,
906                           com.google.longrunning.Operation>
907                           newBuilder()
908                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
909                       .setFullMethodName(generateFullMethodName(SERVICE_NAME, "DeleteNasJob"))
910                       .setSampledToLocalTracing(true)
911                       .setRequestMarshaller(
912                           io.grpc.protobuf.ProtoUtils.marshaller(
913                               com.google.cloud.aiplatform.v1.DeleteNasJobRequest
914                                   .getDefaultInstance()))
915                       .setResponseMarshaller(
916                           io.grpc.protobuf.ProtoUtils.marshaller(
917                               com.google.longrunning.Operation.getDefaultInstance()))
918                       .setSchemaDescriptor(new JobServiceMethodDescriptorSupplier("DeleteNasJob"))
919                       .build();
920         }
921       }
922     }
923     return getDeleteNasJobMethod;
924   }
925 
926   private static volatile io.grpc.MethodDescriptor<
927           com.google.cloud.aiplatform.v1.CancelNasJobRequest, com.google.protobuf.Empty>
928       getCancelNasJobMethod;
929 
930   @io.grpc.stub.annotations.RpcMethod(
931       fullMethodName = SERVICE_NAME + '/' + "CancelNasJob",
932       requestType = com.google.cloud.aiplatform.v1.CancelNasJobRequest.class,
933       responseType = com.google.protobuf.Empty.class,
934       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
935   public static io.grpc.MethodDescriptor<
936           com.google.cloud.aiplatform.v1.CancelNasJobRequest, com.google.protobuf.Empty>
getCancelNasJobMethod()937       getCancelNasJobMethod() {
938     io.grpc.MethodDescriptor<
939             com.google.cloud.aiplatform.v1.CancelNasJobRequest, com.google.protobuf.Empty>
940         getCancelNasJobMethod;
941     if ((getCancelNasJobMethod = JobServiceGrpc.getCancelNasJobMethod) == null) {
942       synchronized (JobServiceGrpc.class) {
943         if ((getCancelNasJobMethod = JobServiceGrpc.getCancelNasJobMethod) == null) {
944           JobServiceGrpc.getCancelNasJobMethod =
945               getCancelNasJobMethod =
946                   io.grpc.MethodDescriptor
947                       .<com.google.cloud.aiplatform.v1.CancelNasJobRequest,
948                           com.google.protobuf.Empty>
949                           newBuilder()
950                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
951                       .setFullMethodName(generateFullMethodName(SERVICE_NAME, "CancelNasJob"))
952                       .setSampledToLocalTracing(true)
953                       .setRequestMarshaller(
954                           io.grpc.protobuf.ProtoUtils.marshaller(
955                               com.google.cloud.aiplatform.v1.CancelNasJobRequest
956                                   .getDefaultInstance()))
957                       .setResponseMarshaller(
958                           io.grpc.protobuf.ProtoUtils.marshaller(
959                               com.google.protobuf.Empty.getDefaultInstance()))
960                       .setSchemaDescriptor(new JobServiceMethodDescriptorSupplier("CancelNasJob"))
961                       .build();
962         }
963       }
964     }
965     return getCancelNasJobMethod;
966   }
967 
968   private static volatile io.grpc.MethodDescriptor<
969           com.google.cloud.aiplatform.v1.GetNasTrialDetailRequest,
970           com.google.cloud.aiplatform.v1.NasTrialDetail>
971       getGetNasTrialDetailMethod;
972 
973   @io.grpc.stub.annotations.RpcMethod(
974       fullMethodName = SERVICE_NAME + '/' + "GetNasTrialDetail",
975       requestType = com.google.cloud.aiplatform.v1.GetNasTrialDetailRequest.class,
976       responseType = com.google.cloud.aiplatform.v1.NasTrialDetail.class,
977       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
978   public static io.grpc.MethodDescriptor<
979           com.google.cloud.aiplatform.v1.GetNasTrialDetailRequest,
980           com.google.cloud.aiplatform.v1.NasTrialDetail>
getGetNasTrialDetailMethod()981       getGetNasTrialDetailMethod() {
982     io.grpc.MethodDescriptor<
983             com.google.cloud.aiplatform.v1.GetNasTrialDetailRequest,
984             com.google.cloud.aiplatform.v1.NasTrialDetail>
985         getGetNasTrialDetailMethod;
986     if ((getGetNasTrialDetailMethod = JobServiceGrpc.getGetNasTrialDetailMethod) == null) {
987       synchronized (JobServiceGrpc.class) {
988         if ((getGetNasTrialDetailMethod = JobServiceGrpc.getGetNasTrialDetailMethod) == null) {
989           JobServiceGrpc.getGetNasTrialDetailMethod =
990               getGetNasTrialDetailMethod =
991                   io.grpc.MethodDescriptor
992                       .<com.google.cloud.aiplatform.v1.GetNasTrialDetailRequest,
993                           com.google.cloud.aiplatform.v1.NasTrialDetail>
994                           newBuilder()
995                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
996                       .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetNasTrialDetail"))
997                       .setSampledToLocalTracing(true)
998                       .setRequestMarshaller(
999                           io.grpc.protobuf.ProtoUtils.marshaller(
1000                               com.google.cloud.aiplatform.v1.GetNasTrialDetailRequest
1001                                   .getDefaultInstance()))
1002                       .setResponseMarshaller(
1003                           io.grpc.protobuf.ProtoUtils.marshaller(
1004                               com.google.cloud.aiplatform.v1.NasTrialDetail.getDefaultInstance()))
1005                       .setSchemaDescriptor(
1006                           new JobServiceMethodDescriptorSupplier("GetNasTrialDetail"))
1007                       .build();
1008         }
1009       }
1010     }
1011     return getGetNasTrialDetailMethod;
1012   }
1013 
1014   private static volatile io.grpc.MethodDescriptor<
1015           com.google.cloud.aiplatform.v1.ListNasTrialDetailsRequest,
1016           com.google.cloud.aiplatform.v1.ListNasTrialDetailsResponse>
1017       getListNasTrialDetailsMethod;
1018 
1019   @io.grpc.stub.annotations.RpcMethod(
1020       fullMethodName = SERVICE_NAME + '/' + "ListNasTrialDetails",
1021       requestType = com.google.cloud.aiplatform.v1.ListNasTrialDetailsRequest.class,
1022       responseType = com.google.cloud.aiplatform.v1.ListNasTrialDetailsResponse.class,
1023       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
1024   public static io.grpc.MethodDescriptor<
1025           com.google.cloud.aiplatform.v1.ListNasTrialDetailsRequest,
1026           com.google.cloud.aiplatform.v1.ListNasTrialDetailsResponse>
getListNasTrialDetailsMethod()1027       getListNasTrialDetailsMethod() {
1028     io.grpc.MethodDescriptor<
1029             com.google.cloud.aiplatform.v1.ListNasTrialDetailsRequest,
1030             com.google.cloud.aiplatform.v1.ListNasTrialDetailsResponse>
1031         getListNasTrialDetailsMethod;
1032     if ((getListNasTrialDetailsMethod = JobServiceGrpc.getListNasTrialDetailsMethod) == null) {
1033       synchronized (JobServiceGrpc.class) {
1034         if ((getListNasTrialDetailsMethod = JobServiceGrpc.getListNasTrialDetailsMethod) == null) {
1035           JobServiceGrpc.getListNasTrialDetailsMethod =
1036               getListNasTrialDetailsMethod =
1037                   io.grpc.MethodDescriptor
1038                       .<com.google.cloud.aiplatform.v1.ListNasTrialDetailsRequest,
1039                           com.google.cloud.aiplatform.v1.ListNasTrialDetailsResponse>
1040                           newBuilder()
1041                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
1042                       .setFullMethodName(
1043                           generateFullMethodName(SERVICE_NAME, "ListNasTrialDetails"))
1044                       .setSampledToLocalTracing(true)
1045                       .setRequestMarshaller(
1046                           io.grpc.protobuf.ProtoUtils.marshaller(
1047                               com.google.cloud.aiplatform.v1.ListNasTrialDetailsRequest
1048                                   .getDefaultInstance()))
1049                       .setResponseMarshaller(
1050                           io.grpc.protobuf.ProtoUtils.marshaller(
1051                               com.google.cloud.aiplatform.v1.ListNasTrialDetailsResponse
1052                                   .getDefaultInstance()))
1053                       .setSchemaDescriptor(
1054                           new JobServiceMethodDescriptorSupplier("ListNasTrialDetails"))
1055                       .build();
1056         }
1057       }
1058     }
1059     return getListNasTrialDetailsMethod;
1060   }
1061 
1062   private static volatile io.grpc.MethodDescriptor<
1063           com.google.cloud.aiplatform.v1.CreateBatchPredictionJobRequest,
1064           com.google.cloud.aiplatform.v1.BatchPredictionJob>
1065       getCreateBatchPredictionJobMethod;
1066 
1067   @io.grpc.stub.annotations.RpcMethod(
1068       fullMethodName = SERVICE_NAME + '/' + "CreateBatchPredictionJob",
1069       requestType = com.google.cloud.aiplatform.v1.CreateBatchPredictionJobRequest.class,
1070       responseType = com.google.cloud.aiplatform.v1.BatchPredictionJob.class,
1071       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
1072   public static io.grpc.MethodDescriptor<
1073           com.google.cloud.aiplatform.v1.CreateBatchPredictionJobRequest,
1074           com.google.cloud.aiplatform.v1.BatchPredictionJob>
getCreateBatchPredictionJobMethod()1075       getCreateBatchPredictionJobMethod() {
1076     io.grpc.MethodDescriptor<
1077             com.google.cloud.aiplatform.v1.CreateBatchPredictionJobRequest,
1078             com.google.cloud.aiplatform.v1.BatchPredictionJob>
1079         getCreateBatchPredictionJobMethod;
1080     if ((getCreateBatchPredictionJobMethod = JobServiceGrpc.getCreateBatchPredictionJobMethod)
1081         == null) {
1082       synchronized (JobServiceGrpc.class) {
1083         if ((getCreateBatchPredictionJobMethod = JobServiceGrpc.getCreateBatchPredictionJobMethod)
1084             == null) {
1085           JobServiceGrpc.getCreateBatchPredictionJobMethod =
1086               getCreateBatchPredictionJobMethod =
1087                   io.grpc.MethodDescriptor
1088                       .<com.google.cloud.aiplatform.v1.CreateBatchPredictionJobRequest,
1089                           com.google.cloud.aiplatform.v1.BatchPredictionJob>
1090                           newBuilder()
1091                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
1092                       .setFullMethodName(
1093                           generateFullMethodName(SERVICE_NAME, "CreateBatchPredictionJob"))
1094                       .setSampledToLocalTracing(true)
1095                       .setRequestMarshaller(
1096                           io.grpc.protobuf.ProtoUtils.marshaller(
1097                               com.google.cloud.aiplatform.v1.CreateBatchPredictionJobRequest
1098                                   .getDefaultInstance()))
1099                       .setResponseMarshaller(
1100                           io.grpc.protobuf.ProtoUtils.marshaller(
1101                               com.google.cloud.aiplatform.v1.BatchPredictionJob
1102                                   .getDefaultInstance()))
1103                       .setSchemaDescriptor(
1104                           new JobServiceMethodDescriptorSupplier("CreateBatchPredictionJob"))
1105                       .build();
1106         }
1107       }
1108     }
1109     return getCreateBatchPredictionJobMethod;
1110   }
1111 
1112   private static volatile io.grpc.MethodDescriptor<
1113           com.google.cloud.aiplatform.v1.GetBatchPredictionJobRequest,
1114           com.google.cloud.aiplatform.v1.BatchPredictionJob>
1115       getGetBatchPredictionJobMethod;
1116 
1117   @io.grpc.stub.annotations.RpcMethod(
1118       fullMethodName = SERVICE_NAME + '/' + "GetBatchPredictionJob",
1119       requestType = com.google.cloud.aiplatform.v1.GetBatchPredictionJobRequest.class,
1120       responseType = com.google.cloud.aiplatform.v1.BatchPredictionJob.class,
1121       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
1122   public static io.grpc.MethodDescriptor<
1123           com.google.cloud.aiplatform.v1.GetBatchPredictionJobRequest,
1124           com.google.cloud.aiplatform.v1.BatchPredictionJob>
getGetBatchPredictionJobMethod()1125       getGetBatchPredictionJobMethod() {
1126     io.grpc.MethodDescriptor<
1127             com.google.cloud.aiplatform.v1.GetBatchPredictionJobRequest,
1128             com.google.cloud.aiplatform.v1.BatchPredictionJob>
1129         getGetBatchPredictionJobMethod;
1130     if ((getGetBatchPredictionJobMethod = JobServiceGrpc.getGetBatchPredictionJobMethod) == null) {
1131       synchronized (JobServiceGrpc.class) {
1132         if ((getGetBatchPredictionJobMethod = JobServiceGrpc.getGetBatchPredictionJobMethod)
1133             == null) {
1134           JobServiceGrpc.getGetBatchPredictionJobMethod =
1135               getGetBatchPredictionJobMethod =
1136                   io.grpc.MethodDescriptor
1137                       .<com.google.cloud.aiplatform.v1.GetBatchPredictionJobRequest,
1138                           com.google.cloud.aiplatform.v1.BatchPredictionJob>
1139                           newBuilder()
1140                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
1141                       .setFullMethodName(
1142                           generateFullMethodName(SERVICE_NAME, "GetBatchPredictionJob"))
1143                       .setSampledToLocalTracing(true)
1144                       .setRequestMarshaller(
1145                           io.grpc.protobuf.ProtoUtils.marshaller(
1146                               com.google.cloud.aiplatform.v1.GetBatchPredictionJobRequest
1147                                   .getDefaultInstance()))
1148                       .setResponseMarshaller(
1149                           io.grpc.protobuf.ProtoUtils.marshaller(
1150                               com.google.cloud.aiplatform.v1.BatchPredictionJob
1151                                   .getDefaultInstance()))
1152                       .setSchemaDescriptor(
1153                           new JobServiceMethodDescriptorSupplier("GetBatchPredictionJob"))
1154                       .build();
1155         }
1156       }
1157     }
1158     return getGetBatchPredictionJobMethod;
1159   }
1160 
1161   private static volatile io.grpc.MethodDescriptor<
1162           com.google.cloud.aiplatform.v1.ListBatchPredictionJobsRequest,
1163           com.google.cloud.aiplatform.v1.ListBatchPredictionJobsResponse>
1164       getListBatchPredictionJobsMethod;
1165 
1166   @io.grpc.stub.annotations.RpcMethod(
1167       fullMethodName = SERVICE_NAME + '/' + "ListBatchPredictionJobs",
1168       requestType = com.google.cloud.aiplatform.v1.ListBatchPredictionJobsRequest.class,
1169       responseType = com.google.cloud.aiplatform.v1.ListBatchPredictionJobsResponse.class,
1170       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
1171   public static io.grpc.MethodDescriptor<
1172           com.google.cloud.aiplatform.v1.ListBatchPredictionJobsRequest,
1173           com.google.cloud.aiplatform.v1.ListBatchPredictionJobsResponse>
getListBatchPredictionJobsMethod()1174       getListBatchPredictionJobsMethod() {
1175     io.grpc.MethodDescriptor<
1176             com.google.cloud.aiplatform.v1.ListBatchPredictionJobsRequest,
1177             com.google.cloud.aiplatform.v1.ListBatchPredictionJobsResponse>
1178         getListBatchPredictionJobsMethod;
1179     if ((getListBatchPredictionJobsMethod = JobServiceGrpc.getListBatchPredictionJobsMethod)
1180         == null) {
1181       synchronized (JobServiceGrpc.class) {
1182         if ((getListBatchPredictionJobsMethod = JobServiceGrpc.getListBatchPredictionJobsMethod)
1183             == null) {
1184           JobServiceGrpc.getListBatchPredictionJobsMethod =
1185               getListBatchPredictionJobsMethod =
1186                   io.grpc.MethodDescriptor
1187                       .<com.google.cloud.aiplatform.v1.ListBatchPredictionJobsRequest,
1188                           com.google.cloud.aiplatform.v1.ListBatchPredictionJobsResponse>
1189                           newBuilder()
1190                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
1191                       .setFullMethodName(
1192                           generateFullMethodName(SERVICE_NAME, "ListBatchPredictionJobs"))
1193                       .setSampledToLocalTracing(true)
1194                       .setRequestMarshaller(
1195                           io.grpc.protobuf.ProtoUtils.marshaller(
1196                               com.google.cloud.aiplatform.v1.ListBatchPredictionJobsRequest
1197                                   .getDefaultInstance()))
1198                       .setResponseMarshaller(
1199                           io.grpc.protobuf.ProtoUtils.marshaller(
1200                               com.google.cloud.aiplatform.v1.ListBatchPredictionJobsResponse
1201                                   .getDefaultInstance()))
1202                       .setSchemaDescriptor(
1203                           new JobServiceMethodDescriptorSupplier("ListBatchPredictionJobs"))
1204                       .build();
1205         }
1206       }
1207     }
1208     return getListBatchPredictionJobsMethod;
1209   }
1210 
1211   private static volatile io.grpc.MethodDescriptor<
1212           com.google.cloud.aiplatform.v1.DeleteBatchPredictionJobRequest,
1213           com.google.longrunning.Operation>
1214       getDeleteBatchPredictionJobMethod;
1215 
1216   @io.grpc.stub.annotations.RpcMethod(
1217       fullMethodName = SERVICE_NAME + '/' + "DeleteBatchPredictionJob",
1218       requestType = com.google.cloud.aiplatform.v1.DeleteBatchPredictionJobRequest.class,
1219       responseType = com.google.longrunning.Operation.class,
1220       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
1221   public static io.grpc.MethodDescriptor<
1222           com.google.cloud.aiplatform.v1.DeleteBatchPredictionJobRequest,
1223           com.google.longrunning.Operation>
getDeleteBatchPredictionJobMethod()1224       getDeleteBatchPredictionJobMethod() {
1225     io.grpc.MethodDescriptor<
1226             com.google.cloud.aiplatform.v1.DeleteBatchPredictionJobRequest,
1227             com.google.longrunning.Operation>
1228         getDeleteBatchPredictionJobMethod;
1229     if ((getDeleteBatchPredictionJobMethod = JobServiceGrpc.getDeleteBatchPredictionJobMethod)
1230         == null) {
1231       synchronized (JobServiceGrpc.class) {
1232         if ((getDeleteBatchPredictionJobMethod = JobServiceGrpc.getDeleteBatchPredictionJobMethod)
1233             == null) {
1234           JobServiceGrpc.getDeleteBatchPredictionJobMethod =
1235               getDeleteBatchPredictionJobMethod =
1236                   io.grpc.MethodDescriptor
1237                       .<com.google.cloud.aiplatform.v1.DeleteBatchPredictionJobRequest,
1238                           com.google.longrunning.Operation>
1239                           newBuilder()
1240                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
1241                       .setFullMethodName(
1242                           generateFullMethodName(SERVICE_NAME, "DeleteBatchPredictionJob"))
1243                       .setSampledToLocalTracing(true)
1244                       .setRequestMarshaller(
1245                           io.grpc.protobuf.ProtoUtils.marshaller(
1246                               com.google.cloud.aiplatform.v1.DeleteBatchPredictionJobRequest
1247                                   .getDefaultInstance()))
1248                       .setResponseMarshaller(
1249                           io.grpc.protobuf.ProtoUtils.marshaller(
1250                               com.google.longrunning.Operation.getDefaultInstance()))
1251                       .setSchemaDescriptor(
1252                           new JobServiceMethodDescriptorSupplier("DeleteBatchPredictionJob"))
1253                       .build();
1254         }
1255       }
1256     }
1257     return getDeleteBatchPredictionJobMethod;
1258   }
1259 
1260   private static volatile io.grpc.MethodDescriptor<
1261           com.google.cloud.aiplatform.v1.CancelBatchPredictionJobRequest, com.google.protobuf.Empty>
1262       getCancelBatchPredictionJobMethod;
1263 
1264   @io.grpc.stub.annotations.RpcMethod(
1265       fullMethodName = SERVICE_NAME + '/' + "CancelBatchPredictionJob",
1266       requestType = com.google.cloud.aiplatform.v1.CancelBatchPredictionJobRequest.class,
1267       responseType = com.google.protobuf.Empty.class,
1268       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
1269   public static io.grpc.MethodDescriptor<
1270           com.google.cloud.aiplatform.v1.CancelBatchPredictionJobRequest, com.google.protobuf.Empty>
getCancelBatchPredictionJobMethod()1271       getCancelBatchPredictionJobMethod() {
1272     io.grpc.MethodDescriptor<
1273             com.google.cloud.aiplatform.v1.CancelBatchPredictionJobRequest,
1274             com.google.protobuf.Empty>
1275         getCancelBatchPredictionJobMethod;
1276     if ((getCancelBatchPredictionJobMethod = JobServiceGrpc.getCancelBatchPredictionJobMethod)
1277         == null) {
1278       synchronized (JobServiceGrpc.class) {
1279         if ((getCancelBatchPredictionJobMethod = JobServiceGrpc.getCancelBatchPredictionJobMethod)
1280             == null) {
1281           JobServiceGrpc.getCancelBatchPredictionJobMethod =
1282               getCancelBatchPredictionJobMethod =
1283                   io.grpc.MethodDescriptor
1284                       .<com.google.cloud.aiplatform.v1.CancelBatchPredictionJobRequest,
1285                           com.google.protobuf.Empty>
1286                           newBuilder()
1287                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
1288                       .setFullMethodName(
1289                           generateFullMethodName(SERVICE_NAME, "CancelBatchPredictionJob"))
1290                       .setSampledToLocalTracing(true)
1291                       .setRequestMarshaller(
1292                           io.grpc.protobuf.ProtoUtils.marshaller(
1293                               com.google.cloud.aiplatform.v1.CancelBatchPredictionJobRequest
1294                                   .getDefaultInstance()))
1295                       .setResponseMarshaller(
1296                           io.grpc.protobuf.ProtoUtils.marshaller(
1297                               com.google.protobuf.Empty.getDefaultInstance()))
1298                       .setSchemaDescriptor(
1299                           new JobServiceMethodDescriptorSupplier("CancelBatchPredictionJob"))
1300                       .build();
1301         }
1302       }
1303     }
1304     return getCancelBatchPredictionJobMethod;
1305   }
1306 
1307   private static volatile io.grpc.MethodDescriptor<
1308           com.google.cloud.aiplatform.v1.CreateModelDeploymentMonitoringJobRequest,
1309           com.google.cloud.aiplatform.v1.ModelDeploymentMonitoringJob>
1310       getCreateModelDeploymentMonitoringJobMethod;
1311 
1312   @io.grpc.stub.annotations.RpcMethod(
1313       fullMethodName = SERVICE_NAME + '/' + "CreateModelDeploymentMonitoringJob",
1314       requestType = com.google.cloud.aiplatform.v1.CreateModelDeploymentMonitoringJobRequest.class,
1315       responseType = com.google.cloud.aiplatform.v1.ModelDeploymentMonitoringJob.class,
1316       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
1317   public static io.grpc.MethodDescriptor<
1318           com.google.cloud.aiplatform.v1.CreateModelDeploymentMonitoringJobRequest,
1319           com.google.cloud.aiplatform.v1.ModelDeploymentMonitoringJob>
getCreateModelDeploymentMonitoringJobMethod()1320       getCreateModelDeploymentMonitoringJobMethod() {
1321     io.grpc.MethodDescriptor<
1322             com.google.cloud.aiplatform.v1.CreateModelDeploymentMonitoringJobRequest,
1323             com.google.cloud.aiplatform.v1.ModelDeploymentMonitoringJob>
1324         getCreateModelDeploymentMonitoringJobMethod;
1325     if ((getCreateModelDeploymentMonitoringJobMethod =
1326             JobServiceGrpc.getCreateModelDeploymentMonitoringJobMethod)
1327         == null) {
1328       synchronized (JobServiceGrpc.class) {
1329         if ((getCreateModelDeploymentMonitoringJobMethod =
1330                 JobServiceGrpc.getCreateModelDeploymentMonitoringJobMethod)
1331             == null) {
1332           JobServiceGrpc.getCreateModelDeploymentMonitoringJobMethod =
1333               getCreateModelDeploymentMonitoringJobMethod =
1334                   io.grpc.MethodDescriptor
1335                       .<com.google.cloud.aiplatform.v1.CreateModelDeploymentMonitoringJobRequest,
1336                           com.google.cloud.aiplatform.v1.ModelDeploymentMonitoringJob>
1337                           newBuilder()
1338                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
1339                       .setFullMethodName(
1340                           generateFullMethodName(
1341                               SERVICE_NAME, "CreateModelDeploymentMonitoringJob"))
1342                       .setSampledToLocalTracing(true)
1343                       .setRequestMarshaller(
1344                           io.grpc.protobuf.ProtoUtils.marshaller(
1345                               com.google.cloud.aiplatform.v1
1346                                   .CreateModelDeploymentMonitoringJobRequest.getDefaultInstance()))
1347                       .setResponseMarshaller(
1348                           io.grpc.protobuf.ProtoUtils.marshaller(
1349                               com.google.cloud.aiplatform.v1.ModelDeploymentMonitoringJob
1350                                   .getDefaultInstance()))
1351                       .setSchemaDescriptor(
1352                           new JobServiceMethodDescriptorSupplier(
1353                               "CreateModelDeploymentMonitoringJob"))
1354                       .build();
1355         }
1356       }
1357     }
1358     return getCreateModelDeploymentMonitoringJobMethod;
1359   }
1360 
1361   private static volatile io.grpc.MethodDescriptor<
1362           com.google.cloud.aiplatform.v1.SearchModelDeploymentMonitoringStatsAnomaliesRequest,
1363           com.google.cloud.aiplatform.v1.SearchModelDeploymentMonitoringStatsAnomaliesResponse>
1364       getSearchModelDeploymentMonitoringStatsAnomaliesMethod;
1365 
1366   @io.grpc.stub.annotations.RpcMethod(
1367       fullMethodName = SERVICE_NAME + '/' + "SearchModelDeploymentMonitoringStatsAnomalies",
1368       requestType =
1369           com.google.cloud.aiplatform.v1.SearchModelDeploymentMonitoringStatsAnomaliesRequest.class,
1370       responseType =
1371           com.google.cloud.aiplatform.v1.SearchModelDeploymentMonitoringStatsAnomaliesResponse
1372               .class,
1373       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
1374   public static io.grpc.MethodDescriptor<
1375           com.google.cloud.aiplatform.v1.SearchModelDeploymentMonitoringStatsAnomaliesRequest,
1376           com.google.cloud.aiplatform.v1.SearchModelDeploymentMonitoringStatsAnomaliesResponse>
getSearchModelDeploymentMonitoringStatsAnomaliesMethod()1377       getSearchModelDeploymentMonitoringStatsAnomaliesMethod() {
1378     io.grpc.MethodDescriptor<
1379             com.google.cloud.aiplatform.v1.SearchModelDeploymentMonitoringStatsAnomaliesRequest,
1380             com.google.cloud.aiplatform.v1.SearchModelDeploymentMonitoringStatsAnomaliesResponse>
1381         getSearchModelDeploymentMonitoringStatsAnomaliesMethod;
1382     if ((getSearchModelDeploymentMonitoringStatsAnomaliesMethod =
1383             JobServiceGrpc.getSearchModelDeploymentMonitoringStatsAnomaliesMethod)
1384         == null) {
1385       synchronized (JobServiceGrpc.class) {
1386         if ((getSearchModelDeploymentMonitoringStatsAnomaliesMethod =
1387                 JobServiceGrpc.getSearchModelDeploymentMonitoringStatsAnomaliesMethod)
1388             == null) {
1389           JobServiceGrpc.getSearchModelDeploymentMonitoringStatsAnomaliesMethod =
1390               getSearchModelDeploymentMonitoringStatsAnomaliesMethod =
1391                   io.grpc.MethodDescriptor
1392                       .<com.google.cloud.aiplatform.v1
1393                               .SearchModelDeploymentMonitoringStatsAnomaliesRequest,
1394                           com.google.cloud.aiplatform.v1
1395                               .SearchModelDeploymentMonitoringStatsAnomaliesResponse>
1396                           newBuilder()
1397                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
1398                       .setFullMethodName(
1399                           generateFullMethodName(
1400                               SERVICE_NAME, "SearchModelDeploymentMonitoringStatsAnomalies"))
1401                       .setSampledToLocalTracing(true)
1402                       .setRequestMarshaller(
1403                           io.grpc.protobuf.ProtoUtils.marshaller(
1404                               com.google.cloud.aiplatform.v1
1405                                   .SearchModelDeploymentMonitoringStatsAnomaliesRequest
1406                                   .getDefaultInstance()))
1407                       .setResponseMarshaller(
1408                           io.grpc.protobuf.ProtoUtils.marshaller(
1409                               com.google.cloud.aiplatform.v1
1410                                   .SearchModelDeploymentMonitoringStatsAnomaliesResponse
1411                                   .getDefaultInstance()))
1412                       .setSchemaDescriptor(
1413                           new JobServiceMethodDescriptorSupplier(
1414                               "SearchModelDeploymentMonitoringStatsAnomalies"))
1415                       .build();
1416         }
1417       }
1418     }
1419     return getSearchModelDeploymentMonitoringStatsAnomaliesMethod;
1420   }
1421 
1422   private static volatile io.grpc.MethodDescriptor<
1423           com.google.cloud.aiplatform.v1.GetModelDeploymentMonitoringJobRequest,
1424           com.google.cloud.aiplatform.v1.ModelDeploymentMonitoringJob>
1425       getGetModelDeploymentMonitoringJobMethod;
1426 
1427   @io.grpc.stub.annotations.RpcMethod(
1428       fullMethodName = SERVICE_NAME + '/' + "GetModelDeploymentMonitoringJob",
1429       requestType = com.google.cloud.aiplatform.v1.GetModelDeploymentMonitoringJobRequest.class,
1430       responseType = com.google.cloud.aiplatform.v1.ModelDeploymentMonitoringJob.class,
1431       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
1432   public static io.grpc.MethodDescriptor<
1433           com.google.cloud.aiplatform.v1.GetModelDeploymentMonitoringJobRequest,
1434           com.google.cloud.aiplatform.v1.ModelDeploymentMonitoringJob>
getGetModelDeploymentMonitoringJobMethod()1435       getGetModelDeploymentMonitoringJobMethod() {
1436     io.grpc.MethodDescriptor<
1437             com.google.cloud.aiplatform.v1.GetModelDeploymentMonitoringJobRequest,
1438             com.google.cloud.aiplatform.v1.ModelDeploymentMonitoringJob>
1439         getGetModelDeploymentMonitoringJobMethod;
1440     if ((getGetModelDeploymentMonitoringJobMethod =
1441             JobServiceGrpc.getGetModelDeploymentMonitoringJobMethod)
1442         == null) {
1443       synchronized (JobServiceGrpc.class) {
1444         if ((getGetModelDeploymentMonitoringJobMethod =
1445                 JobServiceGrpc.getGetModelDeploymentMonitoringJobMethod)
1446             == null) {
1447           JobServiceGrpc.getGetModelDeploymentMonitoringJobMethod =
1448               getGetModelDeploymentMonitoringJobMethod =
1449                   io.grpc.MethodDescriptor
1450                       .<com.google.cloud.aiplatform.v1.GetModelDeploymentMonitoringJobRequest,
1451                           com.google.cloud.aiplatform.v1.ModelDeploymentMonitoringJob>
1452                           newBuilder()
1453                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
1454                       .setFullMethodName(
1455                           generateFullMethodName(SERVICE_NAME, "GetModelDeploymentMonitoringJob"))
1456                       .setSampledToLocalTracing(true)
1457                       .setRequestMarshaller(
1458                           io.grpc.protobuf.ProtoUtils.marshaller(
1459                               com.google.cloud.aiplatform.v1.GetModelDeploymentMonitoringJobRequest
1460                                   .getDefaultInstance()))
1461                       .setResponseMarshaller(
1462                           io.grpc.protobuf.ProtoUtils.marshaller(
1463                               com.google.cloud.aiplatform.v1.ModelDeploymentMonitoringJob
1464                                   .getDefaultInstance()))
1465                       .setSchemaDescriptor(
1466                           new JobServiceMethodDescriptorSupplier("GetModelDeploymentMonitoringJob"))
1467                       .build();
1468         }
1469       }
1470     }
1471     return getGetModelDeploymentMonitoringJobMethod;
1472   }
1473 
1474   private static volatile io.grpc.MethodDescriptor<
1475           com.google.cloud.aiplatform.v1.ListModelDeploymentMonitoringJobsRequest,
1476           com.google.cloud.aiplatform.v1.ListModelDeploymentMonitoringJobsResponse>
1477       getListModelDeploymentMonitoringJobsMethod;
1478 
1479   @io.grpc.stub.annotations.RpcMethod(
1480       fullMethodName = SERVICE_NAME + '/' + "ListModelDeploymentMonitoringJobs",
1481       requestType = com.google.cloud.aiplatform.v1.ListModelDeploymentMonitoringJobsRequest.class,
1482       responseType = com.google.cloud.aiplatform.v1.ListModelDeploymentMonitoringJobsResponse.class,
1483       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
1484   public static io.grpc.MethodDescriptor<
1485           com.google.cloud.aiplatform.v1.ListModelDeploymentMonitoringJobsRequest,
1486           com.google.cloud.aiplatform.v1.ListModelDeploymentMonitoringJobsResponse>
getListModelDeploymentMonitoringJobsMethod()1487       getListModelDeploymentMonitoringJobsMethod() {
1488     io.grpc.MethodDescriptor<
1489             com.google.cloud.aiplatform.v1.ListModelDeploymentMonitoringJobsRequest,
1490             com.google.cloud.aiplatform.v1.ListModelDeploymentMonitoringJobsResponse>
1491         getListModelDeploymentMonitoringJobsMethod;
1492     if ((getListModelDeploymentMonitoringJobsMethod =
1493             JobServiceGrpc.getListModelDeploymentMonitoringJobsMethod)
1494         == null) {
1495       synchronized (JobServiceGrpc.class) {
1496         if ((getListModelDeploymentMonitoringJobsMethod =
1497                 JobServiceGrpc.getListModelDeploymentMonitoringJobsMethod)
1498             == null) {
1499           JobServiceGrpc.getListModelDeploymentMonitoringJobsMethod =
1500               getListModelDeploymentMonitoringJobsMethod =
1501                   io.grpc.MethodDescriptor
1502                       .<com.google.cloud.aiplatform.v1.ListModelDeploymentMonitoringJobsRequest,
1503                           com.google.cloud.aiplatform.v1.ListModelDeploymentMonitoringJobsResponse>
1504                           newBuilder()
1505                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
1506                       .setFullMethodName(
1507                           generateFullMethodName(SERVICE_NAME, "ListModelDeploymentMonitoringJobs"))
1508                       .setSampledToLocalTracing(true)
1509                       .setRequestMarshaller(
1510                           io.grpc.protobuf.ProtoUtils.marshaller(
1511                               com.google.cloud.aiplatform.v1
1512                                   .ListModelDeploymentMonitoringJobsRequest.getDefaultInstance()))
1513                       .setResponseMarshaller(
1514                           io.grpc.protobuf.ProtoUtils.marshaller(
1515                               com.google.cloud.aiplatform.v1
1516                                   .ListModelDeploymentMonitoringJobsResponse.getDefaultInstance()))
1517                       .setSchemaDescriptor(
1518                           new JobServiceMethodDescriptorSupplier(
1519                               "ListModelDeploymentMonitoringJobs"))
1520                       .build();
1521         }
1522       }
1523     }
1524     return getListModelDeploymentMonitoringJobsMethod;
1525   }
1526 
1527   private static volatile io.grpc.MethodDescriptor<
1528           com.google.cloud.aiplatform.v1.UpdateModelDeploymentMonitoringJobRequest,
1529           com.google.longrunning.Operation>
1530       getUpdateModelDeploymentMonitoringJobMethod;
1531 
1532   @io.grpc.stub.annotations.RpcMethod(
1533       fullMethodName = SERVICE_NAME + '/' + "UpdateModelDeploymentMonitoringJob",
1534       requestType = com.google.cloud.aiplatform.v1.UpdateModelDeploymentMonitoringJobRequest.class,
1535       responseType = com.google.longrunning.Operation.class,
1536       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
1537   public static io.grpc.MethodDescriptor<
1538           com.google.cloud.aiplatform.v1.UpdateModelDeploymentMonitoringJobRequest,
1539           com.google.longrunning.Operation>
getUpdateModelDeploymentMonitoringJobMethod()1540       getUpdateModelDeploymentMonitoringJobMethod() {
1541     io.grpc.MethodDescriptor<
1542             com.google.cloud.aiplatform.v1.UpdateModelDeploymentMonitoringJobRequest,
1543             com.google.longrunning.Operation>
1544         getUpdateModelDeploymentMonitoringJobMethod;
1545     if ((getUpdateModelDeploymentMonitoringJobMethod =
1546             JobServiceGrpc.getUpdateModelDeploymentMonitoringJobMethod)
1547         == null) {
1548       synchronized (JobServiceGrpc.class) {
1549         if ((getUpdateModelDeploymentMonitoringJobMethod =
1550                 JobServiceGrpc.getUpdateModelDeploymentMonitoringJobMethod)
1551             == null) {
1552           JobServiceGrpc.getUpdateModelDeploymentMonitoringJobMethod =
1553               getUpdateModelDeploymentMonitoringJobMethod =
1554                   io.grpc.MethodDescriptor
1555                       .<com.google.cloud.aiplatform.v1.UpdateModelDeploymentMonitoringJobRequest,
1556                           com.google.longrunning.Operation>
1557                           newBuilder()
1558                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
1559                       .setFullMethodName(
1560                           generateFullMethodName(
1561                               SERVICE_NAME, "UpdateModelDeploymentMonitoringJob"))
1562                       .setSampledToLocalTracing(true)
1563                       .setRequestMarshaller(
1564                           io.grpc.protobuf.ProtoUtils.marshaller(
1565                               com.google.cloud.aiplatform.v1
1566                                   .UpdateModelDeploymentMonitoringJobRequest.getDefaultInstance()))
1567                       .setResponseMarshaller(
1568                           io.grpc.protobuf.ProtoUtils.marshaller(
1569                               com.google.longrunning.Operation.getDefaultInstance()))
1570                       .setSchemaDescriptor(
1571                           new JobServiceMethodDescriptorSupplier(
1572                               "UpdateModelDeploymentMonitoringJob"))
1573                       .build();
1574         }
1575       }
1576     }
1577     return getUpdateModelDeploymentMonitoringJobMethod;
1578   }
1579 
1580   private static volatile io.grpc.MethodDescriptor<
1581           com.google.cloud.aiplatform.v1.DeleteModelDeploymentMonitoringJobRequest,
1582           com.google.longrunning.Operation>
1583       getDeleteModelDeploymentMonitoringJobMethod;
1584 
1585   @io.grpc.stub.annotations.RpcMethod(
1586       fullMethodName = SERVICE_NAME + '/' + "DeleteModelDeploymentMonitoringJob",
1587       requestType = com.google.cloud.aiplatform.v1.DeleteModelDeploymentMonitoringJobRequest.class,
1588       responseType = com.google.longrunning.Operation.class,
1589       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
1590   public static io.grpc.MethodDescriptor<
1591           com.google.cloud.aiplatform.v1.DeleteModelDeploymentMonitoringJobRequest,
1592           com.google.longrunning.Operation>
getDeleteModelDeploymentMonitoringJobMethod()1593       getDeleteModelDeploymentMonitoringJobMethod() {
1594     io.grpc.MethodDescriptor<
1595             com.google.cloud.aiplatform.v1.DeleteModelDeploymentMonitoringJobRequest,
1596             com.google.longrunning.Operation>
1597         getDeleteModelDeploymentMonitoringJobMethod;
1598     if ((getDeleteModelDeploymentMonitoringJobMethod =
1599             JobServiceGrpc.getDeleteModelDeploymentMonitoringJobMethod)
1600         == null) {
1601       synchronized (JobServiceGrpc.class) {
1602         if ((getDeleteModelDeploymentMonitoringJobMethod =
1603                 JobServiceGrpc.getDeleteModelDeploymentMonitoringJobMethod)
1604             == null) {
1605           JobServiceGrpc.getDeleteModelDeploymentMonitoringJobMethod =
1606               getDeleteModelDeploymentMonitoringJobMethod =
1607                   io.grpc.MethodDescriptor
1608                       .<com.google.cloud.aiplatform.v1.DeleteModelDeploymentMonitoringJobRequest,
1609                           com.google.longrunning.Operation>
1610                           newBuilder()
1611                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
1612                       .setFullMethodName(
1613                           generateFullMethodName(
1614                               SERVICE_NAME, "DeleteModelDeploymentMonitoringJob"))
1615                       .setSampledToLocalTracing(true)
1616                       .setRequestMarshaller(
1617                           io.grpc.protobuf.ProtoUtils.marshaller(
1618                               com.google.cloud.aiplatform.v1
1619                                   .DeleteModelDeploymentMonitoringJobRequest.getDefaultInstance()))
1620                       .setResponseMarshaller(
1621                           io.grpc.protobuf.ProtoUtils.marshaller(
1622                               com.google.longrunning.Operation.getDefaultInstance()))
1623                       .setSchemaDescriptor(
1624                           new JobServiceMethodDescriptorSupplier(
1625                               "DeleteModelDeploymentMonitoringJob"))
1626                       .build();
1627         }
1628       }
1629     }
1630     return getDeleteModelDeploymentMonitoringJobMethod;
1631   }
1632 
1633   private static volatile io.grpc.MethodDescriptor<
1634           com.google.cloud.aiplatform.v1.PauseModelDeploymentMonitoringJobRequest,
1635           com.google.protobuf.Empty>
1636       getPauseModelDeploymentMonitoringJobMethod;
1637 
1638   @io.grpc.stub.annotations.RpcMethod(
1639       fullMethodName = SERVICE_NAME + '/' + "PauseModelDeploymentMonitoringJob",
1640       requestType = com.google.cloud.aiplatform.v1.PauseModelDeploymentMonitoringJobRequest.class,
1641       responseType = com.google.protobuf.Empty.class,
1642       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
1643   public static io.grpc.MethodDescriptor<
1644           com.google.cloud.aiplatform.v1.PauseModelDeploymentMonitoringJobRequest,
1645           com.google.protobuf.Empty>
getPauseModelDeploymentMonitoringJobMethod()1646       getPauseModelDeploymentMonitoringJobMethod() {
1647     io.grpc.MethodDescriptor<
1648             com.google.cloud.aiplatform.v1.PauseModelDeploymentMonitoringJobRequest,
1649             com.google.protobuf.Empty>
1650         getPauseModelDeploymentMonitoringJobMethod;
1651     if ((getPauseModelDeploymentMonitoringJobMethod =
1652             JobServiceGrpc.getPauseModelDeploymentMonitoringJobMethod)
1653         == null) {
1654       synchronized (JobServiceGrpc.class) {
1655         if ((getPauseModelDeploymentMonitoringJobMethod =
1656                 JobServiceGrpc.getPauseModelDeploymentMonitoringJobMethod)
1657             == null) {
1658           JobServiceGrpc.getPauseModelDeploymentMonitoringJobMethod =
1659               getPauseModelDeploymentMonitoringJobMethod =
1660                   io.grpc.MethodDescriptor
1661                       .<com.google.cloud.aiplatform.v1.PauseModelDeploymentMonitoringJobRequest,
1662                           com.google.protobuf.Empty>
1663                           newBuilder()
1664                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
1665                       .setFullMethodName(
1666                           generateFullMethodName(SERVICE_NAME, "PauseModelDeploymentMonitoringJob"))
1667                       .setSampledToLocalTracing(true)
1668                       .setRequestMarshaller(
1669                           io.grpc.protobuf.ProtoUtils.marshaller(
1670                               com.google.cloud.aiplatform.v1
1671                                   .PauseModelDeploymentMonitoringJobRequest.getDefaultInstance()))
1672                       .setResponseMarshaller(
1673                           io.grpc.protobuf.ProtoUtils.marshaller(
1674                               com.google.protobuf.Empty.getDefaultInstance()))
1675                       .setSchemaDescriptor(
1676                           new JobServiceMethodDescriptorSupplier(
1677                               "PauseModelDeploymentMonitoringJob"))
1678                       .build();
1679         }
1680       }
1681     }
1682     return getPauseModelDeploymentMonitoringJobMethod;
1683   }
1684 
1685   private static volatile io.grpc.MethodDescriptor<
1686           com.google.cloud.aiplatform.v1.ResumeModelDeploymentMonitoringJobRequest,
1687           com.google.protobuf.Empty>
1688       getResumeModelDeploymentMonitoringJobMethod;
1689 
1690   @io.grpc.stub.annotations.RpcMethod(
1691       fullMethodName = SERVICE_NAME + '/' + "ResumeModelDeploymentMonitoringJob",
1692       requestType = com.google.cloud.aiplatform.v1.ResumeModelDeploymentMonitoringJobRequest.class,
1693       responseType = com.google.protobuf.Empty.class,
1694       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
1695   public static io.grpc.MethodDescriptor<
1696           com.google.cloud.aiplatform.v1.ResumeModelDeploymentMonitoringJobRequest,
1697           com.google.protobuf.Empty>
getResumeModelDeploymentMonitoringJobMethod()1698       getResumeModelDeploymentMonitoringJobMethod() {
1699     io.grpc.MethodDescriptor<
1700             com.google.cloud.aiplatform.v1.ResumeModelDeploymentMonitoringJobRequest,
1701             com.google.protobuf.Empty>
1702         getResumeModelDeploymentMonitoringJobMethod;
1703     if ((getResumeModelDeploymentMonitoringJobMethod =
1704             JobServiceGrpc.getResumeModelDeploymentMonitoringJobMethod)
1705         == null) {
1706       synchronized (JobServiceGrpc.class) {
1707         if ((getResumeModelDeploymentMonitoringJobMethod =
1708                 JobServiceGrpc.getResumeModelDeploymentMonitoringJobMethod)
1709             == null) {
1710           JobServiceGrpc.getResumeModelDeploymentMonitoringJobMethod =
1711               getResumeModelDeploymentMonitoringJobMethod =
1712                   io.grpc.MethodDescriptor
1713                       .<com.google.cloud.aiplatform.v1.ResumeModelDeploymentMonitoringJobRequest,
1714                           com.google.protobuf.Empty>
1715                           newBuilder()
1716                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
1717                       .setFullMethodName(
1718                           generateFullMethodName(
1719                               SERVICE_NAME, "ResumeModelDeploymentMonitoringJob"))
1720                       .setSampledToLocalTracing(true)
1721                       .setRequestMarshaller(
1722                           io.grpc.protobuf.ProtoUtils.marshaller(
1723                               com.google.cloud.aiplatform.v1
1724                                   .ResumeModelDeploymentMonitoringJobRequest.getDefaultInstance()))
1725                       .setResponseMarshaller(
1726                           io.grpc.protobuf.ProtoUtils.marshaller(
1727                               com.google.protobuf.Empty.getDefaultInstance()))
1728                       .setSchemaDescriptor(
1729                           new JobServiceMethodDescriptorSupplier(
1730                               "ResumeModelDeploymentMonitoringJob"))
1731                       .build();
1732         }
1733       }
1734     }
1735     return getResumeModelDeploymentMonitoringJobMethod;
1736   }
1737 
1738   /** Creates a new async stub that supports all call types for the service */
newStub(io.grpc.Channel channel)1739   public static JobServiceStub newStub(io.grpc.Channel channel) {
1740     io.grpc.stub.AbstractStub.StubFactory<JobServiceStub> factory =
1741         new io.grpc.stub.AbstractStub.StubFactory<JobServiceStub>() {
1742           @java.lang.Override
1743           public JobServiceStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
1744             return new JobServiceStub(channel, callOptions);
1745           }
1746         };
1747     return JobServiceStub.newStub(factory, channel);
1748   }
1749 
1750   /**
1751    * Creates a new blocking-style stub that supports unary and streaming output calls on the service
1752    */
newBlockingStub(io.grpc.Channel channel)1753   public static JobServiceBlockingStub newBlockingStub(io.grpc.Channel channel) {
1754     io.grpc.stub.AbstractStub.StubFactory<JobServiceBlockingStub> factory =
1755         new io.grpc.stub.AbstractStub.StubFactory<JobServiceBlockingStub>() {
1756           @java.lang.Override
1757           public JobServiceBlockingStub newStub(
1758               io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
1759             return new JobServiceBlockingStub(channel, callOptions);
1760           }
1761         };
1762     return JobServiceBlockingStub.newStub(factory, channel);
1763   }
1764 
1765   /** Creates a new ListenableFuture-style stub that supports unary calls on the service */
newFutureStub(io.grpc.Channel channel)1766   public static JobServiceFutureStub newFutureStub(io.grpc.Channel channel) {
1767     io.grpc.stub.AbstractStub.StubFactory<JobServiceFutureStub> factory =
1768         new io.grpc.stub.AbstractStub.StubFactory<JobServiceFutureStub>() {
1769           @java.lang.Override
1770           public JobServiceFutureStub newStub(
1771               io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
1772             return new JobServiceFutureStub(channel, callOptions);
1773           }
1774         };
1775     return JobServiceFutureStub.newStub(factory, channel);
1776   }
1777 
1778   /**
1779    *
1780    *
1781    * <pre>
1782    * A service for creating and managing Vertex AI's jobs.
1783    * </pre>
1784    */
1785   public interface AsyncService {
1786 
1787     /**
1788      *
1789      *
1790      * <pre>
1791      * Creates a CustomJob. A created CustomJob right away
1792      * will be attempted to be run.
1793      * </pre>
1794      */
createCustomJob( com.google.cloud.aiplatform.v1.CreateCustomJobRequest request, io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.CustomJob> responseObserver)1795     default void createCustomJob(
1796         com.google.cloud.aiplatform.v1.CreateCustomJobRequest request,
1797         io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.CustomJob> responseObserver) {
1798       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
1799           getCreateCustomJobMethod(), responseObserver);
1800     }
1801 
1802     /**
1803      *
1804      *
1805      * <pre>
1806      * Gets a CustomJob.
1807      * </pre>
1808      */
getCustomJob( com.google.cloud.aiplatform.v1.GetCustomJobRequest request, io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.CustomJob> responseObserver)1809     default void getCustomJob(
1810         com.google.cloud.aiplatform.v1.GetCustomJobRequest request,
1811         io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.CustomJob> responseObserver) {
1812       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
1813           getGetCustomJobMethod(), responseObserver);
1814     }
1815 
1816     /**
1817      *
1818      *
1819      * <pre>
1820      * Lists CustomJobs in a Location.
1821      * </pre>
1822      */
listCustomJobs( com.google.cloud.aiplatform.v1.ListCustomJobsRequest request, io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.ListCustomJobsResponse> responseObserver)1823     default void listCustomJobs(
1824         com.google.cloud.aiplatform.v1.ListCustomJobsRequest request,
1825         io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.ListCustomJobsResponse>
1826             responseObserver) {
1827       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
1828           getListCustomJobsMethod(), responseObserver);
1829     }
1830 
1831     /**
1832      *
1833      *
1834      * <pre>
1835      * Deletes a CustomJob.
1836      * </pre>
1837      */
deleteCustomJob( com.google.cloud.aiplatform.v1.DeleteCustomJobRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)1838     default void deleteCustomJob(
1839         com.google.cloud.aiplatform.v1.DeleteCustomJobRequest request,
1840         io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
1841       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
1842           getDeleteCustomJobMethod(), responseObserver);
1843     }
1844 
1845     /**
1846      *
1847      *
1848      * <pre>
1849      * Cancels a CustomJob.
1850      * Starts asynchronous cancellation on the CustomJob. The server
1851      * makes a best effort to cancel the job, but success is not
1852      * guaranteed. Clients can use
1853      * [JobService.GetCustomJob][google.cloud.aiplatform.v1.JobService.GetCustomJob]
1854      * or other methods to check whether the cancellation succeeded or whether the
1855      * job completed despite cancellation. On successful cancellation,
1856      * the CustomJob is not deleted; instead it becomes a job with
1857      * a [CustomJob.error][google.cloud.aiplatform.v1.CustomJob.error] value with
1858      * a [google.rpc.Status.code][google.rpc.Status.code] of 1, corresponding to
1859      * `Code.CANCELLED`, and
1860      * [CustomJob.state][google.cloud.aiplatform.v1.CustomJob.state] is set to
1861      * `CANCELLED`.
1862      * </pre>
1863      */
cancelCustomJob( com.google.cloud.aiplatform.v1.CancelCustomJobRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)1864     default void cancelCustomJob(
1865         com.google.cloud.aiplatform.v1.CancelCustomJobRequest request,
1866         io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) {
1867       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
1868           getCancelCustomJobMethod(), responseObserver);
1869     }
1870 
1871     /**
1872      *
1873      *
1874      * <pre>
1875      * Creates a DataLabelingJob.
1876      * </pre>
1877      */
createDataLabelingJob( com.google.cloud.aiplatform.v1.CreateDataLabelingJobRequest request, io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.DataLabelingJob> responseObserver)1878     default void createDataLabelingJob(
1879         com.google.cloud.aiplatform.v1.CreateDataLabelingJobRequest request,
1880         io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.DataLabelingJob>
1881             responseObserver) {
1882       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
1883           getCreateDataLabelingJobMethod(), responseObserver);
1884     }
1885 
1886     /**
1887      *
1888      *
1889      * <pre>
1890      * Gets a DataLabelingJob.
1891      * </pre>
1892      */
getDataLabelingJob( com.google.cloud.aiplatform.v1.GetDataLabelingJobRequest request, io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.DataLabelingJob> responseObserver)1893     default void getDataLabelingJob(
1894         com.google.cloud.aiplatform.v1.GetDataLabelingJobRequest request,
1895         io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.DataLabelingJob>
1896             responseObserver) {
1897       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
1898           getGetDataLabelingJobMethod(), responseObserver);
1899     }
1900 
1901     /**
1902      *
1903      *
1904      * <pre>
1905      * Lists DataLabelingJobs in a Location.
1906      * </pre>
1907      */
listDataLabelingJobs( com.google.cloud.aiplatform.v1.ListDataLabelingJobsRequest request, io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.ListDataLabelingJobsResponse> responseObserver)1908     default void listDataLabelingJobs(
1909         com.google.cloud.aiplatform.v1.ListDataLabelingJobsRequest request,
1910         io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.ListDataLabelingJobsResponse>
1911             responseObserver) {
1912       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
1913           getListDataLabelingJobsMethod(), responseObserver);
1914     }
1915 
1916     /**
1917      *
1918      *
1919      * <pre>
1920      * Deletes a DataLabelingJob.
1921      * </pre>
1922      */
deleteDataLabelingJob( com.google.cloud.aiplatform.v1.DeleteDataLabelingJobRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)1923     default void deleteDataLabelingJob(
1924         com.google.cloud.aiplatform.v1.DeleteDataLabelingJobRequest request,
1925         io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
1926       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
1927           getDeleteDataLabelingJobMethod(), responseObserver);
1928     }
1929 
1930     /**
1931      *
1932      *
1933      * <pre>
1934      * Cancels a DataLabelingJob. Success of cancellation is not guaranteed.
1935      * </pre>
1936      */
cancelDataLabelingJob( com.google.cloud.aiplatform.v1.CancelDataLabelingJobRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)1937     default void cancelDataLabelingJob(
1938         com.google.cloud.aiplatform.v1.CancelDataLabelingJobRequest request,
1939         io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) {
1940       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
1941           getCancelDataLabelingJobMethod(), responseObserver);
1942     }
1943 
1944     /**
1945      *
1946      *
1947      * <pre>
1948      * Creates a HyperparameterTuningJob
1949      * </pre>
1950      */
createHyperparameterTuningJob( com.google.cloud.aiplatform.v1.CreateHyperparameterTuningJobRequest request, io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.HyperparameterTuningJob> responseObserver)1951     default void createHyperparameterTuningJob(
1952         com.google.cloud.aiplatform.v1.CreateHyperparameterTuningJobRequest request,
1953         io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.HyperparameterTuningJob>
1954             responseObserver) {
1955       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
1956           getCreateHyperparameterTuningJobMethod(), responseObserver);
1957     }
1958 
1959     /**
1960      *
1961      *
1962      * <pre>
1963      * Gets a HyperparameterTuningJob
1964      * </pre>
1965      */
getHyperparameterTuningJob( com.google.cloud.aiplatform.v1.GetHyperparameterTuningJobRequest request, io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.HyperparameterTuningJob> responseObserver)1966     default void getHyperparameterTuningJob(
1967         com.google.cloud.aiplatform.v1.GetHyperparameterTuningJobRequest request,
1968         io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.HyperparameterTuningJob>
1969             responseObserver) {
1970       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
1971           getGetHyperparameterTuningJobMethod(), responseObserver);
1972     }
1973 
1974     /**
1975      *
1976      *
1977      * <pre>
1978      * Lists HyperparameterTuningJobs in a Location.
1979      * </pre>
1980      */
listHyperparameterTuningJobs( com.google.cloud.aiplatform.v1.ListHyperparameterTuningJobsRequest request, io.grpc.stub.StreamObserver< com.google.cloud.aiplatform.v1.ListHyperparameterTuningJobsResponse> responseObserver)1981     default void listHyperparameterTuningJobs(
1982         com.google.cloud.aiplatform.v1.ListHyperparameterTuningJobsRequest request,
1983         io.grpc.stub.StreamObserver<
1984                 com.google.cloud.aiplatform.v1.ListHyperparameterTuningJobsResponse>
1985             responseObserver) {
1986       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
1987           getListHyperparameterTuningJobsMethod(), responseObserver);
1988     }
1989 
1990     /**
1991      *
1992      *
1993      * <pre>
1994      * Deletes a HyperparameterTuningJob.
1995      * </pre>
1996      */
deleteHyperparameterTuningJob( com.google.cloud.aiplatform.v1.DeleteHyperparameterTuningJobRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)1997     default void deleteHyperparameterTuningJob(
1998         com.google.cloud.aiplatform.v1.DeleteHyperparameterTuningJobRequest request,
1999         io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
2000       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
2001           getDeleteHyperparameterTuningJobMethod(), responseObserver);
2002     }
2003 
2004     /**
2005      *
2006      *
2007      * <pre>
2008      * Cancels a HyperparameterTuningJob.
2009      * Starts asynchronous cancellation on the HyperparameterTuningJob. The server
2010      * makes a best effort to cancel the job, but success is not
2011      * guaranteed. Clients can use
2012      * [JobService.GetHyperparameterTuningJob][google.cloud.aiplatform.v1.JobService.GetHyperparameterTuningJob]
2013      * or other methods to check whether the cancellation succeeded or whether the
2014      * job completed despite cancellation. On successful cancellation,
2015      * the HyperparameterTuningJob is not deleted; instead it becomes a job with
2016      * a
2017      * [HyperparameterTuningJob.error][google.cloud.aiplatform.v1.HyperparameterTuningJob.error]
2018      * value with a [google.rpc.Status.code][google.rpc.Status.code] of 1,
2019      * corresponding to `Code.CANCELLED`, and
2020      * [HyperparameterTuningJob.state][google.cloud.aiplatform.v1.HyperparameterTuningJob.state]
2021      * is set to `CANCELLED`.
2022      * </pre>
2023      */
cancelHyperparameterTuningJob( com.google.cloud.aiplatform.v1.CancelHyperparameterTuningJobRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)2024     default void cancelHyperparameterTuningJob(
2025         com.google.cloud.aiplatform.v1.CancelHyperparameterTuningJobRequest request,
2026         io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) {
2027       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
2028           getCancelHyperparameterTuningJobMethod(), responseObserver);
2029     }
2030 
2031     /**
2032      *
2033      *
2034      * <pre>
2035      * Creates a NasJob
2036      * </pre>
2037      */
createNasJob( com.google.cloud.aiplatform.v1.CreateNasJobRequest request, io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.NasJob> responseObserver)2038     default void createNasJob(
2039         com.google.cloud.aiplatform.v1.CreateNasJobRequest request,
2040         io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.NasJob> responseObserver) {
2041       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
2042           getCreateNasJobMethod(), responseObserver);
2043     }
2044 
2045     /**
2046      *
2047      *
2048      * <pre>
2049      * Gets a NasJob
2050      * </pre>
2051      */
getNasJob( com.google.cloud.aiplatform.v1.GetNasJobRequest request, io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.NasJob> responseObserver)2052     default void getNasJob(
2053         com.google.cloud.aiplatform.v1.GetNasJobRequest request,
2054         io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.NasJob> responseObserver) {
2055       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetNasJobMethod(), responseObserver);
2056     }
2057 
2058     /**
2059      *
2060      *
2061      * <pre>
2062      * Lists NasJobs in a Location.
2063      * </pre>
2064      */
listNasJobs( com.google.cloud.aiplatform.v1.ListNasJobsRequest request, io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.ListNasJobsResponse> responseObserver)2065     default void listNasJobs(
2066         com.google.cloud.aiplatform.v1.ListNasJobsRequest request,
2067         io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.ListNasJobsResponse>
2068             responseObserver) {
2069       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
2070           getListNasJobsMethod(), responseObserver);
2071     }
2072 
2073     /**
2074      *
2075      *
2076      * <pre>
2077      * Deletes a NasJob.
2078      * </pre>
2079      */
deleteNasJob( com.google.cloud.aiplatform.v1.DeleteNasJobRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)2080     default void deleteNasJob(
2081         com.google.cloud.aiplatform.v1.DeleteNasJobRequest request,
2082         io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
2083       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
2084           getDeleteNasJobMethod(), responseObserver);
2085     }
2086 
2087     /**
2088      *
2089      *
2090      * <pre>
2091      * Cancels a NasJob.
2092      * Starts asynchronous cancellation on the NasJob. The server
2093      * makes a best effort to cancel the job, but success is not
2094      * guaranteed. Clients can use
2095      * [JobService.GetNasJob][google.cloud.aiplatform.v1.JobService.GetNasJob] or
2096      * other methods to check whether the cancellation succeeded or whether the
2097      * job completed despite cancellation. On successful cancellation,
2098      * the NasJob is not deleted; instead it becomes a job with
2099      * a [NasJob.error][google.cloud.aiplatform.v1.NasJob.error] value with a
2100      * [google.rpc.Status.code][google.rpc.Status.code] of 1, corresponding to
2101      * `Code.CANCELLED`, and
2102      * [NasJob.state][google.cloud.aiplatform.v1.NasJob.state] is set to
2103      * `CANCELLED`.
2104      * </pre>
2105      */
cancelNasJob( com.google.cloud.aiplatform.v1.CancelNasJobRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)2106     default void cancelNasJob(
2107         com.google.cloud.aiplatform.v1.CancelNasJobRequest request,
2108         io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) {
2109       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
2110           getCancelNasJobMethod(), responseObserver);
2111     }
2112 
2113     /**
2114      *
2115      *
2116      * <pre>
2117      * Gets a NasTrialDetail.
2118      * </pre>
2119      */
getNasTrialDetail( com.google.cloud.aiplatform.v1.GetNasTrialDetailRequest request, io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.NasTrialDetail> responseObserver)2120     default void getNasTrialDetail(
2121         com.google.cloud.aiplatform.v1.GetNasTrialDetailRequest request,
2122         io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.NasTrialDetail>
2123             responseObserver) {
2124       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
2125           getGetNasTrialDetailMethod(), responseObserver);
2126     }
2127 
2128     /**
2129      *
2130      *
2131      * <pre>
2132      * List top NasTrialDetails of a NasJob.
2133      * </pre>
2134      */
listNasTrialDetails( com.google.cloud.aiplatform.v1.ListNasTrialDetailsRequest request, io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.ListNasTrialDetailsResponse> responseObserver)2135     default void listNasTrialDetails(
2136         com.google.cloud.aiplatform.v1.ListNasTrialDetailsRequest request,
2137         io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.ListNasTrialDetailsResponse>
2138             responseObserver) {
2139       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
2140           getListNasTrialDetailsMethod(), responseObserver);
2141     }
2142 
2143     /**
2144      *
2145      *
2146      * <pre>
2147      * Creates a BatchPredictionJob. A BatchPredictionJob once created will
2148      * right away be attempted to start.
2149      * </pre>
2150      */
createBatchPredictionJob( com.google.cloud.aiplatform.v1.CreateBatchPredictionJobRequest request, io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.BatchPredictionJob> responseObserver)2151     default void createBatchPredictionJob(
2152         com.google.cloud.aiplatform.v1.CreateBatchPredictionJobRequest request,
2153         io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.BatchPredictionJob>
2154             responseObserver) {
2155       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
2156           getCreateBatchPredictionJobMethod(), responseObserver);
2157     }
2158 
2159     /**
2160      *
2161      *
2162      * <pre>
2163      * Gets a BatchPredictionJob
2164      * </pre>
2165      */
getBatchPredictionJob( com.google.cloud.aiplatform.v1.GetBatchPredictionJobRequest request, io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.BatchPredictionJob> responseObserver)2166     default void getBatchPredictionJob(
2167         com.google.cloud.aiplatform.v1.GetBatchPredictionJobRequest request,
2168         io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.BatchPredictionJob>
2169             responseObserver) {
2170       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
2171           getGetBatchPredictionJobMethod(), responseObserver);
2172     }
2173 
2174     /**
2175      *
2176      *
2177      * <pre>
2178      * Lists BatchPredictionJobs in a Location.
2179      * </pre>
2180      */
listBatchPredictionJobs( com.google.cloud.aiplatform.v1.ListBatchPredictionJobsRequest request, io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.ListBatchPredictionJobsResponse> responseObserver)2181     default void listBatchPredictionJobs(
2182         com.google.cloud.aiplatform.v1.ListBatchPredictionJobsRequest request,
2183         io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.ListBatchPredictionJobsResponse>
2184             responseObserver) {
2185       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
2186           getListBatchPredictionJobsMethod(), responseObserver);
2187     }
2188 
2189     /**
2190      *
2191      *
2192      * <pre>
2193      * Deletes a BatchPredictionJob. Can only be called on jobs that already
2194      * finished.
2195      * </pre>
2196      */
deleteBatchPredictionJob( com.google.cloud.aiplatform.v1.DeleteBatchPredictionJobRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)2197     default void deleteBatchPredictionJob(
2198         com.google.cloud.aiplatform.v1.DeleteBatchPredictionJobRequest request,
2199         io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
2200       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
2201           getDeleteBatchPredictionJobMethod(), responseObserver);
2202     }
2203 
2204     /**
2205      *
2206      *
2207      * <pre>
2208      * Cancels a BatchPredictionJob.
2209      * Starts asynchronous cancellation on the BatchPredictionJob. The server
2210      * makes the best effort to cancel the job, but success is not
2211      * guaranteed. Clients can use
2212      * [JobService.GetBatchPredictionJob][google.cloud.aiplatform.v1.JobService.GetBatchPredictionJob]
2213      * or other methods to check whether the cancellation succeeded or whether the
2214      * job completed despite cancellation. On a successful cancellation,
2215      * the BatchPredictionJob is not deleted;instead its
2216      * [BatchPredictionJob.state][google.cloud.aiplatform.v1.BatchPredictionJob.state]
2217      * is set to `CANCELLED`. Any files already outputted by the job are not
2218      * deleted.
2219      * </pre>
2220      */
cancelBatchPredictionJob( com.google.cloud.aiplatform.v1.CancelBatchPredictionJobRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)2221     default void cancelBatchPredictionJob(
2222         com.google.cloud.aiplatform.v1.CancelBatchPredictionJobRequest request,
2223         io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) {
2224       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
2225           getCancelBatchPredictionJobMethod(), responseObserver);
2226     }
2227 
2228     /**
2229      *
2230      *
2231      * <pre>
2232      * Creates a ModelDeploymentMonitoringJob. It will run periodically on a
2233      * configured interval.
2234      * </pre>
2235      */
createModelDeploymentMonitoringJob( com.google.cloud.aiplatform.v1.CreateModelDeploymentMonitoringJobRequest request, io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.ModelDeploymentMonitoringJob> responseObserver)2236     default void createModelDeploymentMonitoringJob(
2237         com.google.cloud.aiplatform.v1.CreateModelDeploymentMonitoringJobRequest request,
2238         io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.ModelDeploymentMonitoringJob>
2239             responseObserver) {
2240       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
2241           getCreateModelDeploymentMonitoringJobMethod(), responseObserver);
2242     }
2243 
2244     /**
2245      *
2246      *
2247      * <pre>
2248      * Searches Model Monitoring Statistics generated within a given time window.
2249      * </pre>
2250      */
searchModelDeploymentMonitoringStatsAnomalies( com.google.cloud.aiplatform.v1.SearchModelDeploymentMonitoringStatsAnomaliesRequest request, io.grpc.stub.StreamObserver< com.google.cloud.aiplatform.v1 .SearchModelDeploymentMonitoringStatsAnomaliesResponse> responseObserver)2251     default void searchModelDeploymentMonitoringStatsAnomalies(
2252         com.google.cloud.aiplatform.v1.SearchModelDeploymentMonitoringStatsAnomaliesRequest request,
2253         io.grpc.stub.StreamObserver<
2254                 com.google.cloud.aiplatform.v1
2255                     .SearchModelDeploymentMonitoringStatsAnomaliesResponse>
2256             responseObserver) {
2257       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
2258           getSearchModelDeploymentMonitoringStatsAnomaliesMethod(), responseObserver);
2259     }
2260 
2261     /**
2262      *
2263      *
2264      * <pre>
2265      * Gets a ModelDeploymentMonitoringJob.
2266      * </pre>
2267      */
getModelDeploymentMonitoringJob( com.google.cloud.aiplatform.v1.GetModelDeploymentMonitoringJobRequest request, io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.ModelDeploymentMonitoringJob> responseObserver)2268     default void getModelDeploymentMonitoringJob(
2269         com.google.cloud.aiplatform.v1.GetModelDeploymentMonitoringJobRequest request,
2270         io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.ModelDeploymentMonitoringJob>
2271             responseObserver) {
2272       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
2273           getGetModelDeploymentMonitoringJobMethod(), responseObserver);
2274     }
2275 
2276     /**
2277      *
2278      *
2279      * <pre>
2280      * Lists ModelDeploymentMonitoringJobs in a Location.
2281      * </pre>
2282      */
listModelDeploymentMonitoringJobs( com.google.cloud.aiplatform.v1.ListModelDeploymentMonitoringJobsRequest request, io.grpc.stub.StreamObserver< com.google.cloud.aiplatform.v1.ListModelDeploymentMonitoringJobsResponse> responseObserver)2283     default void listModelDeploymentMonitoringJobs(
2284         com.google.cloud.aiplatform.v1.ListModelDeploymentMonitoringJobsRequest request,
2285         io.grpc.stub.StreamObserver<
2286                 com.google.cloud.aiplatform.v1.ListModelDeploymentMonitoringJobsResponse>
2287             responseObserver) {
2288       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
2289           getListModelDeploymentMonitoringJobsMethod(), responseObserver);
2290     }
2291 
2292     /**
2293      *
2294      *
2295      * <pre>
2296      * Updates a ModelDeploymentMonitoringJob.
2297      * </pre>
2298      */
updateModelDeploymentMonitoringJob( com.google.cloud.aiplatform.v1.UpdateModelDeploymentMonitoringJobRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)2299     default void updateModelDeploymentMonitoringJob(
2300         com.google.cloud.aiplatform.v1.UpdateModelDeploymentMonitoringJobRequest request,
2301         io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
2302       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
2303           getUpdateModelDeploymentMonitoringJobMethod(), responseObserver);
2304     }
2305 
2306     /**
2307      *
2308      *
2309      * <pre>
2310      * Deletes a ModelDeploymentMonitoringJob.
2311      * </pre>
2312      */
deleteModelDeploymentMonitoringJob( com.google.cloud.aiplatform.v1.DeleteModelDeploymentMonitoringJobRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)2313     default void deleteModelDeploymentMonitoringJob(
2314         com.google.cloud.aiplatform.v1.DeleteModelDeploymentMonitoringJobRequest request,
2315         io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
2316       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
2317           getDeleteModelDeploymentMonitoringJobMethod(), responseObserver);
2318     }
2319 
2320     /**
2321      *
2322      *
2323      * <pre>
2324      * Pauses a ModelDeploymentMonitoringJob. If the job is running, the server
2325      * makes a best effort to cancel the job. Will mark
2326      * [ModelDeploymentMonitoringJob.state][google.cloud.aiplatform.v1.ModelDeploymentMonitoringJob.state]
2327      * to 'PAUSED'.
2328      * </pre>
2329      */
pauseModelDeploymentMonitoringJob( com.google.cloud.aiplatform.v1.PauseModelDeploymentMonitoringJobRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)2330     default void pauseModelDeploymentMonitoringJob(
2331         com.google.cloud.aiplatform.v1.PauseModelDeploymentMonitoringJobRequest request,
2332         io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) {
2333       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
2334           getPauseModelDeploymentMonitoringJobMethod(), responseObserver);
2335     }
2336 
2337     /**
2338      *
2339      *
2340      * <pre>
2341      * Resumes a paused ModelDeploymentMonitoringJob. It will start to run from
2342      * next scheduled time. A deleted ModelDeploymentMonitoringJob can't be
2343      * resumed.
2344      * </pre>
2345      */
resumeModelDeploymentMonitoringJob( com.google.cloud.aiplatform.v1.ResumeModelDeploymentMonitoringJobRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)2346     default void resumeModelDeploymentMonitoringJob(
2347         com.google.cloud.aiplatform.v1.ResumeModelDeploymentMonitoringJobRequest request,
2348         io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) {
2349       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
2350           getResumeModelDeploymentMonitoringJobMethod(), responseObserver);
2351     }
2352   }
2353 
2354   /**
2355    * Base class for the server implementation of the service JobService.
2356    *
2357    * <pre>
2358    * A service for creating and managing Vertex AI's jobs.
2359    * </pre>
2360    */
2361   public abstract static class JobServiceImplBase implements io.grpc.BindableService, AsyncService {
2362 
2363     @java.lang.Override
bindService()2364     public final io.grpc.ServerServiceDefinition bindService() {
2365       return JobServiceGrpc.bindService(this);
2366     }
2367   }
2368 
2369   /**
2370    * A stub to allow clients to do asynchronous rpc calls to service JobService.
2371    *
2372    * <pre>
2373    * A service for creating and managing Vertex AI's jobs.
2374    * </pre>
2375    */
2376   public static final class JobServiceStub extends io.grpc.stub.AbstractAsyncStub<JobServiceStub> {
JobServiceStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions)2377     private JobServiceStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
2378       super(channel, callOptions);
2379     }
2380 
2381     @java.lang.Override
build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)2382     protected JobServiceStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
2383       return new JobServiceStub(channel, callOptions);
2384     }
2385 
2386     /**
2387      *
2388      *
2389      * <pre>
2390      * Creates a CustomJob. A created CustomJob right away
2391      * will be attempted to be run.
2392      * </pre>
2393      */
createCustomJob( com.google.cloud.aiplatform.v1.CreateCustomJobRequest request, io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.CustomJob> responseObserver)2394     public void createCustomJob(
2395         com.google.cloud.aiplatform.v1.CreateCustomJobRequest request,
2396         io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.CustomJob> responseObserver) {
2397       io.grpc.stub.ClientCalls.asyncUnaryCall(
2398           getChannel().newCall(getCreateCustomJobMethod(), getCallOptions()),
2399           request,
2400           responseObserver);
2401     }
2402 
2403     /**
2404      *
2405      *
2406      * <pre>
2407      * Gets a CustomJob.
2408      * </pre>
2409      */
getCustomJob( com.google.cloud.aiplatform.v1.GetCustomJobRequest request, io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.CustomJob> responseObserver)2410     public void getCustomJob(
2411         com.google.cloud.aiplatform.v1.GetCustomJobRequest request,
2412         io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.CustomJob> responseObserver) {
2413       io.grpc.stub.ClientCalls.asyncUnaryCall(
2414           getChannel().newCall(getGetCustomJobMethod(), getCallOptions()),
2415           request,
2416           responseObserver);
2417     }
2418 
2419     /**
2420      *
2421      *
2422      * <pre>
2423      * Lists CustomJobs in a Location.
2424      * </pre>
2425      */
listCustomJobs( com.google.cloud.aiplatform.v1.ListCustomJobsRequest request, io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.ListCustomJobsResponse> responseObserver)2426     public void listCustomJobs(
2427         com.google.cloud.aiplatform.v1.ListCustomJobsRequest request,
2428         io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.ListCustomJobsResponse>
2429             responseObserver) {
2430       io.grpc.stub.ClientCalls.asyncUnaryCall(
2431           getChannel().newCall(getListCustomJobsMethod(), getCallOptions()),
2432           request,
2433           responseObserver);
2434     }
2435 
2436     /**
2437      *
2438      *
2439      * <pre>
2440      * Deletes a CustomJob.
2441      * </pre>
2442      */
deleteCustomJob( com.google.cloud.aiplatform.v1.DeleteCustomJobRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)2443     public void deleteCustomJob(
2444         com.google.cloud.aiplatform.v1.DeleteCustomJobRequest request,
2445         io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
2446       io.grpc.stub.ClientCalls.asyncUnaryCall(
2447           getChannel().newCall(getDeleteCustomJobMethod(), getCallOptions()),
2448           request,
2449           responseObserver);
2450     }
2451 
2452     /**
2453      *
2454      *
2455      * <pre>
2456      * Cancels a CustomJob.
2457      * Starts asynchronous cancellation on the CustomJob. The server
2458      * makes a best effort to cancel the job, but success is not
2459      * guaranteed. Clients can use
2460      * [JobService.GetCustomJob][google.cloud.aiplatform.v1.JobService.GetCustomJob]
2461      * or other methods to check whether the cancellation succeeded or whether the
2462      * job completed despite cancellation. On successful cancellation,
2463      * the CustomJob is not deleted; instead it becomes a job with
2464      * a [CustomJob.error][google.cloud.aiplatform.v1.CustomJob.error] value with
2465      * a [google.rpc.Status.code][google.rpc.Status.code] of 1, corresponding to
2466      * `Code.CANCELLED`, and
2467      * [CustomJob.state][google.cloud.aiplatform.v1.CustomJob.state] is set to
2468      * `CANCELLED`.
2469      * </pre>
2470      */
cancelCustomJob( com.google.cloud.aiplatform.v1.CancelCustomJobRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)2471     public void cancelCustomJob(
2472         com.google.cloud.aiplatform.v1.CancelCustomJobRequest request,
2473         io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) {
2474       io.grpc.stub.ClientCalls.asyncUnaryCall(
2475           getChannel().newCall(getCancelCustomJobMethod(), getCallOptions()),
2476           request,
2477           responseObserver);
2478     }
2479 
2480     /**
2481      *
2482      *
2483      * <pre>
2484      * Creates a DataLabelingJob.
2485      * </pre>
2486      */
createDataLabelingJob( com.google.cloud.aiplatform.v1.CreateDataLabelingJobRequest request, io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.DataLabelingJob> responseObserver)2487     public void createDataLabelingJob(
2488         com.google.cloud.aiplatform.v1.CreateDataLabelingJobRequest request,
2489         io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.DataLabelingJob>
2490             responseObserver) {
2491       io.grpc.stub.ClientCalls.asyncUnaryCall(
2492           getChannel().newCall(getCreateDataLabelingJobMethod(), getCallOptions()),
2493           request,
2494           responseObserver);
2495     }
2496 
2497     /**
2498      *
2499      *
2500      * <pre>
2501      * Gets a DataLabelingJob.
2502      * </pre>
2503      */
getDataLabelingJob( com.google.cloud.aiplatform.v1.GetDataLabelingJobRequest request, io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.DataLabelingJob> responseObserver)2504     public void getDataLabelingJob(
2505         com.google.cloud.aiplatform.v1.GetDataLabelingJobRequest request,
2506         io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.DataLabelingJob>
2507             responseObserver) {
2508       io.grpc.stub.ClientCalls.asyncUnaryCall(
2509           getChannel().newCall(getGetDataLabelingJobMethod(), getCallOptions()),
2510           request,
2511           responseObserver);
2512     }
2513 
2514     /**
2515      *
2516      *
2517      * <pre>
2518      * Lists DataLabelingJobs in a Location.
2519      * </pre>
2520      */
listDataLabelingJobs( com.google.cloud.aiplatform.v1.ListDataLabelingJobsRequest request, io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.ListDataLabelingJobsResponse> responseObserver)2521     public void listDataLabelingJobs(
2522         com.google.cloud.aiplatform.v1.ListDataLabelingJobsRequest request,
2523         io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.ListDataLabelingJobsResponse>
2524             responseObserver) {
2525       io.grpc.stub.ClientCalls.asyncUnaryCall(
2526           getChannel().newCall(getListDataLabelingJobsMethod(), getCallOptions()),
2527           request,
2528           responseObserver);
2529     }
2530 
2531     /**
2532      *
2533      *
2534      * <pre>
2535      * Deletes a DataLabelingJob.
2536      * </pre>
2537      */
deleteDataLabelingJob( com.google.cloud.aiplatform.v1.DeleteDataLabelingJobRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)2538     public void deleteDataLabelingJob(
2539         com.google.cloud.aiplatform.v1.DeleteDataLabelingJobRequest request,
2540         io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
2541       io.grpc.stub.ClientCalls.asyncUnaryCall(
2542           getChannel().newCall(getDeleteDataLabelingJobMethod(), getCallOptions()),
2543           request,
2544           responseObserver);
2545     }
2546 
2547     /**
2548      *
2549      *
2550      * <pre>
2551      * Cancels a DataLabelingJob. Success of cancellation is not guaranteed.
2552      * </pre>
2553      */
cancelDataLabelingJob( com.google.cloud.aiplatform.v1.CancelDataLabelingJobRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)2554     public void cancelDataLabelingJob(
2555         com.google.cloud.aiplatform.v1.CancelDataLabelingJobRequest request,
2556         io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) {
2557       io.grpc.stub.ClientCalls.asyncUnaryCall(
2558           getChannel().newCall(getCancelDataLabelingJobMethod(), getCallOptions()),
2559           request,
2560           responseObserver);
2561     }
2562 
2563     /**
2564      *
2565      *
2566      * <pre>
2567      * Creates a HyperparameterTuningJob
2568      * </pre>
2569      */
createHyperparameterTuningJob( com.google.cloud.aiplatform.v1.CreateHyperparameterTuningJobRequest request, io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.HyperparameterTuningJob> responseObserver)2570     public void createHyperparameterTuningJob(
2571         com.google.cloud.aiplatform.v1.CreateHyperparameterTuningJobRequest request,
2572         io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.HyperparameterTuningJob>
2573             responseObserver) {
2574       io.grpc.stub.ClientCalls.asyncUnaryCall(
2575           getChannel().newCall(getCreateHyperparameterTuningJobMethod(), getCallOptions()),
2576           request,
2577           responseObserver);
2578     }
2579 
2580     /**
2581      *
2582      *
2583      * <pre>
2584      * Gets a HyperparameterTuningJob
2585      * </pre>
2586      */
getHyperparameterTuningJob( com.google.cloud.aiplatform.v1.GetHyperparameterTuningJobRequest request, io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.HyperparameterTuningJob> responseObserver)2587     public void getHyperparameterTuningJob(
2588         com.google.cloud.aiplatform.v1.GetHyperparameterTuningJobRequest request,
2589         io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.HyperparameterTuningJob>
2590             responseObserver) {
2591       io.grpc.stub.ClientCalls.asyncUnaryCall(
2592           getChannel().newCall(getGetHyperparameterTuningJobMethod(), getCallOptions()),
2593           request,
2594           responseObserver);
2595     }
2596 
2597     /**
2598      *
2599      *
2600      * <pre>
2601      * Lists HyperparameterTuningJobs in a Location.
2602      * </pre>
2603      */
listHyperparameterTuningJobs( com.google.cloud.aiplatform.v1.ListHyperparameterTuningJobsRequest request, io.grpc.stub.StreamObserver< com.google.cloud.aiplatform.v1.ListHyperparameterTuningJobsResponse> responseObserver)2604     public void listHyperparameterTuningJobs(
2605         com.google.cloud.aiplatform.v1.ListHyperparameterTuningJobsRequest request,
2606         io.grpc.stub.StreamObserver<
2607                 com.google.cloud.aiplatform.v1.ListHyperparameterTuningJobsResponse>
2608             responseObserver) {
2609       io.grpc.stub.ClientCalls.asyncUnaryCall(
2610           getChannel().newCall(getListHyperparameterTuningJobsMethod(), getCallOptions()),
2611           request,
2612           responseObserver);
2613     }
2614 
2615     /**
2616      *
2617      *
2618      * <pre>
2619      * Deletes a HyperparameterTuningJob.
2620      * </pre>
2621      */
deleteHyperparameterTuningJob( com.google.cloud.aiplatform.v1.DeleteHyperparameterTuningJobRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)2622     public void deleteHyperparameterTuningJob(
2623         com.google.cloud.aiplatform.v1.DeleteHyperparameterTuningJobRequest request,
2624         io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
2625       io.grpc.stub.ClientCalls.asyncUnaryCall(
2626           getChannel().newCall(getDeleteHyperparameterTuningJobMethod(), getCallOptions()),
2627           request,
2628           responseObserver);
2629     }
2630 
2631     /**
2632      *
2633      *
2634      * <pre>
2635      * Cancels a HyperparameterTuningJob.
2636      * Starts asynchronous cancellation on the HyperparameterTuningJob. The server
2637      * makes a best effort to cancel the job, but success is not
2638      * guaranteed. Clients can use
2639      * [JobService.GetHyperparameterTuningJob][google.cloud.aiplatform.v1.JobService.GetHyperparameterTuningJob]
2640      * or other methods to check whether the cancellation succeeded or whether the
2641      * job completed despite cancellation. On successful cancellation,
2642      * the HyperparameterTuningJob is not deleted; instead it becomes a job with
2643      * a
2644      * [HyperparameterTuningJob.error][google.cloud.aiplatform.v1.HyperparameterTuningJob.error]
2645      * value with a [google.rpc.Status.code][google.rpc.Status.code] of 1,
2646      * corresponding to `Code.CANCELLED`, and
2647      * [HyperparameterTuningJob.state][google.cloud.aiplatform.v1.HyperparameterTuningJob.state]
2648      * is set to `CANCELLED`.
2649      * </pre>
2650      */
cancelHyperparameterTuningJob( com.google.cloud.aiplatform.v1.CancelHyperparameterTuningJobRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)2651     public void cancelHyperparameterTuningJob(
2652         com.google.cloud.aiplatform.v1.CancelHyperparameterTuningJobRequest request,
2653         io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) {
2654       io.grpc.stub.ClientCalls.asyncUnaryCall(
2655           getChannel().newCall(getCancelHyperparameterTuningJobMethod(), getCallOptions()),
2656           request,
2657           responseObserver);
2658     }
2659 
2660     /**
2661      *
2662      *
2663      * <pre>
2664      * Creates a NasJob
2665      * </pre>
2666      */
createNasJob( com.google.cloud.aiplatform.v1.CreateNasJobRequest request, io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.NasJob> responseObserver)2667     public void createNasJob(
2668         com.google.cloud.aiplatform.v1.CreateNasJobRequest request,
2669         io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.NasJob> responseObserver) {
2670       io.grpc.stub.ClientCalls.asyncUnaryCall(
2671           getChannel().newCall(getCreateNasJobMethod(), getCallOptions()),
2672           request,
2673           responseObserver);
2674     }
2675 
2676     /**
2677      *
2678      *
2679      * <pre>
2680      * Gets a NasJob
2681      * </pre>
2682      */
getNasJob( com.google.cloud.aiplatform.v1.GetNasJobRequest request, io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.NasJob> responseObserver)2683     public void getNasJob(
2684         com.google.cloud.aiplatform.v1.GetNasJobRequest request,
2685         io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.NasJob> responseObserver) {
2686       io.grpc.stub.ClientCalls.asyncUnaryCall(
2687           getChannel().newCall(getGetNasJobMethod(), getCallOptions()), request, responseObserver);
2688     }
2689 
2690     /**
2691      *
2692      *
2693      * <pre>
2694      * Lists NasJobs in a Location.
2695      * </pre>
2696      */
listNasJobs( com.google.cloud.aiplatform.v1.ListNasJobsRequest request, io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.ListNasJobsResponse> responseObserver)2697     public void listNasJobs(
2698         com.google.cloud.aiplatform.v1.ListNasJobsRequest request,
2699         io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.ListNasJobsResponse>
2700             responseObserver) {
2701       io.grpc.stub.ClientCalls.asyncUnaryCall(
2702           getChannel().newCall(getListNasJobsMethod(), getCallOptions()),
2703           request,
2704           responseObserver);
2705     }
2706 
2707     /**
2708      *
2709      *
2710      * <pre>
2711      * Deletes a NasJob.
2712      * </pre>
2713      */
deleteNasJob( com.google.cloud.aiplatform.v1.DeleteNasJobRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)2714     public void deleteNasJob(
2715         com.google.cloud.aiplatform.v1.DeleteNasJobRequest request,
2716         io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
2717       io.grpc.stub.ClientCalls.asyncUnaryCall(
2718           getChannel().newCall(getDeleteNasJobMethod(), getCallOptions()),
2719           request,
2720           responseObserver);
2721     }
2722 
2723     /**
2724      *
2725      *
2726      * <pre>
2727      * Cancels a NasJob.
2728      * Starts asynchronous cancellation on the NasJob. The server
2729      * makes a best effort to cancel the job, but success is not
2730      * guaranteed. Clients can use
2731      * [JobService.GetNasJob][google.cloud.aiplatform.v1.JobService.GetNasJob] or
2732      * other methods to check whether the cancellation succeeded or whether the
2733      * job completed despite cancellation. On successful cancellation,
2734      * the NasJob is not deleted; instead it becomes a job with
2735      * a [NasJob.error][google.cloud.aiplatform.v1.NasJob.error] value with a
2736      * [google.rpc.Status.code][google.rpc.Status.code] of 1, corresponding to
2737      * `Code.CANCELLED`, and
2738      * [NasJob.state][google.cloud.aiplatform.v1.NasJob.state] is set to
2739      * `CANCELLED`.
2740      * </pre>
2741      */
cancelNasJob( com.google.cloud.aiplatform.v1.CancelNasJobRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)2742     public void cancelNasJob(
2743         com.google.cloud.aiplatform.v1.CancelNasJobRequest request,
2744         io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) {
2745       io.grpc.stub.ClientCalls.asyncUnaryCall(
2746           getChannel().newCall(getCancelNasJobMethod(), getCallOptions()),
2747           request,
2748           responseObserver);
2749     }
2750 
2751     /**
2752      *
2753      *
2754      * <pre>
2755      * Gets a NasTrialDetail.
2756      * </pre>
2757      */
getNasTrialDetail( com.google.cloud.aiplatform.v1.GetNasTrialDetailRequest request, io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.NasTrialDetail> responseObserver)2758     public void getNasTrialDetail(
2759         com.google.cloud.aiplatform.v1.GetNasTrialDetailRequest request,
2760         io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.NasTrialDetail>
2761             responseObserver) {
2762       io.grpc.stub.ClientCalls.asyncUnaryCall(
2763           getChannel().newCall(getGetNasTrialDetailMethod(), getCallOptions()),
2764           request,
2765           responseObserver);
2766     }
2767 
2768     /**
2769      *
2770      *
2771      * <pre>
2772      * List top NasTrialDetails of a NasJob.
2773      * </pre>
2774      */
listNasTrialDetails( com.google.cloud.aiplatform.v1.ListNasTrialDetailsRequest request, io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.ListNasTrialDetailsResponse> responseObserver)2775     public void listNasTrialDetails(
2776         com.google.cloud.aiplatform.v1.ListNasTrialDetailsRequest request,
2777         io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.ListNasTrialDetailsResponse>
2778             responseObserver) {
2779       io.grpc.stub.ClientCalls.asyncUnaryCall(
2780           getChannel().newCall(getListNasTrialDetailsMethod(), getCallOptions()),
2781           request,
2782           responseObserver);
2783     }
2784 
2785     /**
2786      *
2787      *
2788      * <pre>
2789      * Creates a BatchPredictionJob. A BatchPredictionJob once created will
2790      * right away be attempted to start.
2791      * </pre>
2792      */
createBatchPredictionJob( com.google.cloud.aiplatform.v1.CreateBatchPredictionJobRequest request, io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.BatchPredictionJob> responseObserver)2793     public void createBatchPredictionJob(
2794         com.google.cloud.aiplatform.v1.CreateBatchPredictionJobRequest request,
2795         io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.BatchPredictionJob>
2796             responseObserver) {
2797       io.grpc.stub.ClientCalls.asyncUnaryCall(
2798           getChannel().newCall(getCreateBatchPredictionJobMethod(), getCallOptions()),
2799           request,
2800           responseObserver);
2801     }
2802 
2803     /**
2804      *
2805      *
2806      * <pre>
2807      * Gets a BatchPredictionJob
2808      * </pre>
2809      */
getBatchPredictionJob( com.google.cloud.aiplatform.v1.GetBatchPredictionJobRequest request, io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.BatchPredictionJob> responseObserver)2810     public void getBatchPredictionJob(
2811         com.google.cloud.aiplatform.v1.GetBatchPredictionJobRequest request,
2812         io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.BatchPredictionJob>
2813             responseObserver) {
2814       io.grpc.stub.ClientCalls.asyncUnaryCall(
2815           getChannel().newCall(getGetBatchPredictionJobMethod(), getCallOptions()),
2816           request,
2817           responseObserver);
2818     }
2819 
2820     /**
2821      *
2822      *
2823      * <pre>
2824      * Lists BatchPredictionJobs in a Location.
2825      * </pre>
2826      */
listBatchPredictionJobs( com.google.cloud.aiplatform.v1.ListBatchPredictionJobsRequest request, io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.ListBatchPredictionJobsResponse> responseObserver)2827     public void listBatchPredictionJobs(
2828         com.google.cloud.aiplatform.v1.ListBatchPredictionJobsRequest request,
2829         io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.ListBatchPredictionJobsResponse>
2830             responseObserver) {
2831       io.grpc.stub.ClientCalls.asyncUnaryCall(
2832           getChannel().newCall(getListBatchPredictionJobsMethod(), getCallOptions()),
2833           request,
2834           responseObserver);
2835     }
2836 
2837     /**
2838      *
2839      *
2840      * <pre>
2841      * Deletes a BatchPredictionJob. Can only be called on jobs that already
2842      * finished.
2843      * </pre>
2844      */
deleteBatchPredictionJob( com.google.cloud.aiplatform.v1.DeleteBatchPredictionJobRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)2845     public void deleteBatchPredictionJob(
2846         com.google.cloud.aiplatform.v1.DeleteBatchPredictionJobRequest request,
2847         io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
2848       io.grpc.stub.ClientCalls.asyncUnaryCall(
2849           getChannel().newCall(getDeleteBatchPredictionJobMethod(), getCallOptions()),
2850           request,
2851           responseObserver);
2852     }
2853 
2854     /**
2855      *
2856      *
2857      * <pre>
2858      * Cancels a BatchPredictionJob.
2859      * Starts asynchronous cancellation on the BatchPredictionJob. The server
2860      * makes the best effort to cancel the job, but success is not
2861      * guaranteed. Clients can use
2862      * [JobService.GetBatchPredictionJob][google.cloud.aiplatform.v1.JobService.GetBatchPredictionJob]
2863      * or other methods to check whether the cancellation succeeded or whether the
2864      * job completed despite cancellation. On a successful cancellation,
2865      * the BatchPredictionJob is not deleted;instead its
2866      * [BatchPredictionJob.state][google.cloud.aiplatform.v1.BatchPredictionJob.state]
2867      * is set to `CANCELLED`. Any files already outputted by the job are not
2868      * deleted.
2869      * </pre>
2870      */
cancelBatchPredictionJob( com.google.cloud.aiplatform.v1.CancelBatchPredictionJobRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)2871     public void cancelBatchPredictionJob(
2872         com.google.cloud.aiplatform.v1.CancelBatchPredictionJobRequest request,
2873         io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) {
2874       io.grpc.stub.ClientCalls.asyncUnaryCall(
2875           getChannel().newCall(getCancelBatchPredictionJobMethod(), getCallOptions()),
2876           request,
2877           responseObserver);
2878     }
2879 
2880     /**
2881      *
2882      *
2883      * <pre>
2884      * Creates a ModelDeploymentMonitoringJob. It will run periodically on a
2885      * configured interval.
2886      * </pre>
2887      */
createModelDeploymentMonitoringJob( com.google.cloud.aiplatform.v1.CreateModelDeploymentMonitoringJobRequest request, io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.ModelDeploymentMonitoringJob> responseObserver)2888     public void createModelDeploymentMonitoringJob(
2889         com.google.cloud.aiplatform.v1.CreateModelDeploymentMonitoringJobRequest request,
2890         io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.ModelDeploymentMonitoringJob>
2891             responseObserver) {
2892       io.grpc.stub.ClientCalls.asyncUnaryCall(
2893           getChannel().newCall(getCreateModelDeploymentMonitoringJobMethod(), getCallOptions()),
2894           request,
2895           responseObserver);
2896     }
2897 
2898     /**
2899      *
2900      *
2901      * <pre>
2902      * Searches Model Monitoring Statistics generated within a given time window.
2903      * </pre>
2904      */
searchModelDeploymentMonitoringStatsAnomalies( com.google.cloud.aiplatform.v1.SearchModelDeploymentMonitoringStatsAnomaliesRequest request, io.grpc.stub.StreamObserver< com.google.cloud.aiplatform.v1 .SearchModelDeploymentMonitoringStatsAnomaliesResponse> responseObserver)2905     public void searchModelDeploymentMonitoringStatsAnomalies(
2906         com.google.cloud.aiplatform.v1.SearchModelDeploymentMonitoringStatsAnomaliesRequest request,
2907         io.grpc.stub.StreamObserver<
2908                 com.google.cloud.aiplatform.v1
2909                     .SearchModelDeploymentMonitoringStatsAnomaliesResponse>
2910             responseObserver) {
2911       io.grpc.stub.ClientCalls.asyncUnaryCall(
2912           getChannel()
2913               .newCall(getSearchModelDeploymentMonitoringStatsAnomaliesMethod(), getCallOptions()),
2914           request,
2915           responseObserver);
2916     }
2917 
2918     /**
2919      *
2920      *
2921      * <pre>
2922      * Gets a ModelDeploymentMonitoringJob.
2923      * </pre>
2924      */
getModelDeploymentMonitoringJob( com.google.cloud.aiplatform.v1.GetModelDeploymentMonitoringJobRequest request, io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.ModelDeploymentMonitoringJob> responseObserver)2925     public void getModelDeploymentMonitoringJob(
2926         com.google.cloud.aiplatform.v1.GetModelDeploymentMonitoringJobRequest request,
2927         io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.ModelDeploymentMonitoringJob>
2928             responseObserver) {
2929       io.grpc.stub.ClientCalls.asyncUnaryCall(
2930           getChannel().newCall(getGetModelDeploymentMonitoringJobMethod(), getCallOptions()),
2931           request,
2932           responseObserver);
2933     }
2934 
2935     /**
2936      *
2937      *
2938      * <pre>
2939      * Lists ModelDeploymentMonitoringJobs in a Location.
2940      * </pre>
2941      */
listModelDeploymentMonitoringJobs( com.google.cloud.aiplatform.v1.ListModelDeploymentMonitoringJobsRequest request, io.grpc.stub.StreamObserver< com.google.cloud.aiplatform.v1.ListModelDeploymentMonitoringJobsResponse> responseObserver)2942     public void listModelDeploymentMonitoringJobs(
2943         com.google.cloud.aiplatform.v1.ListModelDeploymentMonitoringJobsRequest request,
2944         io.grpc.stub.StreamObserver<
2945                 com.google.cloud.aiplatform.v1.ListModelDeploymentMonitoringJobsResponse>
2946             responseObserver) {
2947       io.grpc.stub.ClientCalls.asyncUnaryCall(
2948           getChannel().newCall(getListModelDeploymentMonitoringJobsMethod(), getCallOptions()),
2949           request,
2950           responseObserver);
2951     }
2952 
2953     /**
2954      *
2955      *
2956      * <pre>
2957      * Updates a ModelDeploymentMonitoringJob.
2958      * </pre>
2959      */
updateModelDeploymentMonitoringJob( com.google.cloud.aiplatform.v1.UpdateModelDeploymentMonitoringJobRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)2960     public void updateModelDeploymentMonitoringJob(
2961         com.google.cloud.aiplatform.v1.UpdateModelDeploymentMonitoringJobRequest request,
2962         io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
2963       io.grpc.stub.ClientCalls.asyncUnaryCall(
2964           getChannel().newCall(getUpdateModelDeploymentMonitoringJobMethod(), getCallOptions()),
2965           request,
2966           responseObserver);
2967     }
2968 
2969     /**
2970      *
2971      *
2972      * <pre>
2973      * Deletes a ModelDeploymentMonitoringJob.
2974      * </pre>
2975      */
deleteModelDeploymentMonitoringJob( com.google.cloud.aiplatform.v1.DeleteModelDeploymentMonitoringJobRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)2976     public void deleteModelDeploymentMonitoringJob(
2977         com.google.cloud.aiplatform.v1.DeleteModelDeploymentMonitoringJobRequest request,
2978         io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
2979       io.grpc.stub.ClientCalls.asyncUnaryCall(
2980           getChannel().newCall(getDeleteModelDeploymentMonitoringJobMethod(), getCallOptions()),
2981           request,
2982           responseObserver);
2983     }
2984 
2985     /**
2986      *
2987      *
2988      * <pre>
2989      * Pauses a ModelDeploymentMonitoringJob. If the job is running, the server
2990      * makes a best effort to cancel the job. Will mark
2991      * [ModelDeploymentMonitoringJob.state][google.cloud.aiplatform.v1.ModelDeploymentMonitoringJob.state]
2992      * to 'PAUSED'.
2993      * </pre>
2994      */
pauseModelDeploymentMonitoringJob( com.google.cloud.aiplatform.v1.PauseModelDeploymentMonitoringJobRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)2995     public void pauseModelDeploymentMonitoringJob(
2996         com.google.cloud.aiplatform.v1.PauseModelDeploymentMonitoringJobRequest request,
2997         io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) {
2998       io.grpc.stub.ClientCalls.asyncUnaryCall(
2999           getChannel().newCall(getPauseModelDeploymentMonitoringJobMethod(), getCallOptions()),
3000           request,
3001           responseObserver);
3002     }
3003 
3004     /**
3005      *
3006      *
3007      * <pre>
3008      * Resumes a paused ModelDeploymentMonitoringJob. It will start to run from
3009      * next scheduled time. A deleted ModelDeploymentMonitoringJob can't be
3010      * resumed.
3011      * </pre>
3012      */
resumeModelDeploymentMonitoringJob( com.google.cloud.aiplatform.v1.ResumeModelDeploymentMonitoringJobRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)3013     public void resumeModelDeploymentMonitoringJob(
3014         com.google.cloud.aiplatform.v1.ResumeModelDeploymentMonitoringJobRequest request,
3015         io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) {
3016       io.grpc.stub.ClientCalls.asyncUnaryCall(
3017           getChannel().newCall(getResumeModelDeploymentMonitoringJobMethod(), getCallOptions()),
3018           request,
3019           responseObserver);
3020     }
3021   }
3022 
3023   /**
3024    * A stub to allow clients to do synchronous rpc calls to service JobService.
3025    *
3026    * <pre>
3027    * A service for creating and managing Vertex AI's jobs.
3028    * </pre>
3029    */
3030   public static final class JobServiceBlockingStub
3031       extends io.grpc.stub.AbstractBlockingStub<JobServiceBlockingStub> {
JobServiceBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions)3032     private JobServiceBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
3033       super(channel, callOptions);
3034     }
3035 
3036     @java.lang.Override
build( io.grpc.Channel channel, io.grpc.CallOptions callOptions)3037     protected JobServiceBlockingStub build(
3038         io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
3039       return new JobServiceBlockingStub(channel, callOptions);
3040     }
3041 
3042     /**
3043      *
3044      *
3045      * <pre>
3046      * Creates a CustomJob. A created CustomJob right away
3047      * will be attempted to be run.
3048      * </pre>
3049      */
createCustomJob( com.google.cloud.aiplatform.v1.CreateCustomJobRequest request)3050     public com.google.cloud.aiplatform.v1.CustomJob createCustomJob(
3051         com.google.cloud.aiplatform.v1.CreateCustomJobRequest request) {
3052       return io.grpc.stub.ClientCalls.blockingUnaryCall(
3053           getChannel(), getCreateCustomJobMethod(), getCallOptions(), request);
3054     }
3055 
3056     /**
3057      *
3058      *
3059      * <pre>
3060      * Gets a CustomJob.
3061      * </pre>
3062      */
getCustomJob( com.google.cloud.aiplatform.v1.GetCustomJobRequest request)3063     public com.google.cloud.aiplatform.v1.CustomJob getCustomJob(
3064         com.google.cloud.aiplatform.v1.GetCustomJobRequest request) {
3065       return io.grpc.stub.ClientCalls.blockingUnaryCall(
3066           getChannel(), getGetCustomJobMethod(), getCallOptions(), request);
3067     }
3068 
3069     /**
3070      *
3071      *
3072      * <pre>
3073      * Lists CustomJobs in a Location.
3074      * </pre>
3075      */
listCustomJobs( com.google.cloud.aiplatform.v1.ListCustomJobsRequest request)3076     public com.google.cloud.aiplatform.v1.ListCustomJobsResponse listCustomJobs(
3077         com.google.cloud.aiplatform.v1.ListCustomJobsRequest request) {
3078       return io.grpc.stub.ClientCalls.blockingUnaryCall(
3079           getChannel(), getListCustomJobsMethod(), getCallOptions(), request);
3080     }
3081 
3082     /**
3083      *
3084      *
3085      * <pre>
3086      * Deletes a CustomJob.
3087      * </pre>
3088      */
deleteCustomJob( com.google.cloud.aiplatform.v1.DeleteCustomJobRequest request)3089     public com.google.longrunning.Operation deleteCustomJob(
3090         com.google.cloud.aiplatform.v1.DeleteCustomJobRequest request) {
3091       return io.grpc.stub.ClientCalls.blockingUnaryCall(
3092           getChannel(), getDeleteCustomJobMethod(), getCallOptions(), request);
3093     }
3094 
3095     /**
3096      *
3097      *
3098      * <pre>
3099      * Cancels a CustomJob.
3100      * Starts asynchronous cancellation on the CustomJob. The server
3101      * makes a best effort to cancel the job, but success is not
3102      * guaranteed. Clients can use
3103      * [JobService.GetCustomJob][google.cloud.aiplatform.v1.JobService.GetCustomJob]
3104      * or other methods to check whether the cancellation succeeded or whether the
3105      * job completed despite cancellation. On successful cancellation,
3106      * the CustomJob is not deleted; instead it becomes a job with
3107      * a [CustomJob.error][google.cloud.aiplatform.v1.CustomJob.error] value with
3108      * a [google.rpc.Status.code][google.rpc.Status.code] of 1, corresponding to
3109      * `Code.CANCELLED`, and
3110      * [CustomJob.state][google.cloud.aiplatform.v1.CustomJob.state] is set to
3111      * `CANCELLED`.
3112      * </pre>
3113      */
cancelCustomJob( com.google.cloud.aiplatform.v1.CancelCustomJobRequest request)3114     public com.google.protobuf.Empty cancelCustomJob(
3115         com.google.cloud.aiplatform.v1.CancelCustomJobRequest request) {
3116       return io.grpc.stub.ClientCalls.blockingUnaryCall(
3117           getChannel(), getCancelCustomJobMethod(), getCallOptions(), request);
3118     }
3119 
3120     /**
3121      *
3122      *
3123      * <pre>
3124      * Creates a DataLabelingJob.
3125      * </pre>
3126      */
createDataLabelingJob( com.google.cloud.aiplatform.v1.CreateDataLabelingJobRequest request)3127     public com.google.cloud.aiplatform.v1.DataLabelingJob createDataLabelingJob(
3128         com.google.cloud.aiplatform.v1.CreateDataLabelingJobRequest request) {
3129       return io.grpc.stub.ClientCalls.blockingUnaryCall(
3130           getChannel(), getCreateDataLabelingJobMethod(), getCallOptions(), request);
3131     }
3132 
3133     /**
3134      *
3135      *
3136      * <pre>
3137      * Gets a DataLabelingJob.
3138      * </pre>
3139      */
getDataLabelingJob( com.google.cloud.aiplatform.v1.GetDataLabelingJobRequest request)3140     public com.google.cloud.aiplatform.v1.DataLabelingJob getDataLabelingJob(
3141         com.google.cloud.aiplatform.v1.GetDataLabelingJobRequest request) {
3142       return io.grpc.stub.ClientCalls.blockingUnaryCall(
3143           getChannel(), getGetDataLabelingJobMethod(), getCallOptions(), request);
3144     }
3145 
3146     /**
3147      *
3148      *
3149      * <pre>
3150      * Lists DataLabelingJobs in a Location.
3151      * </pre>
3152      */
listDataLabelingJobs( com.google.cloud.aiplatform.v1.ListDataLabelingJobsRequest request)3153     public com.google.cloud.aiplatform.v1.ListDataLabelingJobsResponse listDataLabelingJobs(
3154         com.google.cloud.aiplatform.v1.ListDataLabelingJobsRequest request) {
3155       return io.grpc.stub.ClientCalls.blockingUnaryCall(
3156           getChannel(), getListDataLabelingJobsMethod(), getCallOptions(), request);
3157     }
3158 
3159     /**
3160      *
3161      *
3162      * <pre>
3163      * Deletes a DataLabelingJob.
3164      * </pre>
3165      */
deleteDataLabelingJob( com.google.cloud.aiplatform.v1.DeleteDataLabelingJobRequest request)3166     public com.google.longrunning.Operation deleteDataLabelingJob(
3167         com.google.cloud.aiplatform.v1.DeleteDataLabelingJobRequest request) {
3168       return io.grpc.stub.ClientCalls.blockingUnaryCall(
3169           getChannel(), getDeleteDataLabelingJobMethod(), getCallOptions(), request);
3170     }
3171 
3172     /**
3173      *
3174      *
3175      * <pre>
3176      * Cancels a DataLabelingJob. Success of cancellation is not guaranteed.
3177      * </pre>
3178      */
cancelDataLabelingJob( com.google.cloud.aiplatform.v1.CancelDataLabelingJobRequest request)3179     public com.google.protobuf.Empty cancelDataLabelingJob(
3180         com.google.cloud.aiplatform.v1.CancelDataLabelingJobRequest request) {
3181       return io.grpc.stub.ClientCalls.blockingUnaryCall(
3182           getChannel(), getCancelDataLabelingJobMethod(), getCallOptions(), request);
3183     }
3184 
3185     /**
3186      *
3187      *
3188      * <pre>
3189      * Creates a HyperparameterTuningJob
3190      * </pre>
3191      */
createHyperparameterTuningJob( com.google.cloud.aiplatform.v1.CreateHyperparameterTuningJobRequest request)3192     public com.google.cloud.aiplatform.v1.HyperparameterTuningJob createHyperparameterTuningJob(
3193         com.google.cloud.aiplatform.v1.CreateHyperparameterTuningJobRequest request) {
3194       return io.grpc.stub.ClientCalls.blockingUnaryCall(
3195           getChannel(), getCreateHyperparameterTuningJobMethod(), getCallOptions(), request);
3196     }
3197 
3198     /**
3199      *
3200      *
3201      * <pre>
3202      * Gets a HyperparameterTuningJob
3203      * </pre>
3204      */
getHyperparameterTuningJob( com.google.cloud.aiplatform.v1.GetHyperparameterTuningJobRequest request)3205     public com.google.cloud.aiplatform.v1.HyperparameterTuningJob getHyperparameterTuningJob(
3206         com.google.cloud.aiplatform.v1.GetHyperparameterTuningJobRequest request) {
3207       return io.grpc.stub.ClientCalls.blockingUnaryCall(
3208           getChannel(), getGetHyperparameterTuningJobMethod(), getCallOptions(), request);
3209     }
3210 
3211     /**
3212      *
3213      *
3214      * <pre>
3215      * Lists HyperparameterTuningJobs in a Location.
3216      * </pre>
3217      */
3218     public com.google.cloud.aiplatform.v1.ListHyperparameterTuningJobsResponse
listHyperparameterTuningJobs( com.google.cloud.aiplatform.v1.ListHyperparameterTuningJobsRequest request)3219         listHyperparameterTuningJobs(
3220             com.google.cloud.aiplatform.v1.ListHyperparameterTuningJobsRequest request) {
3221       return io.grpc.stub.ClientCalls.blockingUnaryCall(
3222           getChannel(), getListHyperparameterTuningJobsMethod(), getCallOptions(), request);
3223     }
3224 
3225     /**
3226      *
3227      *
3228      * <pre>
3229      * Deletes a HyperparameterTuningJob.
3230      * </pre>
3231      */
deleteHyperparameterTuningJob( com.google.cloud.aiplatform.v1.DeleteHyperparameterTuningJobRequest request)3232     public com.google.longrunning.Operation deleteHyperparameterTuningJob(
3233         com.google.cloud.aiplatform.v1.DeleteHyperparameterTuningJobRequest request) {
3234       return io.grpc.stub.ClientCalls.blockingUnaryCall(
3235           getChannel(), getDeleteHyperparameterTuningJobMethod(), getCallOptions(), request);
3236     }
3237 
3238     /**
3239      *
3240      *
3241      * <pre>
3242      * Cancels a HyperparameterTuningJob.
3243      * Starts asynchronous cancellation on the HyperparameterTuningJob. The server
3244      * makes a best effort to cancel the job, but success is not
3245      * guaranteed. Clients can use
3246      * [JobService.GetHyperparameterTuningJob][google.cloud.aiplatform.v1.JobService.GetHyperparameterTuningJob]
3247      * or other methods to check whether the cancellation succeeded or whether the
3248      * job completed despite cancellation. On successful cancellation,
3249      * the HyperparameterTuningJob is not deleted; instead it becomes a job with
3250      * a
3251      * [HyperparameterTuningJob.error][google.cloud.aiplatform.v1.HyperparameterTuningJob.error]
3252      * value with a [google.rpc.Status.code][google.rpc.Status.code] of 1,
3253      * corresponding to `Code.CANCELLED`, and
3254      * [HyperparameterTuningJob.state][google.cloud.aiplatform.v1.HyperparameterTuningJob.state]
3255      * is set to `CANCELLED`.
3256      * </pre>
3257      */
cancelHyperparameterTuningJob( com.google.cloud.aiplatform.v1.CancelHyperparameterTuningJobRequest request)3258     public com.google.protobuf.Empty cancelHyperparameterTuningJob(
3259         com.google.cloud.aiplatform.v1.CancelHyperparameterTuningJobRequest request) {
3260       return io.grpc.stub.ClientCalls.blockingUnaryCall(
3261           getChannel(), getCancelHyperparameterTuningJobMethod(), getCallOptions(), request);
3262     }
3263 
3264     /**
3265      *
3266      *
3267      * <pre>
3268      * Creates a NasJob
3269      * </pre>
3270      */
createNasJob( com.google.cloud.aiplatform.v1.CreateNasJobRequest request)3271     public com.google.cloud.aiplatform.v1.NasJob createNasJob(
3272         com.google.cloud.aiplatform.v1.CreateNasJobRequest request) {
3273       return io.grpc.stub.ClientCalls.blockingUnaryCall(
3274           getChannel(), getCreateNasJobMethod(), getCallOptions(), request);
3275     }
3276 
3277     /**
3278      *
3279      *
3280      * <pre>
3281      * Gets a NasJob
3282      * </pre>
3283      */
getNasJob( com.google.cloud.aiplatform.v1.GetNasJobRequest request)3284     public com.google.cloud.aiplatform.v1.NasJob getNasJob(
3285         com.google.cloud.aiplatform.v1.GetNasJobRequest request) {
3286       return io.grpc.stub.ClientCalls.blockingUnaryCall(
3287           getChannel(), getGetNasJobMethod(), getCallOptions(), request);
3288     }
3289 
3290     /**
3291      *
3292      *
3293      * <pre>
3294      * Lists NasJobs in a Location.
3295      * </pre>
3296      */
listNasJobs( com.google.cloud.aiplatform.v1.ListNasJobsRequest request)3297     public com.google.cloud.aiplatform.v1.ListNasJobsResponse listNasJobs(
3298         com.google.cloud.aiplatform.v1.ListNasJobsRequest request) {
3299       return io.grpc.stub.ClientCalls.blockingUnaryCall(
3300           getChannel(), getListNasJobsMethod(), getCallOptions(), request);
3301     }
3302 
3303     /**
3304      *
3305      *
3306      * <pre>
3307      * Deletes a NasJob.
3308      * </pre>
3309      */
deleteNasJob( com.google.cloud.aiplatform.v1.DeleteNasJobRequest request)3310     public com.google.longrunning.Operation deleteNasJob(
3311         com.google.cloud.aiplatform.v1.DeleteNasJobRequest request) {
3312       return io.grpc.stub.ClientCalls.blockingUnaryCall(
3313           getChannel(), getDeleteNasJobMethod(), getCallOptions(), request);
3314     }
3315 
3316     /**
3317      *
3318      *
3319      * <pre>
3320      * Cancels a NasJob.
3321      * Starts asynchronous cancellation on the NasJob. The server
3322      * makes a best effort to cancel the job, but success is not
3323      * guaranteed. Clients can use
3324      * [JobService.GetNasJob][google.cloud.aiplatform.v1.JobService.GetNasJob] or
3325      * other methods to check whether the cancellation succeeded or whether the
3326      * job completed despite cancellation. On successful cancellation,
3327      * the NasJob is not deleted; instead it becomes a job with
3328      * a [NasJob.error][google.cloud.aiplatform.v1.NasJob.error] value with a
3329      * [google.rpc.Status.code][google.rpc.Status.code] of 1, corresponding to
3330      * `Code.CANCELLED`, and
3331      * [NasJob.state][google.cloud.aiplatform.v1.NasJob.state] is set to
3332      * `CANCELLED`.
3333      * </pre>
3334      */
cancelNasJob( com.google.cloud.aiplatform.v1.CancelNasJobRequest request)3335     public com.google.protobuf.Empty cancelNasJob(
3336         com.google.cloud.aiplatform.v1.CancelNasJobRequest request) {
3337       return io.grpc.stub.ClientCalls.blockingUnaryCall(
3338           getChannel(), getCancelNasJobMethod(), getCallOptions(), request);
3339     }
3340 
3341     /**
3342      *
3343      *
3344      * <pre>
3345      * Gets a NasTrialDetail.
3346      * </pre>
3347      */
getNasTrialDetail( com.google.cloud.aiplatform.v1.GetNasTrialDetailRequest request)3348     public com.google.cloud.aiplatform.v1.NasTrialDetail getNasTrialDetail(
3349         com.google.cloud.aiplatform.v1.GetNasTrialDetailRequest request) {
3350       return io.grpc.stub.ClientCalls.blockingUnaryCall(
3351           getChannel(), getGetNasTrialDetailMethod(), getCallOptions(), request);
3352     }
3353 
3354     /**
3355      *
3356      *
3357      * <pre>
3358      * List top NasTrialDetails of a NasJob.
3359      * </pre>
3360      */
listNasTrialDetails( com.google.cloud.aiplatform.v1.ListNasTrialDetailsRequest request)3361     public com.google.cloud.aiplatform.v1.ListNasTrialDetailsResponse listNasTrialDetails(
3362         com.google.cloud.aiplatform.v1.ListNasTrialDetailsRequest request) {
3363       return io.grpc.stub.ClientCalls.blockingUnaryCall(
3364           getChannel(), getListNasTrialDetailsMethod(), getCallOptions(), request);
3365     }
3366 
3367     /**
3368      *
3369      *
3370      * <pre>
3371      * Creates a BatchPredictionJob. A BatchPredictionJob once created will
3372      * right away be attempted to start.
3373      * </pre>
3374      */
createBatchPredictionJob( com.google.cloud.aiplatform.v1.CreateBatchPredictionJobRequest request)3375     public com.google.cloud.aiplatform.v1.BatchPredictionJob createBatchPredictionJob(
3376         com.google.cloud.aiplatform.v1.CreateBatchPredictionJobRequest request) {
3377       return io.grpc.stub.ClientCalls.blockingUnaryCall(
3378           getChannel(), getCreateBatchPredictionJobMethod(), getCallOptions(), request);
3379     }
3380 
3381     /**
3382      *
3383      *
3384      * <pre>
3385      * Gets a BatchPredictionJob
3386      * </pre>
3387      */
getBatchPredictionJob( com.google.cloud.aiplatform.v1.GetBatchPredictionJobRequest request)3388     public com.google.cloud.aiplatform.v1.BatchPredictionJob getBatchPredictionJob(
3389         com.google.cloud.aiplatform.v1.GetBatchPredictionJobRequest request) {
3390       return io.grpc.stub.ClientCalls.blockingUnaryCall(
3391           getChannel(), getGetBatchPredictionJobMethod(), getCallOptions(), request);
3392     }
3393 
3394     /**
3395      *
3396      *
3397      * <pre>
3398      * Lists BatchPredictionJobs in a Location.
3399      * </pre>
3400      */
listBatchPredictionJobs( com.google.cloud.aiplatform.v1.ListBatchPredictionJobsRequest request)3401     public com.google.cloud.aiplatform.v1.ListBatchPredictionJobsResponse listBatchPredictionJobs(
3402         com.google.cloud.aiplatform.v1.ListBatchPredictionJobsRequest request) {
3403       return io.grpc.stub.ClientCalls.blockingUnaryCall(
3404           getChannel(), getListBatchPredictionJobsMethod(), getCallOptions(), request);
3405     }
3406 
3407     /**
3408      *
3409      *
3410      * <pre>
3411      * Deletes a BatchPredictionJob. Can only be called on jobs that already
3412      * finished.
3413      * </pre>
3414      */
deleteBatchPredictionJob( com.google.cloud.aiplatform.v1.DeleteBatchPredictionJobRequest request)3415     public com.google.longrunning.Operation deleteBatchPredictionJob(
3416         com.google.cloud.aiplatform.v1.DeleteBatchPredictionJobRequest request) {
3417       return io.grpc.stub.ClientCalls.blockingUnaryCall(
3418           getChannel(), getDeleteBatchPredictionJobMethod(), getCallOptions(), request);
3419     }
3420 
3421     /**
3422      *
3423      *
3424      * <pre>
3425      * Cancels a BatchPredictionJob.
3426      * Starts asynchronous cancellation on the BatchPredictionJob. The server
3427      * makes the best effort to cancel the job, but success is not
3428      * guaranteed. Clients can use
3429      * [JobService.GetBatchPredictionJob][google.cloud.aiplatform.v1.JobService.GetBatchPredictionJob]
3430      * or other methods to check whether the cancellation succeeded or whether the
3431      * job completed despite cancellation. On a successful cancellation,
3432      * the BatchPredictionJob is not deleted;instead its
3433      * [BatchPredictionJob.state][google.cloud.aiplatform.v1.BatchPredictionJob.state]
3434      * is set to `CANCELLED`. Any files already outputted by the job are not
3435      * deleted.
3436      * </pre>
3437      */
cancelBatchPredictionJob( com.google.cloud.aiplatform.v1.CancelBatchPredictionJobRequest request)3438     public com.google.protobuf.Empty cancelBatchPredictionJob(
3439         com.google.cloud.aiplatform.v1.CancelBatchPredictionJobRequest request) {
3440       return io.grpc.stub.ClientCalls.blockingUnaryCall(
3441           getChannel(), getCancelBatchPredictionJobMethod(), getCallOptions(), request);
3442     }
3443 
3444     /**
3445      *
3446      *
3447      * <pre>
3448      * Creates a ModelDeploymentMonitoringJob. It will run periodically on a
3449      * configured interval.
3450      * </pre>
3451      */
3452     public com.google.cloud.aiplatform.v1.ModelDeploymentMonitoringJob
createModelDeploymentMonitoringJob( com.google.cloud.aiplatform.v1.CreateModelDeploymentMonitoringJobRequest request)3453         createModelDeploymentMonitoringJob(
3454             com.google.cloud.aiplatform.v1.CreateModelDeploymentMonitoringJobRequest request) {
3455       return io.grpc.stub.ClientCalls.blockingUnaryCall(
3456           getChannel(), getCreateModelDeploymentMonitoringJobMethod(), getCallOptions(), request);
3457     }
3458 
3459     /**
3460      *
3461      *
3462      * <pre>
3463      * Searches Model Monitoring Statistics generated within a given time window.
3464      * </pre>
3465      */
3466     public com.google.cloud.aiplatform.v1.SearchModelDeploymentMonitoringStatsAnomaliesResponse
searchModelDeploymentMonitoringStatsAnomalies( com.google.cloud.aiplatform.v1.SearchModelDeploymentMonitoringStatsAnomaliesRequest request)3467         searchModelDeploymentMonitoringStatsAnomalies(
3468             com.google.cloud.aiplatform.v1.SearchModelDeploymentMonitoringStatsAnomaliesRequest
3469                 request) {
3470       return io.grpc.stub.ClientCalls.blockingUnaryCall(
3471           getChannel(),
3472           getSearchModelDeploymentMonitoringStatsAnomaliesMethod(),
3473           getCallOptions(),
3474           request);
3475     }
3476 
3477     /**
3478      *
3479      *
3480      * <pre>
3481      * Gets a ModelDeploymentMonitoringJob.
3482      * </pre>
3483      */
3484     public com.google.cloud.aiplatform.v1.ModelDeploymentMonitoringJob
getModelDeploymentMonitoringJob( com.google.cloud.aiplatform.v1.GetModelDeploymentMonitoringJobRequest request)3485         getModelDeploymentMonitoringJob(
3486             com.google.cloud.aiplatform.v1.GetModelDeploymentMonitoringJobRequest request) {
3487       return io.grpc.stub.ClientCalls.blockingUnaryCall(
3488           getChannel(), getGetModelDeploymentMonitoringJobMethod(), getCallOptions(), request);
3489     }
3490 
3491     /**
3492      *
3493      *
3494      * <pre>
3495      * Lists ModelDeploymentMonitoringJobs in a Location.
3496      * </pre>
3497      */
3498     public com.google.cloud.aiplatform.v1.ListModelDeploymentMonitoringJobsResponse
listModelDeploymentMonitoringJobs( com.google.cloud.aiplatform.v1.ListModelDeploymentMonitoringJobsRequest request)3499         listModelDeploymentMonitoringJobs(
3500             com.google.cloud.aiplatform.v1.ListModelDeploymentMonitoringJobsRequest request) {
3501       return io.grpc.stub.ClientCalls.blockingUnaryCall(
3502           getChannel(), getListModelDeploymentMonitoringJobsMethod(), getCallOptions(), request);
3503     }
3504 
3505     /**
3506      *
3507      *
3508      * <pre>
3509      * Updates a ModelDeploymentMonitoringJob.
3510      * </pre>
3511      */
updateModelDeploymentMonitoringJob( com.google.cloud.aiplatform.v1.UpdateModelDeploymentMonitoringJobRequest request)3512     public com.google.longrunning.Operation updateModelDeploymentMonitoringJob(
3513         com.google.cloud.aiplatform.v1.UpdateModelDeploymentMonitoringJobRequest request) {
3514       return io.grpc.stub.ClientCalls.blockingUnaryCall(
3515           getChannel(), getUpdateModelDeploymentMonitoringJobMethod(), getCallOptions(), request);
3516     }
3517 
3518     /**
3519      *
3520      *
3521      * <pre>
3522      * Deletes a ModelDeploymentMonitoringJob.
3523      * </pre>
3524      */
deleteModelDeploymentMonitoringJob( com.google.cloud.aiplatform.v1.DeleteModelDeploymentMonitoringJobRequest request)3525     public com.google.longrunning.Operation deleteModelDeploymentMonitoringJob(
3526         com.google.cloud.aiplatform.v1.DeleteModelDeploymentMonitoringJobRequest request) {
3527       return io.grpc.stub.ClientCalls.blockingUnaryCall(
3528           getChannel(), getDeleteModelDeploymentMonitoringJobMethod(), getCallOptions(), request);
3529     }
3530 
3531     /**
3532      *
3533      *
3534      * <pre>
3535      * Pauses a ModelDeploymentMonitoringJob. If the job is running, the server
3536      * makes a best effort to cancel the job. Will mark
3537      * [ModelDeploymentMonitoringJob.state][google.cloud.aiplatform.v1.ModelDeploymentMonitoringJob.state]
3538      * to 'PAUSED'.
3539      * </pre>
3540      */
pauseModelDeploymentMonitoringJob( com.google.cloud.aiplatform.v1.PauseModelDeploymentMonitoringJobRequest request)3541     public com.google.protobuf.Empty pauseModelDeploymentMonitoringJob(
3542         com.google.cloud.aiplatform.v1.PauseModelDeploymentMonitoringJobRequest request) {
3543       return io.grpc.stub.ClientCalls.blockingUnaryCall(
3544           getChannel(), getPauseModelDeploymentMonitoringJobMethod(), getCallOptions(), request);
3545     }
3546 
3547     /**
3548      *
3549      *
3550      * <pre>
3551      * Resumes a paused ModelDeploymentMonitoringJob. It will start to run from
3552      * next scheduled time. A deleted ModelDeploymentMonitoringJob can't be
3553      * resumed.
3554      * </pre>
3555      */
resumeModelDeploymentMonitoringJob( com.google.cloud.aiplatform.v1.ResumeModelDeploymentMonitoringJobRequest request)3556     public com.google.protobuf.Empty resumeModelDeploymentMonitoringJob(
3557         com.google.cloud.aiplatform.v1.ResumeModelDeploymentMonitoringJobRequest request) {
3558       return io.grpc.stub.ClientCalls.blockingUnaryCall(
3559           getChannel(), getResumeModelDeploymentMonitoringJobMethod(), getCallOptions(), request);
3560     }
3561   }
3562 
3563   /**
3564    * A stub to allow clients to do ListenableFuture-style rpc calls to service JobService.
3565    *
3566    * <pre>
3567    * A service for creating and managing Vertex AI's jobs.
3568    * </pre>
3569    */
3570   public static final class JobServiceFutureStub
3571       extends io.grpc.stub.AbstractFutureStub<JobServiceFutureStub> {
JobServiceFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions)3572     private JobServiceFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
3573       super(channel, callOptions);
3574     }
3575 
3576     @java.lang.Override
build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)3577     protected JobServiceFutureStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
3578       return new JobServiceFutureStub(channel, callOptions);
3579     }
3580 
3581     /**
3582      *
3583      *
3584      * <pre>
3585      * Creates a CustomJob. A created CustomJob right away
3586      * will be attempted to be run.
3587      * </pre>
3588      */
3589     public com.google.common.util.concurrent.ListenableFuture<
3590             com.google.cloud.aiplatform.v1.CustomJob>
createCustomJob(com.google.cloud.aiplatform.v1.CreateCustomJobRequest request)3591         createCustomJob(com.google.cloud.aiplatform.v1.CreateCustomJobRequest request) {
3592       return io.grpc.stub.ClientCalls.futureUnaryCall(
3593           getChannel().newCall(getCreateCustomJobMethod(), getCallOptions()), request);
3594     }
3595 
3596     /**
3597      *
3598      *
3599      * <pre>
3600      * Gets a CustomJob.
3601      * </pre>
3602      */
3603     public com.google.common.util.concurrent.ListenableFuture<
3604             com.google.cloud.aiplatform.v1.CustomJob>
getCustomJob(com.google.cloud.aiplatform.v1.GetCustomJobRequest request)3605         getCustomJob(com.google.cloud.aiplatform.v1.GetCustomJobRequest request) {
3606       return io.grpc.stub.ClientCalls.futureUnaryCall(
3607           getChannel().newCall(getGetCustomJobMethod(), getCallOptions()), request);
3608     }
3609 
3610     /**
3611      *
3612      *
3613      * <pre>
3614      * Lists CustomJobs in a Location.
3615      * </pre>
3616      */
3617     public com.google.common.util.concurrent.ListenableFuture<
3618             com.google.cloud.aiplatform.v1.ListCustomJobsResponse>
listCustomJobs(com.google.cloud.aiplatform.v1.ListCustomJobsRequest request)3619         listCustomJobs(com.google.cloud.aiplatform.v1.ListCustomJobsRequest request) {
3620       return io.grpc.stub.ClientCalls.futureUnaryCall(
3621           getChannel().newCall(getListCustomJobsMethod(), getCallOptions()), request);
3622     }
3623 
3624     /**
3625      *
3626      *
3627      * <pre>
3628      * Deletes a CustomJob.
3629      * </pre>
3630      */
3631     public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation>
deleteCustomJob(com.google.cloud.aiplatform.v1.DeleteCustomJobRequest request)3632         deleteCustomJob(com.google.cloud.aiplatform.v1.DeleteCustomJobRequest request) {
3633       return io.grpc.stub.ClientCalls.futureUnaryCall(
3634           getChannel().newCall(getDeleteCustomJobMethod(), getCallOptions()), request);
3635     }
3636 
3637     /**
3638      *
3639      *
3640      * <pre>
3641      * Cancels a CustomJob.
3642      * Starts asynchronous cancellation on the CustomJob. The server
3643      * makes a best effort to cancel the job, but success is not
3644      * guaranteed. Clients can use
3645      * [JobService.GetCustomJob][google.cloud.aiplatform.v1.JobService.GetCustomJob]
3646      * or other methods to check whether the cancellation succeeded or whether the
3647      * job completed despite cancellation. On successful cancellation,
3648      * the CustomJob is not deleted; instead it becomes a job with
3649      * a [CustomJob.error][google.cloud.aiplatform.v1.CustomJob.error] value with
3650      * a [google.rpc.Status.code][google.rpc.Status.code] of 1, corresponding to
3651      * `Code.CANCELLED`, and
3652      * [CustomJob.state][google.cloud.aiplatform.v1.CustomJob.state] is set to
3653      * `CANCELLED`.
3654      * </pre>
3655      */
3656     public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>
cancelCustomJob(com.google.cloud.aiplatform.v1.CancelCustomJobRequest request)3657         cancelCustomJob(com.google.cloud.aiplatform.v1.CancelCustomJobRequest request) {
3658       return io.grpc.stub.ClientCalls.futureUnaryCall(
3659           getChannel().newCall(getCancelCustomJobMethod(), getCallOptions()), request);
3660     }
3661 
3662     /**
3663      *
3664      *
3665      * <pre>
3666      * Creates a DataLabelingJob.
3667      * </pre>
3668      */
3669     public com.google.common.util.concurrent.ListenableFuture<
3670             com.google.cloud.aiplatform.v1.DataLabelingJob>
createDataLabelingJob(com.google.cloud.aiplatform.v1.CreateDataLabelingJobRequest request)3671         createDataLabelingJob(com.google.cloud.aiplatform.v1.CreateDataLabelingJobRequest request) {
3672       return io.grpc.stub.ClientCalls.futureUnaryCall(
3673           getChannel().newCall(getCreateDataLabelingJobMethod(), getCallOptions()), request);
3674     }
3675 
3676     /**
3677      *
3678      *
3679      * <pre>
3680      * Gets a DataLabelingJob.
3681      * </pre>
3682      */
3683     public com.google.common.util.concurrent.ListenableFuture<
3684             com.google.cloud.aiplatform.v1.DataLabelingJob>
getDataLabelingJob(com.google.cloud.aiplatform.v1.GetDataLabelingJobRequest request)3685         getDataLabelingJob(com.google.cloud.aiplatform.v1.GetDataLabelingJobRequest request) {
3686       return io.grpc.stub.ClientCalls.futureUnaryCall(
3687           getChannel().newCall(getGetDataLabelingJobMethod(), getCallOptions()), request);
3688     }
3689 
3690     /**
3691      *
3692      *
3693      * <pre>
3694      * Lists DataLabelingJobs in a Location.
3695      * </pre>
3696      */
3697     public com.google.common.util.concurrent.ListenableFuture<
3698             com.google.cloud.aiplatform.v1.ListDataLabelingJobsResponse>
listDataLabelingJobs(com.google.cloud.aiplatform.v1.ListDataLabelingJobsRequest request)3699         listDataLabelingJobs(com.google.cloud.aiplatform.v1.ListDataLabelingJobsRequest request) {
3700       return io.grpc.stub.ClientCalls.futureUnaryCall(
3701           getChannel().newCall(getListDataLabelingJobsMethod(), getCallOptions()), request);
3702     }
3703 
3704     /**
3705      *
3706      *
3707      * <pre>
3708      * Deletes a DataLabelingJob.
3709      * </pre>
3710      */
3711     public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation>
deleteDataLabelingJob(com.google.cloud.aiplatform.v1.DeleteDataLabelingJobRequest request)3712         deleteDataLabelingJob(com.google.cloud.aiplatform.v1.DeleteDataLabelingJobRequest request) {
3713       return io.grpc.stub.ClientCalls.futureUnaryCall(
3714           getChannel().newCall(getDeleteDataLabelingJobMethod(), getCallOptions()), request);
3715     }
3716 
3717     /**
3718      *
3719      *
3720      * <pre>
3721      * Cancels a DataLabelingJob. Success of cancellation is not guaranteed.
3722      * </pre>
3723      */
3724     public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>
cancelDataLabelingJob(com.google.cloud.aiplatform.v1.CancelDataLabelingJobRequest request)3725         cancelDataLabelingJob(com.google.cloud.aiplatform.v1.CancelDataLabelingJobRequest request) {
3726       return io.grpc.stub.ClientCalls.futureUnaryCall(
3727           getChannel().newCall(getCancelDataLabelingJobMethod(), getCallOptions()), request);
3728     }
3729 
3730     /**
3731      *
3732      *
3733      * <pre>
3734      * Creates a HyperparameterTuningJob
3735      * </pre>
3736      */
3737     public com.google.common.util.concurrent.ListenableFuture<
3738             com.google.cloud.aiplatform.v1.HyperparameterTuningJob>
createHyperparameterTuningJob( com.google.cloud.aiplatform.v1.CreateHyperparameterTuningJobRequest request)3739         createHyperparameterTuningJob(
3740             com.google.cloud.aiplatform.v1.CreateHyperparameterTuningJobRequest request) {
3741       return io.grpc.stub.ClientCalls.futureUnaryCall(
3742           getChannel().newCall(getCreateHyperparameterTuningJobMethod(), getCallOptions()),
3743           request);
3744     }
3745 
3746     /**
3747      *
3748      *
3749      * <pre>
3750      * Gets a HyperparameterTuningJob
3751      * </pre>
3752      */
3753     public com.google.common.util.concurrent.ListenableFuture<
3754             com.google.cloud.aiplatform.v1.HyperparameterTuningJob>
getHyperparameterTuningJob( com.google.cloud.aiplatform.v1.GetHyperparameterTuningJobRequest request)3755         getHyperparameterTuningJob(
3756             com.google.cloud.aiplatform.v1.GetHyperparameterTuningJobRequest request) {
3757       return io.grpc.stub.ClientCalls.futureUnaryCall(
3758           getChannel().newCall(getGetHyperparameterTuningJobMethod(), getCallOptions()), request);
3759     }
3760 
3761     /**
3762      *
3763      *
3764      * <pre>
3765      * Lists HyperparameterTuningJobs in a Location.
3766      * </pre>
3767      */
3768     public com.google.common.util.concurrent.ListenableFuture<
3769             com.google.cloud.aiplatform.v1.ListHyperparameterTuningJobsResponse>
listHyperparameterTuningJobs( com.google.cloud.aiplatform.v1.ListHyperparameterTuningJobsRequest request)3770         listHyperparameterTuningJobs(
3771             com.google.cloud.aiplatform.v1.ListHyperparameterTuningJobsRequest request) {
3772       return io.grpc.stub.ClientCalls.futureUnaryCall(
3773           getChannel().newCall(getListHyperparameterTuningJobsMethod(), getCallOptions()), request);
3774     }
3775 
3776     /**
3777      *
3778      *
3779      * <pre>
3780      * Deletes a HyperparameterTuningJob.
3781      * </pre>
3782      */
3783     public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation>
deleteHyperparameterTuningJob( com.google.cloud.aiplatform.v1.DeleteHyperparameterTuningJobRequest request)3784         deleteHyperparameterTuningJob(
3785             com.google.cloud.aiplatform.v1.DeleteHyperparameterTuningJobRequest request) {
3786       return io.grpc.stub.ClientCalls.futureUnaryCall(
3787           getChannel().newCall(getDeleteHyperparameterTuningJobMethod(), getCallOptions()),
3788           request);
3789     }
3790 
3791     /**
3792      *
3793      *
3794      * <pre>
3795      * Cancels a HyperparameterTuningJob.
3796      * Starts asynchronous cancellation on the HyperparameterTuningJob. The server
3797      * makes a best effort to cancel the job, but success is not
3798      * guaranteed. Clients can use
3799      * [JobService.GetHyperparameterTuningJob][google.cloud.aiplatform.v1.JobService.GetHyperparameterTuningJob]
3800      * or other methods to check whether the cancellation succeeded or whether the
3801      * job completed despite cancellation. On successful cancellation,
3802      * the HyperparameterTuningJob is not deleted; instead it becomes a job with
3803      * a
3804      * [HyperparameterTuningJob.error][google.cloud.aiplatform.v1.HyperparameterTuningJob.error]
3805      * value with a [google.rpc.Status.code][google.rpc.Status.code] of 1,
3806      * corresponding to `Code.CANCELLED`, and
3807      * [HyperparameterTuningJob.state][google.cloud.aiplatform.v1.HyperparameterTuningJob.state]
3808      * is set to `CANCELLED`.
3809      * </pre>
3810      */
3811     public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>
cancelHyperparameterTuningJob( com.google.cloud.aiplatform.v1.CancelHyperparameterTuningJobRequest request)3812         cancelHyperparameterTuningJob(
3813             com.google.cloud.aiplatform.v1.CancelHyperparameterTuningJobRequest request) {
3814       return io.grpc.stub.ClientCalls.futureUnaryCall(
3815           getChannel().newCall(getCancelHyperparameterTuningJobMethod(), getCallOptions()),
3816           request);
3817     }
3818 
3819     /**
3820      *
3821      *
3822      * <pre>
3823      * Creates a NasJob
3824      * </pre>
3825      */
3826     public com.google.common.util.concurrent.ListenableFuture<com.google.cloud.aiplatform.v1.NasJob>
createNasJob(com.google.cloud.aiplatform.v1.CreateNasJobRequest request)3827         createNasJob(com.google.cloud.aiplatform.v1.CreateNasJobRequest request) {
3828       return io.grpc.stub.ClientCalls.futureUnaryCall(
3829           getChannel().newCall(getCreateNasJobMethod(), getCallOptions()), request);
3830     }
3831 
3832     /**
3833      *
3834      *
3835      * <pre>
3836      * Gets a NasJob
3837      * </pre>
3838      */
3839     public com.google.common.util.concurrent.ListenableFuture<com.google.cloud.aiplatform.v1.NasJob>
getNasJob(com.google.cloud.aiplatform.v1.GetNasJobRequest request)3840         getNasJob(com.google.cloud.aiplatform.v1.GetNasJobRequest request) {
3841       return io.grpc.stub.ClientCalls.futureUnaryCall(
3842           getChannel().newCall(getGetNasJobMethod(), getCallOptions()), request);
3843     }
3844 
3845     /**
3846      *
3847      *
3848      * <pre>
3849      * Lists NasJobs in a Location.
3850      * </pre>
3851      */
3852     public com.google.common.util.concurrent.ListenableFuture<
3853             com.google.cloud.aiplatform.v1.ListNasJobsResponse>
listNasJobs(com.google.cloud.aiplatform.v1.ListNasJobsRequest request)3854         listNasJobs(com.google.cloud.aiplatform.v1.ListNasJobsRequest request) {
3855       return io.grpc.stub.ClientCalls.futureUnaryCall(
3856           getChannel().newCall(getListNasJobsMethod(), getCallOptions()), request);
3857     }
3858 
3859     /**
3860      *
3861      *
3862      * <pre>
3863      * Deletes a NasJob.
3864      * </pre>
3865      */
3866     public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation>
deleteNasJob(com.google.cloud.aiplatform.v1.DeleteNasJobRequest request)3867         deleteNasJob(com.google.cloud.aiplatform.v1.DeleteNasJobRequest request) {
3868       return io.grpc.stub.ClientCalls.futureUnaryCall(
3869           getChannel().newCall(getDeleteNasJobMethod(), getCallOptions()), request);
3870     }
3871 
3872     /**
3873      *
3874      *
3875      * <pre>
3876      * Cancels a NasJob.
3877      * Starts asynchronous cancellation on the NasJob. The server
3878      * makes a best effort to cancel the job, but success is not
3879      * guaranteed. Clients can use
3880      * [JobService.GetNasJob][google.cloud.aiplatform.v1.JobService.GetNasJob] or
3881      * other methods to check whether the cancellation succeeded or whether the
3882      * job completed despite cancellation. On successful cancellation,
3883      * the NasJob is not deleted; instead it becomes a job with
3884      * a [NasJob.error][google.cloud.aiplatform.v1.NasJob.error] value with a
3885      * [google.rpc.Status.code][google.rpc.Status.code] of 1, corresponding to
3886      * `Code.CANCELLED`, and
3887      * [NasJob.state][google.cloud.aiplatform.v1.NasJob.state] is set to
3888      * `CANCELLED`.
3889      * </pre>
3890      */
3891     public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>
cancelNasJob(com.google.cloud.aiplatform.v1.CancelNasJobRequest request)3892         cancelNasJob(com.google.cloud.aiplatform.v1.CancelNasJobRequest request) {
3893       return io.grpc.stub.ClientCalls.futureUnaryCall(
3894           getChannel().newCall(getCancelNasJobMethod(), getCallOptions()), request);
3895     }
3896 
3897     /**
3898      *
3899      *
3900      * <pre>
3901      * Gets a NasTrialDetail.
3902      * </pre>
3903      */
3904     public com.google.common.util.concurrent.ListenableFuture<
3905             com.google.cloud.aiplatform.v1.NasTrialDetail>
getNasTrialDetail(com.google.cloud.aiplatform.v1.GetNasTrialDetailRequest request)3906         getNasTrialDetail(com.google.cloud.aiplatform.v1.GetNasTrialDetailRequest request) {
3907       return io.grpc.stub.ClientCalls.futureUnaryCall(
3908           getChannel().newCall(getGetNasTrialDetailMethod(), getCallOptions()), request);
3909     }
3910 
3911     /**
3912      *
3913      *
3914      * <pre>
3915      * List top NasTrialDetails of a NasJob.
3916      * </pre>
3917      */
3918     public com.google.common.util.concurrent.ListenableFuture<
3919             com.google.cloud.aiplatform.v1.ListNasTrialDetailsResponse>
listNasTrialDetails(com.google.cloud.aiplatform.v1.ListNasTrialDetailsRequest request)3920         listNasTrialDetails(com.google.cloud.aiplatform.v1.ListNasTrialDetailsRequest request) {
3921       return io.grpc.stub.ClientCalls.futureUnaryCall(
3922           getChannel().newCall(getListNasTrialDetailsMethod(), getCallOptions()), request);
3923     }
3924 
3925     /**
3926      *
3927      *
3928      * <pre>
3929      * Creates a BatchPredictionJob. A BatchPredictionJob once created will
3930      * right away be attempted to start.
3931      * </pre>
3932      */
3933     public com.google.common.util.concurrent.ListenableFuture<
3934             com.google.cloud.aiplatform.v1.BatchPredictionJob>
createBatchPredictionJob( com.google.cloud.aiplatform.v1.CreateBatchPredictionJobRequest request)3935         createBatchPredictionJob(
3936             com.google.cloud.aiplatform.v1.CreateBatchPredictionJobRequest request) {
3937       return io.grpc.stub.ClientCalls.futureUnaryCall(
3938           getChannel().newCall(getCreateBatchPredictionJobMethod(), getCallOptions()), request);
3939     }
3940 
3941     /**
3942      *
3943      *
3944      * <pre>
3945      * Gets a BatchPredictionJob
3946      * </pre>
3947      */
3948     public com.google.common.util.concurrent.ListenableFuture<
3949             com.google.cloud.aiplatform.v1.BatchPredictionJob>
getBatchPredictionJob(com.google.cloud.aiplatform.v1.GetBatchPredictionJobRequest request)3950         getBatchPredictionJob(com.google.cloud.aiplatform.v1.GetBatchPredictionJobRequest request) {
3951       return io.grpc.stub.ClientCalls.futureUnaryCall(
3952           getChannel().newCall(getGetBatchPredictionJobMethod(), getCallOptions()), request);
3953     }
3954 
3955     /**
3956      *
3957      *
3958      * <pre>
3959      * Lists BatchPredictionJobs in a Location.
3960      * </pre>
3961      */
3962     public com.google.common.util.concurrent.ListenableFuture<
3963             com.google.cloud.aiplatform.v1.ListBatchPredictionJobsResponse>
listBatchPredictionJobs( com.google.cloud.aiplatform.v1.ListBatchPredictionJobsRequest request)3964         listBatchPredictionJobs(
3965             com.google.cloud.aiplatform.v1.ListBatchPredictionJobsRequest request) {
3966       return io.grpc.stub.ClientCalls.futureUnaryCall(
3967           getChannel().newCall(getListBatchPredictionJobsMethod(), getCallOptions()), request);
3968     }
3969 
3970     /**
3971      *
3972      *
3973      * <pre>
3974      * Deletes a BatchPredictionJob. Can only be called on jobs that already
3975      * finished.
3976      * </pre>
3977      */
3978     public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation>
deleteBatchPredictionJob( com.google.cloud.aiplatform.v1.DeleteBatchPredictionJobRequest request)3979         deleteBatchPredictionJob(
3980             com.google.cloud.aiplatform.v1.DeleteBatchPredictionJobRequest request) {
3981       return io.grpc.stub.ClientCalls.futureUnaryCall(
3982           getChannel().newCall(getDeleteBatchPredictionJobMethod(), getCallOptions()), request);
3983     }
3984 
3985     /**
3986      *
3987      *
3988      * <pre>
3989      * Cancels a BatchPredictionJob.
3990      * Starts asynchronous cancellation on the BatchPredictionJob. The server
3991      * makes the best effort to cancel the job, but success is not
3992      * guaranteed. Clients can use
3993      * [JobService.GetBatchPredictionJob][google.cloud.aiplatform.v1.JobService.GetBatchPredictionJob]
3994      * or other methods to check whether the cancellation succeeded or whether the
3995      * job completed despite cancellation. On a successful cancellation,
3996      * the BatchPredictionJob is not deleted;instead its
3997      * [BatchPredictionJob.state][google.cloud.aiplatform.v1.BatchPredictionJob.state]
3998      * is set to `CANCELLED`. Any files already outputted by the job are not
3999      * deleted.
4000      * </pre>
4001      */
4002     public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>
cancelBatchPredictionJob( com.google.cloud.aiplatform.v1.CancelBatchPredictionJobRequest request)4003         cancelBatchPredictionJob(
4004             com.google.cloud.aiplatform.v1.CancelBatchPredictionJobRequest request) {
4005       return io.grpc.stub.ClientCalls.futureUnaryCall(
4006           getChannel().newCall(getCancelBatchPredictionJobMethod(), getCallOptions()), request);
4007     }
4008 
4009     /**
4010      *
4011      *
4012      * <pre>
4013      * Creates a ModelDeploymentMonitoringJob. It will run periodically on a
4014      * configured interval.
4015      * </pre>
4016      */
4017     public com.google.common.util.concurrent.ListenableFuture<
4018             com.google.cloud.aiplatform.v1.ModelDeploymentMonitoringJob>
createModelDeploymentMonitoringJob( com.google.cloud.aiplatform.v1.CreateModelDeploymentMonitoringJobRequest request)4019         createModelDeploymentMonitoringJob(
4020             com.google.cloud.aiplatform.v1.CreateModelDeploymentMonitoringJobRequest request) {
4021       return io.grpc.stub.ClientCalls.futureUnaryCall(
4022           getChannel().newCall(getCreateModelDeploymentMonitoringJobMethod(), getCallOptions()),
4023           request);
4024     }
4025 
4026     /**
4027      *
4028      *
4029      * <pre>
4030      * Searches Model Monitoring Statistics generated within a given time window.
4031      * </pre>
4032      */
4033     public com.google.common.util.concurrent.ListenableFuture<
4034             com.google.cloud.aiplatform.v1.SearchModelDeploymentMonitoringStatsAnomaliesResponse>
searchModelDeploymentMonitoringStatsAnomalies( com.google.cloud.aiplatform.v1.SearchModelDeploymentMonitoringStatsAnomaliesRequest request)4035         searchModelDeploymentMonitoringStatsAnomalies(
4036             com.google.cloud.aiplatform.v1.SearchModelDeploymentMonitoringStatsAnomaliesRequest
4037                 request) {
4038       return io.grpc.stub.ClientCalls.futureUnaryCall(
4039           getChannel()
4040               .newCall(getSearchModelDeploymentMonitoringStatsAnomaliesMethod(), getCallOptions()),
4041           request);
4042     }
4043 
4044     /**
4045      *
4046      *
4047      * <pre>
4048      * Gets a ModelDeploymentMonitoringJob.
4049      * </pre>
4050      */
4051     public com.google.common.util.concurrent.ListenableFuture<
4052             com.google.cloud.aiplatform.v1.ModelDeploymentMonitoringJob>
getModelDeploymentMonitoringJob( com.google.cloud.aiplatform.v1.GetModelDeploymentMonitoringJobRequest request)4053         getModelDeploymentMonitoringJob(
4054             com.google.cloud.aiplatform.v1.GetModelDeploymentMonitoringJobRequest request) {
4055       return io.grpc.stub.ClientCalls.futureUnaryCall(
4056           getChannel().newCall(getGetModelDeploymentMonitoringJobMethod(), getCallOptions()),
4057           request);
4058     }
4059 
4060     /**
4061      *
4062      *
4063      * <pre>
4064      * Lists ModelDeploymentMonitoringJobs in a Location.
4065      * </pre>
4066      */
4067     public com.google.common.util.concurrent.ListenableFuture<
4068             com.google.cloud.aiplatform.v1.ListModelDeploymentMonitoringJobsResponse>
listModelDeploymentMonitoringJobs( com.google.cloud.aiplatform.v1.ListModelDeploymentMonitoringJobsRequest request)4069         listModelDeploymentMonitoringJobs(
4070             com.google.cloud.aiplatform.v1.ListModelDeploymentMonitoringJobsRequest request) {
4071       return io.grpc.stub.ClientCalls.futureUnaryCall(
4072           getChannel().newCall(getListModelDeploymentMonitoringJobsMethod(), getCallOptions()),
4073           request);
4074     }
4075 
4076     /**
4077      *
4078      *
4079      * <pre>
4080      * Updates a ModelDeploymentMonitoringJob.
4081      * </pre>
4082      */
4083     public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation>
updateModelDeploymentMonitoringJob( com.google.cloud.aiplatform.v1.UpdateModelDeploymentMonitoringJobRequest request)4084         updateModelDeploymentMonitoringJob(
4085             com.google.cloud.aiplatform.v1.UpdateModelDeploymentMonitoringJobRequest request) {
4086       return io.grpc.stub.ClientCalls.futureUnaryCall(
4087           getChannel().newCall(getUpdateModelDeploymentMonitoringJobMethod(), getCallOptions()),
4088           request);
4089     }
4090 
4091     /**
4092      *
4093      *
4094      * <pre>
4095      * Deletes a ModelDeploymentMonitoringJob.
4096      * </pre>
4097      */
4098     public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation>
deleteModelDeploymentMonitoringJob( com.google.cloud.aiplatform.v1.DeleteModelDeploymentMonitoringJobRequest request)4099         deleteModelDeploymentMonitoringJob(
4100             com.google.cloud.aiplatform.v1.DeleteModelDeploymentMonitoringJobRequest request) {
4101       return io.grpc.stub.ClientCalls.futureUnaryCall(
4102           getChannel().newCall(getDeleteModelDeploymentMonitoringJobMethod(), getCallOptions()),
4103           request);
4104     }
4105 
4106     /**
4107      *
4108      *
4109      * <pre>
4110      * Pauses a ModelDeploymentMonitoringJob. If the job is running, the server
4111      * makes a best effort to cancel the job. Will mark
4112      * [ModelDeploymentMonitoringJob.state][google.cloud.aiplatform.v1.ModelDeploymentMonitoringJob.state]
4113      * to 'PAUSED'.
4114      * </pre>
4115      */
4116     public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>
pauseModelDeploymentMonitoringJob( com.google.cloud.aiplatform.v1.PauseModelDeploymentMonitoringJobRequest request)4117         pauseModelDeploymentMonitoringJob(
4118             com.google.cloud.aiplatform.v1.PauseModelDeploymentMonitoringJobRequest request) {
4119       return io.grpc.stub.ClientCalls.futureUnaryCall(
4120           getChannel().newCall(getPauseModelDeploymentMonitoringJobMethod(), getCallOptions()),
4121           request);
4122     }
4123 
4124     /**
4125      *
4126      *
4127      * <pre>
4128      * Resumes a paused ModelDeploymentMonitoringJob. It will start to run from
4129      * next scheduled time. A deleted ModelDeploymentMonitoringJob can't be
4130      * resumed.
4131      * </pre>
4132      */
4133     public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>
resumeModelDeploymentMonitoringJob( com.google.cloud.aiplatform.v1.ResumeModelDeploymentMonitoringJobRequest request)4134         resumeModelDeploymentMonitoringJob(
4135             com.google.cloud.aiplatform.v1.ResumeModelDeploymentMonitoringJobRequest request) {
4136       return io.grpc.stub.ClientCalls.futureUnaryCall(
4137           getChannel().newCall(getResumeModelDeploymentMonitoringJobMethod(), getCallOptions()),
4138           request);
4139     }
4140   }
4141 
4142   private static final int METHODID_CREATE_CUSTOM_JOB = 0;
4143   private static final int METHODID_GET_CUSTOM_JOB = 1;
4144   private static final int METHODID_LIST_CUSTOM_JOBS = 2;
4145   private static final int METHODID_DELETE_CUSTOM_JOB = 3;
4146   private static final int METHODID_CANCEL_CUSTOM_JOB = 4;
4147   private static final int METHODID_CREATE_DATA_LABELING_JOB = 5;
4148   private static final int METHODID_GET_DATA_LABELING_JOB = 6;
4149   private static final int METHODID_LIST_DATA_LABELING_JOBS = 7;
4150   private static final int METHODID_DELETE_DATA_LABELING_JOB = 8;
4151   private static final int METHODID_CANCEL_DATA_LABELING_JOB = 9;
4152   private static final int METHODID_CREATE_HYPERPARAMETER_TUNING_JOB = 10;
4153   private static final int METHODID_GET_HYPERPARAMETER_TUNING_JOB = 11;
4154   private static final int METHODID_LIST_HYPERPARAMETER_TUNING_JOBS = 12;
4155   private static final int METHODID_DELETE_HYPERPARAMETER_TUNING_JOB = 13;
4156   private static final int METHODID_CANCEL_HYPERPARAMETER_TUNING_JOB = 14;
4157   private static final int METHODID_CREATE_NAS_JOB = 15;
4158   private static final int METHODID_GET_NAS_JOB = 16;
4159   private static final int METHODID_LIST_NAS_JOBS = 17;
4160   private static final int METHODID_DELETE_NAS_JOB = 18;
4161   private static final int METHODID_CANCEL_NAS_JOB = 19;
4162   private static final int METHODID_GET_NAS_TRIAL_DETAIL = 20;
4163   private static final int METHODID_LIST_NAS_TRIAL_DETAILS = 21;
4164   private static final int METHODID_CREATE_BATCH_PREDICTION_JOB = 22;
4165   private static final int METHODID_GET_BATCH_PREDICTION_JOB = 23;
4166   private static final int METHODID_LIST_BATCH_PREDICTION_JOBS = 24;
4167   private static final int METHODID_DELETE_BATCH_PREDICTION_JOB = 25;
4168   private static final int METHODID_CANCEL_BATCH_PREDICTION_JOB = 26;
4169   private static final int METHODID_CREATE_MODEL_DEPLOYMENT_MONITORING_JOB = 27;
4170   private static final int METHODID_SEARCH_MODEL_DEPLOYMENT_MONITORING_STATS_ANOMALIES = 28;
4171   private static final int METHODID_GET_MODEL_DEPLOYMENT_MONITORING_JOB = 29;
4172   private static final int METHODID_LIST_MODEL_DEPLOYMENT_MONITORING_JOBS = 30;
4173   private static final int METHODID_UPDATE_MODEL_DEPLOYMENT_MONITORING_JOB = 31;
4174   private static final int METHODID_DELETE_MODEL_DEPLOYMENT_MONITORING_JOB = 32;
4175   private static final int METHODID_PAUSE_MODEL_DEPLOYMENT_MONITORING_JOB = 33;
4176   private static final int METHODID_RESUME_MODEL_DEPLOYMENT_MONITORING_JOB = 34;
4177 
4178   private static final class MethodHandlers<Req, Resp>
4179       implements io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
4180           io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
4181           io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
4182           io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
4183     private final AsyncService serviceImpl;
4184     private final int methodId;
4185 
MethodHandlers(AsyncService serviceImpl, int methodId)4186     MethodHandlers(AsyncService serviceImpl, int methodId) {
4187       this.serviceImpl = serviceImpl;
4188       this.methodId = methodId;
4189     }
4190 
4191     @java.lang.Override
4192     @java.lang.SuppressWarnings("unchecked")
invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver)4193     public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) {
4194       switch (methodId) {
4195         case METHODID_CREATE_CUSTOM_JOB:
4196           serviceImpl.createCustomJob(
4197               (com.google.cloud.aiplatform.v1.CreateCustomJobRequest) request,
4198               (io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.CustomJob>)
4199                   responseObserver);
4200           break;
4201         case METHODID_GET_CUSTOM_JOB:
4202           serviceImpl.getCustomJob(
4203               (com.google.cloud.aiplatform.v1.GetCustomJobRequest) request,
4204               (io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.CustomJob>)
4205                   responseObserver);
4206           break;
4207         case METHODID_LIST_CUSTOM_JOBS:
4208           serviceImpl.listCustomJobs(
4209               (com.google.cloud.aiplatform.v1.ListCustomJobsRequest) request,
4210               (io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.ListCustomJobsResponse>)
4211                   responseObserver);
4212           break;
4213         case METHODID_DELETE_CUSTOM_JOB:
4214           serviceImpl.deleteCustomJob(
4215               (com.google.cloud.aiplatform.v1.DeleteCustomJobRequest) request,
4216               (io.grpc.stub.StreamObserver<com.google.longrunning.Operation>) responseObserver);
4217           break;
4218         case METHODID_CANCEL_CUSTOM_JOB:
4219           serviceImpl.cancelCustomJob(
4220               (com.google.cloud.aiplatform.v1.CancelCustomJobRequest) request,
4221               (io.grpc.stub.StreamObserver<com.google.protobuf.Empty>) responseObserver);
4222           break;
4223         case METHODID_CREATE_DATA_LABELING_JOB:
4224           serviceImpl.createDataLabelingJob(
4225               (com.google.cloud.aiplatform.v1.CreateDataLabelingJobRequest) request,
4226               (io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.DataLabelingJob>)
4227                   responseObserver);
4228           break;
4229         case METHODID_GET_DATA_LABELING_JOB:
4230           serviceImpl.getDataLabelingJob(
4231               (com.google.cloud.aiplatform.v1.GetDataLabelingJobRequest) request,
4232               (io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.DataLabelingJob>)
4233                   responseObserver);
4234           break;
4235         case METHODID_LIST_DATA_LABELING_JOBS:
4236           serviceImpl.listDataLabelingJobs(
4237               (com.google.cloud.aiplatform.v1.ListDataLabelingJobsRequest) request,
4238               (io.grpc.stub.StreamObserver<
4239                       com.google.cloud.aiplatform.v1.ListDataLabelingJobsResponse>)
4240                   responseObserver);
4241           break;
4242         case METHODID_DELETE_DATA_LABELING_JOB:
4243           serviceImpl.deleteDataLabelingJob(
4244               (com.google.cloud.aiplatform.v1.DeleteDataLabelingJobRequest) request,
4245               (io.grpc.stub.StreamObserver<com.google.longrunning.Operation>) responseObserver);
4246           break;
4247         case METHODID_CANCEL_DATA_LABELING_JOB:
4248           serviceImpl.cancelDataLabelingJob(
4249               (com.google.cloud.aiplatform.v1.CancelDataLabelingJobRequest) request,
4250               (io.grpc.stub.StreamObserver<com.google.protobuf.Empty>) responseObserver);
4251           break;
4252         case METHODID_CREATE_HYPERPARAMETER_TUNING_JOB:
4253           serviceImpl.createHyperparameterTuningJob(
4254               (com.google.cloud.aiplatform.v1.CreateHyperparameterTuningJobRequest) request,
4255               (io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.HyperparameterTuningJob>)
4256                   responseObserver);
4257           break;
4258         case METHODID_GET_HYPERPARAMETER_TUNING_JOB:
4259           serviceImpl.getHyperparameterTuningJob(
4260               (com.google.cloud.aiplatform.v1.GetHyperparameterTuningJobRequest) request,
4261               (io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.HyperparameterTuningJob>)
4262                   responseObserver);
4263           break;
4264         case METHODID_LIST_HYPERPARAMETER_TUNING_JOBS:
4265           serviceImpl.listHyperparameterTuningJobs(
4266               (com.google.cloud.aiplatform.v1.ListHyperparameterTuningJobsRequest) request,
4267               (io.grpc.stub.StreamObserver<
4268                       com.google.cloud.aiplatform.v1.ListHyperparameterTuningJobsResponse>)
4269                   responseObserver);
4270           break;
4271         case METHODID_DELETE_HYPERPARAMETER_TUNING_JOB:
4272           serviceImpl.deleteHyperparameterTuningJob(
4273               (com.google.cloud.aiplatform.v1.DeleteHyperparameterTuningJobRequest) request,
4274               (io.grpc.stub.StreamObserver<com.google.longrunning.Operation>) responseObserver);
4275           break;
4276         case METHODID_CANCEL_HYPERPARAMETER_TUNING_JOB:
4277           serviceImpl.cancelHyperparameterTuningJob(
4278               (com.google.cloud.aiplatform.v1.CancelHyperparameterTuningJobRequest) request,
4279               (io.grpc.stub.StreamObserver<com.google.protobuf.Empty>) responseObserver);
4280           break;
4281         case METHODID_CREATE_NAS_JOB:
4282           serviceImpl.createNasJob(
4283               (com.google.cloud.aiplatform.v1.CreateNasJobRequest) request,
4284               (io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.NasJob>)
4285                   responseObserver);
4286           break;
4287         case METHODID_GET_NAS_JOB:
4288           serviceImpl.getNasJob(
4289               (com.google.cloud.aiplatform.v1.GetNasJobRequest) request,
4290               (io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.NasJob>)
4291                   responseObserver);
4292           break;
4293         case METHODID_LIST_NAS_JOBS:
4294           serviceImpl.listNasJobs(
4295               (com.google.cloud.aiplatform.v1.ListNasJobsRequest) request,
4296               (io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.ListNasJobsResponse>)
4297                   responseObserver);
4298           break;
4299         case METHODID_DELETE_NAS_JOB:
4300           serviceImpl.deleteNasJob(
4301               (com.google.cloud.aiplatform.v1.DeleteNasJobRequest) request,
4302               (io.grpc.stub.StreamObserver<com.google.longrunning.Operation>) responseObserver);
4303           break;
4304         case METHODID_CANCEL_NAS_JOB:
4305           serviceImpl.cancelNasJob(
4306               (com.google.cloud.aiplatform.v1.CancelNasJobRequest) request,
4307               (io.grpc.stub.StreamObserver<com.google.protobuf.Empty>) responseObserver);
4308           break;
4309         case METHODID_GET_NAS_TRIAL_DETAIL:
4310           serviceImpl.getNasTrialDetail(
4311               (com.google.cloud.aiplatform.v1.GetNasTrialDetailRequest) request,
4312               (io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.NasTrialDetail>)
4313                   responseObserver);
4314           break;
4315         case METHODID_LIST_NAS_TRIAL_DETAILS:
4316           serviceImpl.listNasTrialDetails(
4317               (com.google.cloud.aiplatform.v1.ListNasTrialDetailsRequest) request,
4318               (io.grpc.stub.StreamObserver<
4319                       com.google.cloud.aiplatform.v1.ListNasTrialDetailsResponse>)
4320                   responseObserver);
4321           break;
4322         case METHODID_CREATE_BATCH_PREDICTION_JOB:
4323           serviceImpl.createBatchPredictionJob(
4324               (com.google.cloud.aiplatform.v1.CreateBatchPredictionJobRequest) request,
4325               (io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.BatchPredictionJob>)
4326                   responseObserver);
4327           break;
4328         case METHODID_GET_BATCH_PREDICTION_JOB:
4329           serviceImpl.getBatchPredictionJob(
4330               (com.google.cloud.aiplatform.v1.GetBatchPredictionJobRequest) request,
4331               (io.grpc.stub.StreamObserver<com.google.cloud.aiplatform.v1.BatchPredictionJob>)
4332                   responseObserver);
4333           break;
4334         case METHODID_LIST_BATCH_PREDICTION_JOBS:
4335           serviceImpl.listBatchPredictionJobs(
4336               (com.google.cloud.aiplatform.v1.ListBatchPredictionJobsRequest) request,
4337               (io.grpc.stub.StreamObserver<
4338                       com.google.cloud.aiplatform.v1.ListBatchPredictionJobsResponse>)
4339                   responseObserver);
4340           break;
4341         case METHODID_DELETE_BATCH_PREDICTION_JOB:
4342           serviceImpl.deleteBatchPredictionJob(
4343               (com.google.cloud.aiplatform.v1.DeleteBatchPredictionJobRequest) request,
4344               (io.grpc.stub.StreamObserver<com.google.longrunning.Operation>) responseObserver);
4345           break;
4346         case METHODID_CANCEL_BATCH_PREDICTION_JOB:
4347           serviceImpl.cancelBatchPredictionJob(
4348               (com.google.cloud.aiplatform.v1.CancelBatchPredictionJobRequest) request,
4349               (io.grpc.stub.StreamObserver<com.google.protobuf.Empty>) responseObserver);
4350           break;
4351         case METHODID_CREATE_MODEL_DEPLOYMENT_MONITORING_JOB:
4352           serviceImpl.createModelDeploymentMonitoringJob(
4353               (com.google.cloud.aiplatform.v1.CreateModelDeploymentMonitoringJobRequest) request,
4354               (io.grpc.stub.StreamObserver<
4355                       com.google.cloud.aiplatform.v1.ModelDeploymentMonitoringJob>)
4356                   responseObserver);
4357           break;
4358         case METHODID_SEARCH_MODEL_DEPLOYMENT_MONITORING_STATS_ANOMALIES:
4359           serviceImpl.searchModelDeploymentMonitoringStatsAnomalies(
4360               (com.google.cloud.aiplatform.v1.SearchModelDeploymentMonitoringStatsAnomaliesRequest)
4361                   request,
4362               (io.grpc.stub.StreamObserver<
4363                       com.google.cloud.aiplatform.v1
4364                           .SearchModelDeploymentMonitoringStatsAnomaliesResponse>)
4365                   responseObserver);
4366           break;
4367         case METHODID_GET_MODEL_DEPLOYMENT_MONITORING_JOB:
4368           serviceImpl.getModelDeploymentMonitoringJob(
4369               (com.google.cloud.aiplatform.v1.GetModelDeploymentMonitoringJobRequest) request,
4370               (io.grpc.stub.StreamObserver<
4371                       com.google.cloud.aiplatform.v1.ModelDeploymentMonitoringJob>)
4372                   responseObserver);
4373           break;
4374         case METHODID_LIST_MODEL_DEPLOYMENT_MONITORING_JOBS:
4375           serviceImpl.listModelDeploymentMonitoringJobs(
4376               (com.google.cloud.aiplatform.v1.ListModelDeploymentMonitoringJobsRequest) request,
4377               (io.grpc.stub.StreamObserver<
4378                       com.google.cloud.aiplatform.v1.ListModelDeploymentMonitoringJobsResponse>)
4379                   responseObserver);
4380           break;
4381         case METHODID_UPDATE_MODEL_DEPLOYMENT_MONITORING_JOB:
4382           serviceImpl.updateModelDeploymentMonitoringJob(
4383               (com.google.cloud.aiplatform.v1.UpdateModelDeploymentMonitoringJobRequest) request,
4384               (io.grpc.stub.StreamObserver<com.google.longrunning.Operation>) responseObserver);
4385           break;
4386         case METHODID_DELETE_MODEL_DEPLOYMENT_MONITORING_JOB:
4387           serviceImpl.deleteModelDeploymentMonitoringJob(
4388               (com.google.cloud.aiplatform.v1.DeleteModelDeploymentMonitoringJobRequest) request,
4389               (io.grpc.stub.StreamObserver<com.google.longrunning.Operation>) responseObserver);
4390           break;
4391         case METHODID_PAUSE_MODEL_DEPLOYMENT_MONITORING_JOB:
4392           serviceImpl.pauseModelDeploymentMonitoringJob(
4393               (com.google.cloud.aiplatform.v1.PauseModelDeploymentMonitoringJobRequest) request,
4394               (io.grpc.stub.StreamObserver<com.google.protobuf.Empty>) responseObserver);
4395           break;
4396         case METHODID_RESUME_MODEL_DEPLOYMENT_MONITORING_JOB:
4397           serviceImpl.resumeModelDeploymentMonitoringJob(
4398               (com.google.cloud.aiplatform.v1.ResumeModelDeploymentMonitoringJobRequest) request,
4399               (io.grpc.stub.StreamObserver<com.google.protobuf.Empty>) responseObserver);
4400           break;
4401         default:
4402           throw new AssertionError();
4403       }
4404     }
4405 
4406     @java.lang.Override
4407     @java.lang.SuppressWarnings("unchecked")
invoke( io.grpc.stub.StreamObserver<Resp> responseObserver)4408     public io.grpc.stub.StreamObserver<Req> invoke(
4409         io.grpc.stub.StreamObserver<Resp> responseObserver) {
4410       switch (methodId) {
4411         default:
4412           throw new AssertionError();
4413       }
4414     }
4415   }
4416 
bindService(AsyncService service)4417   public static final io.grpc.ServerServiceDefinition bindService(AsyncService service) {
4418     return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
4419         .addMethod(
4420             getCreateCustomJobMethod(),
4421             io.grpc.stub.ServerCalls.asyncUnaryCall(
4422                 new MethodHandlers<
4423                     com.google.cloud.aiplatform.v1.CreateCustomJobRequest,
4424                     com.google.cloud.aiplatform.v1.CustomJob>(service, METHODID_CREATE_CUSTOM_JOB)))
4425         .addMethod(
4426             getGetCustomJobMethod(),
4427             io.grpc.stub.ServerCalls.asyncUnaryCall(
4428                 new MethodHandlers<
4429                     com.google.cloud.aiplatform.v1.GetCustomJobRequest,
4430                     com.google.cloud.aiplatform.v1.CustomJob>(service, METHODID_GET_CUSTOM_JOB)))
4431         .addMethod(
4432             getListCustomJobsMethod(),
4433             io.grpc.stub.ServerCalls.asyncUnaryCall(
4434                 new MethodHandlers<
4435                     com.google.cloud.aiplatform.v1.ListCustomJobsRequest,
4436                     com.google.cloud.aiplatform.v1.ListCustomJobsResponse>(
4437                     service, METHODID_LIST_CUSTOM_JOBS)))
4438         .addMethod(
4439             getDeleteCustomJobMethod(),
4440             io.grpc.stub.ServerCalls.asyncUnaryCall(
4441                 new MethodHandlers<
4442                     com.google.cloud.aiplatform.v1.DeleteCustomJobRequest,
4443                     com.google.longrunning.Operation>(service, METHODID_DELETE_CUSTOM_JOB)))
4444         .addMethod(
4445             getCancelCustomJobMethod(),
4446             io.grpc.stub.ServerCalls.asyncUnaryCall(
4447                 new MethodHandlers<
4448                     com.google.cloud.aiplatform.v1.CancelCustomJobRequest,
4449                     com.google.protobuf.Empty>(service, METHODID_CANCEL_CUSTOM_JOB)))
4450         .addMethod(
4451             getCreateDataLabelingJobMethod(),
4452             io.grpc.stub.ServerCalls.asyncUnaryCall(
4453                 new MethodHandlers<
4454                     com.google.cloud.aiplatform.v1.CreateDataLabelingJobRequest,
4455                     com.google.cloud.aiplatform.v1.DataLabelingJob>(
4456                     service, METHODID_CREATE_DATA_LABELING_JOB)))
4457         .addMethod(
4458             getGetDataLabelingJobMethod(),
4459             io.grpc.stub.ServerCalls.asyncUnaryCall(
4460                 new MethodHandlers<
4461                     com.google.cloud.aiplatform.v1.GetDataLabelingJobRequest,
4462                     com.google.cloud.aiplatform.v1.DataLabelingJob>(
4463                     service, METHODID_GET_DATA_LABELING_JOB)))
4464         .addMethod(
4465             getListDataLabelingJobsMethod(),
4466             io.grpc.stub.ServerCalls.asyncUnaryCall(
4467                 new MethodHandlers<
4468                     com.google.cloud.aiplatform.v1.ListDataLabelingJobsRequest,
4469                     com.google.cloud.aiplatform.v1.ListDataLabelingJobsResponse>(
4470                     service, METHODID_LIST_DATA_LABELING_JOBS)))
4471         .addMethod(
4472             getDeleteDataLabelingJobMethod(),
4473             io.grpc.stub.ServerCalls.asyncUnaryCall(
4474                 new MethodHandlers<
4475                     com.google.cloud.aiplatform.v1.DeleteDataLabelingJobRequest,
4476                     com.google.longrunning.Operation>(service, METHODID_DELETE_DATA_LABELING_JOB)))
4477         .addMethod(
4478             getCancelDataLabelingJobMethod(),
4479             io.grpc.stub.ServerCalls.asyncUnaryCall(
4480                 new MethodHandlers<
4481                     com.google.cloud.aiplatform.v1.CancelDataLabelingJobRequest,
4482                     com.google.protobuf.Empty>(service, METHODID_CANCEL_DATA_LABELING_JOB)))
4483         .addMethod(
4484             getCreateHyperparameterTuningJobMethod(),
4485             io.grpc.stub.ServerCalls.asyncUnaryCall(
4486                 new MethodHandlers<
4487                     com.google.cloud.aiplatform.v1.CreateHyperparameterTuningJobRequest,
4488                     com.google.cloud.aiplatform.v1.HyperparameterTuningJob>(
4489                     service, METHODID_CREATE_HYPERPARAMETER_TUNING_JOB)))
4490         .addMethod(
4491             getGetHyperparameterTuningJobMethod(),
4492             io.grpc.stub.ServerCalls.asyncUnaryCall(
4493                 new MethodHandlers<
4494                     com.google.cloud.aiplatform.v1.GetHyperparameterTuningJobRequest,
4495                     com.google.cloud.aiplatform.v1.HyperparameterTuningJob>(
4496                     service, METHODID_GET_HYPERPARAMETER_TUNING_JOB)))
4497         .addMethod(
4498             getListHyperparameterTuningJobsMethod(),
4499             io.grpc.stub.ServerCalls.asyncUnaryCall(
4500                 new MethodHandlers<
4501                     com.google.cloud.aiplatform.v1.ListHyperparameterTuningJobsRequest,
4502                     com.google.cloud.aiplatform.v1.ListHyperparameterTuningJobsResponse>(
4503                     service, METHODID_LIST_HYPERPARAMETER_TUNING_JOBS)))
4504         .addMethod(
4505             getDeleteHyperparameterTuningJobMethod(),
4506             io.grpc.stub.ServerCalls.asyncUnaryCall(
4507                 new MethodHandlers<
4508                     com.google.cloud.aiplatform.v1.DeleteHyperparameterTuningJobRequest,
4509                     com.google.longrunning.Operation>(
4510                     service, METHODID_DELETE_HYPERPARAMETER_TUNING_JOB)))
4511         .addMethod(
4512             getCancelHyperparameterTuningJobMethod(),
4513             io.grpc.stub.ServerCalls.asyncUnaryCall(
4514                 new MethodHandlers<
4515                     com.google.cloud.aiplatform.v1.CancelHyperparameterTuningJobRequest,
4516                     com.google.protobuf.Empty>(service, METHODID_CANCEL_HYPERPARAMETER_TUNING_JOB)))
4517         .addMethod(
4518             getCreateNasJobMethod(),
4519             io.grpc.stub.ServerCalls.asyncUnaryCall(
4520                 new MethodHandlers<
4521                     com.google.cloud.aiplatform.v1.CreateNasJobRequest,
4522                     com.google.cloud.aiplatform.v1.NasJob>(service, METHODID_CREATE_NAS_JOB)))
4523         .addMethod(
4524             getGetNasJobMethod(),
4525             io.grpc.stub.ServerCalls.asyncUnaryCall(
4526                 new MethodHandlers<
4527                     com.google.cloud.aiplatform.v1.GetNasJobRequest,
4528                     com.google.cloud.aiplatform.v1.NasJob>(service, METHODID_GET_NAS_JOB)))
4529         .addMethod(
4530             getListNasJobsMethod(),
4531             io.grpc.stub.ServerCalls.asyncUnaryCall(
4532                 new MethodHandlers<
4533                     com.google.cloud.aiplatform.v1.ListNasJobsRequest,
4534                     com.google.cloud.aiplatform.v1.ListNasJobsResponse>(
4535                     service, METHODID_LIST_NAS_JOBS)))
4536         .addMethod(
4537             getDeleteNasJobMethod(),
4538             io.grpc.stub.ServerCalls.asyncUnaryCall(
4539                 new MethodHandlers<
4540                     com.google.cloud.aiplatform.v1.DeleteNasJobRequest,
4541                     com.google.longrunning.Operation>(service, METHODID_DELETE_NAS_JOB)))
4542         .addMethod(
4543             getCancelNasJobMethod(),
4544             io.grpc.stub.ServerCalls.asyncUnaryCall(
4545                 new MethodHandlers<
4546                     com.google.cloud.aiplatform.v1.CancelNasJobRequest, com.google.protobuf.Empty>(
4547                     service, METHODID_CANCEL_NAS_JOB)))
4548         .addMethod(
4549             getGetNasTrialDetailMethod(),
4550             io.grpc.stub.ServerCalls.asyncUnaryCall(
4551                 new MethodHandlers<
4552                     com.google.cloud.aiplatform.v1.GetNasTrialDetailRequest,
4553                     com.google.cloud.aiplatform.v1.NasTrialDetail>(
4554                     service, METHODID_GET_NAS_TRIAL_DETAIL)))
4555         .addMethod(
4556             getListNasTrialDetailsMethod(),
4557             io.grpc.stub.ServerCalls.asyncUnaryCall(
4558                 new MethodHandlers<
4559                     com.google.cloud.aiplatform.v1.ListNasTrialDetailsRequest,
4560                     com.google.cloud.aiplatform.v1.ListNasTrialDetailsResponse>(
4561                     service, METHODID_LIST_NAS_TRIAL_DETAILS)))
4562         .addMethod(
4563             getCreateBatchPredictionJobMethod(),
4564             io.grpc.stub.ServerCalls.asyncUnaryCall(
4565                 new MethodHandlers<
4566                     com.google.cloud.aiplatform.v1.CreateBatchPredictionJobRequest,
4567                     com.google.cloud.aiplatform.v1.BatchPredictionJob>(
4568                     service, METHODID_CREATE_BATCH_PREDICTION_JOB)))
4569         .addMethod(
4570             getGetBatchPredictionJobMethod(),
4571             io.grpc.stub.ServerCalls.asyncUnaryCall(
4572                 new MethodHandlers<
4573                     com.google.cloud.aiplatform.v1.GetBatchPredictionJobRequest,
4574                     com.google.cloud.aiplatform.v1.BatchPredictionJob>(
4575                     service, METHODID_GET_BATCH_PREDICTION_JOB)))
4576         .addMethod(
4577             getListBatchPredictionJobsMethod(),
4578             io.grpc.stub.ServerCalls.asyncUnaryCall(
4579                 new MethodHandlers<
4580                     com.google.cloud.aiplatform.v1.ListBatchPredictionJobsRequest,
4581                     com.google.cloud.aiplatform.v1.ListBatchPredictionJobsResponse>(
4582                     service, METHODID_LIST_BATCH_PREDICTION_JOBS)))
4583         .addMethod(
4584             getDeleteBatchPredictionJobMethod(),
4585             io.grpc.stub.ServerCalls.asyncUnaryCall(
4586                 new MethodHandlers<
4587                     com.google.cloud.aiplatform.v1.DeleteBatchPredictionJobRequest,
4588                     com.google.longrunning.Operation>(
4589                     service, METHODID_DELETE_BATCH_PREDICTION_JOB)))
4590         .addMethod(
4591             getCancelBatchPredictionJobMethod(),
4592             io.grpc.stub.ServerCalls.asyncUnaryCall(
4593                 new MethodHandlers<
4594                     com.google.cloud.aiplatform.v1.CancelBatchPredictionJobRequest,
4595                     com.google.protobuf.Empty>(service, METHODID_CANCEL_BATCH_PREDICTION_JOB)))
4596         .addMethod(
4597             getCreateModelDeploymentMonitoringJobMethod(),
4598             io.grpc.stub.ServerCalls.asyncUnaryCall(
4599                 new MethodHandlers<
4600                     com.google.cloud.aiplatform.v1.CreateModelDeploymentMonitoringJobRequest,
4601                     com.google.cloud.aiplatform.v1.ModelDeploymentMonitoringJob>(
4602                     service, METHODID_CREATE_MODEL_DEPLOYMENT_MONITORING_JOB)))
4603         .addMethod(
4604             getSearchModelDeploymentMonitoringStatsAnomaliesMethod(),
4605             io.grpc.stub.ServerCalls.asyncUnaryCall(
4606                 new MethodHandlers<
4607                     com.google.cloud.aiplatform.v1
4608                         .SearchModelDeploymentMonitoringStatsAnomaliesRequest,
4609                     com.google.cloud.aiplatform.v1
4610                         .SearchModelDeploymentMonitoringStatsAnomaliesResponse>(
4611                     service, METHODID_SEARCH_MODEL_DEPLOYMENT_MONITORING_STATS_ANOMALIES)))
4612         .addMethod(
4613             getGetModelDeploymentMonitoringJobMethod(),
4614             io.grpc.stub.ServerCalls.asyncUnaryCall(
4615                 new MethodHandlers<
4616                     com.google.cloud.aiplatform.v1.GetModelDeploymentMonitoringJobRequest,
4617                     com.google.cloud.aiplatform.v1.ModelDeploymentMonitoringJob>(
4618                     service, METHODID_GET_MODEL_DEPLOYMENT_MONITORING_JOB)))
4619         .addMethod(
4620             getListModelDeploymentMonitoringJobsMethod(),
4621             io.grpc.stub.ServerCalls.asyncUnaryCall(
4622                 new MethodHandlers<
4623                     com.google.cloud.aiplatform.v1.ListModelDeploymentMonitoringJobsRequest,
4624                     com.google.cloud.aiplatform.v1.ListModelDeploymentMonitoringJobsResponse>(
4625                     service, METHODID_LIST_MODEL_DEPLOYMENT_MONITORING_JOBS)))
4626         .addMethod(
4627             getUpdateModelDeploymentMonitoringJobMethod(),
4628             io.grpc.stub.ServerCalls.asyncUnaryCall(
4629                 new MethodHandlers<
4630                     com.google.cloud.aiplatform.v1.UpdateModelDeploymentMonitoringJobRequest,
4631                     com.google.longrunning.Operation>(
4632                     service, METHODID_UPDATE_MODEL_DEPLOYMENT_MONITORING_JOB)))
4633         .addMethod(
4634             getDeleteModelDeploymentMonitoringJobMethod(),
4635             io.grpc.stub.ServerCalls.asyncUnaryCall(
4636                 new MethodHandlers<
4637                     com.google.cloud.aiplatform.v1.DeleteModelDeploymentMonitoringJobRequest,
4638                     com.google.longrunning.Operation>(
4639                     service, METHODID_DELETE_MODEL_DEPLOYMENT_MONITORING_JOB)))
4640         .addMethod(
4641             getPauseModelDeploymentMonitoringJobMethod(),
4642             io.grpc.stub.ServerCalls.asyncUnaryCall(
4643                 new MethodHandlers<
4644                     com.google.cloud.aiplatform.v1.PauseModelDeploymentMonitoringJobRequest,
4645                     com.google.protobuf.Empty>(
4646                     service, METHODID_PAUSE_MODEL_DEPLOYMENT_MONITORING_JOB)))
4647         .addMethod(
4648             getResumeModelDeploymentMonitoringJobMethod(),
4649             io.grpc.stub.ServerCalls.asyncUnaryCall(
4650                 new MethodHandlers<
4651                     com.google.cloud.aiplatform.v1.ResumeModelDeploymentMonitoringJobRequest,
4652                     com.google.protobuf.Empty>(
4653                     service, METHODID_RESUME_MODEL_DEPLOYMENT_MONITORING_JOB)))
4654         .build();
4655   }
4656 
4657   private abstract static class JobServiceBaseDescriptorSupplier
4658       implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
4659           io.grpc.protobuf.ProtoServiceDescriptorSupplier {
JobServiceBaseDescriptorSupplier()4660     JobServiceBaseDescriptorSupplier() {}
4661 
4662     @java.lang.Override
getFileDescriptor()4663     public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
4664       return com.google.cloud.aiplatform.v1.JobServiceProto.getDescriptor();
4665     }
4666 
4667     @java.lang.Override
getServiceDescriptor()4668     public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
4669       return getFileDescriptor().findServiceByName("JobService");
4670     }
4671   }
4672 
4673   private static final class JobServiceFileDescriptorSupplier
4674       extends JobServiceBaseDescriptorSupplier {
JobServiceFileDescriptorSupplier()4675     JobServiceFileDescriptorSupplier() {}
4676   }
4677 
4678   private static final class JobServiceMethodDescriptorSupplier
4679       extends JobServiceBaseDescriptorSupplier
4680       implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
4681     private final String methodName;
4682 
JobServiceMethodDescriptorSupplier(String methodName)4683     JobServiceMethodDescriptorSupplier(String methodName) {
4684       this.methodName = methodName;
4685     }
4686 
4687     @java.lang.Override
getMethodDescriptor()4688     public com.google.protobuf.Descriptors.MethodDescriptor getMethodDescriptor() {
4689       return getServiceDescriptor().findMethodByName(methodName);
4690     }
4691   }
4692 
4693   private static volatile io.grpc.ServiceDescriptor serviceDescriptor;
4694 
getServiceDescriptor()4695   public static io.grpc.ServiceDescriptor getServiceDescriptor() {
4696     io.grpc.ServiceDescriptor result = serviceDescriptor;
4697     if (result == null) {
4698       synchronized (JobServiceGrpc.class) {
4699         result = serviceDescriptor;
4700         if (result == null) {
4701           serviceDescriptor =
4702               result =
4703                   io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
4704                       .setSchemaDescriptor(new JobServiceFileDescriptorSupplier())
4705                       .addMethod(getCreateCustomJobMethod())
4706                       .addMethod(getGetCustomJobMethod())
4707                       .addMethod(getListCustomJobsMethod())
4708                       .addMethod(getDeleteCustomJobMethod())
4709                       .addMethod(getCancelCustomJobMethod())
4710                       .addMethod(getCreateDataLabelingJobMethod())
4711                       .addMethod(getGetDataLabelingJobMethod())
4712                       .addMethod(getListDataLabelingJobsMethod())
4713                       .addMethod(getDeleteDataLabelingJobMethod())
4714                       .addMethod(getCancelDataLabelingJobMethod())
4715                       .addMethod(getCreateHyperparameterTuningJobMethod())
4716                       .addMethod(getGetHyperparameterTuningJobMethod())
4717                       .addMethod(getListHyperparameterTuningJobsMethod())
4718                       .addMethod(getDeleteHyperparameterTuningJobMethod())
4719                       .addMethod(getCancelHyperparameterTuningJobMethod())
4720                       .addMethod(getCreateNasJobMethod())
4721                       .addMethod(getGetNasJobMethod())
4722                       .addMethod(getListNasJobsMethod())
4723                       .addMethod(getDeleteNasJobMethod())
4724                       .addMethod(getCancelNasJobMethod())
4725                       .addMethod(getGetNasTrialDetailMethod())
4726                       .addMethod(getListNasTrialDetailsMethod())
4727                       .addMethod(getCreateBatchPredictionJobMethod())
4728                       .addMethod(getGetBatchPredictionJobMethod())
4729                       .addMethod(getListBatchPredictionJobsMethod())
4730                       .addMethod(getDeleteBatchPredictionJobMethod())
4731                       .addMethod(getCancelBatchPredictionJobMethod())
4732                       .addMethod(getCreateModelDeploymentMonitoringJobMethod())
4733                       .addMethod(getSearchModelDeploymentMonitoringStatsAnomaliesMethod())
4734                       .addMethod(getGetModelDeploymentMonitoringJobMethod())
4735                       .addMethod(getListModelDeploymentMonitoringJobsMethod())
4736                       .addMethod(getUpdateModelDeploymentMonitoringJobMethod())
4737                       .addMethod(getDeleteModelDeploymentMonitoringJobMethod())
4738                       .addMethod(getPauseModelDeploymentMonitoringJobMethod())
4739                       .addMethod(getResumeModelDeploymentMonitoringJobMethod())
4740                       .build();
4741         }
4742       }
4743     }
4744     return result;
4745   }
4746 }
4747