() {
- @Override
- public ListAnnotationsPagedResponse apply(ListAnnotationsPage input) {
- return new ListAnnotationsPagedResponse(input);
- }
- },
+ input -> new ListAnnotationsPagedResponse(input),
MoreExecutors.directExecutor());
}
diff --git a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/DatasetServiceSettings.java b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/DatasetServiceSettings.java
index 56665ea03..3956f654b 100644
--- a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/DatasetServiceSettings.java
+++ b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/DatasetServiceSettings.java
@@ -237,14 +237,13 @@ public DatasetServiceStubSettings.Builder getStubSettingsBuilder() {
return ((DatasetServiceStubSettings.Builder) getStubSettings());
}
- // NEXT_MAJOR_VER: remove 'throws Exception'.
/**
* Applies the given settings updater function to all of the unary API methods in this service.
*
* Note: This method does not support applying settings to streaming methods.
*/
public Builder applyToAllUnaryMethods(
- ApiFunction, Void> settingsUpdater) throws Exception {
+ ApiFunction, Void> settingsUpdater) {
super.applyToAllUnaryMethods(
getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater);
return this;
diff --git a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/EndpointServiceClient.java b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/EndpointServiceClient.java
index 9cfa4a8c6..c4424c20f 100644
--- a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/EndpointServiceClient.java
+++ b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/EndpointServiceClient.java
@@ -16,7 +16,6 @@
package com.google.cloud.aiplatform.v1;
-import com.google.api.core.ApiFunction;
import com.google.api.core.ApiFuture;
import com.google.api.core.ApiFutures;
import com.google.api.core.BetaApi;
@@ -1097,12 +1096,7 @@ public static ApiFuture createAsync(
ListEndpointsPage.createEmptyPage().createPageAsync(context, futureResponse);
return ApiFutures.transform(
futurePage,
- new ApiFunction() {
- @Override
- public ListEndpointsPagedResponse apply(ListEndpointsPage input) {
- return new ListEndpointsPagedResponse(input);
- }
- },
+ input -> new ListEndpointsPagedResponse(input),
MoreExecutors.directExecutor());
}
diff --git a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/EndpointServiceSettings.java b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/EndpointServiceSettings.java
index d350c3cc8..eca80dba7 100644
--- a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/EndpointServiceSettings.java
+++ b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/EndpointServiceSettings.java
@@ -219,14 +219,13 @@ public EndpointServiceStubSettings.Builder getStubSettingsBuilder() {
return ((EndpointServiceStubSettings.Builder) getStubSettings());
}
- // NEXT_MAJOR_VER: remove 'throws Exception'.
/**
* Applies the given settings updater function to all of the unary API methods in this service.
*
* Note: This method does not support applying settings to streaming methods.
*/
public Builder applyToAllUnaryMethods(
- ApiFunction, Void> settingsUpdater) throws Exception {
+ ApiFunction, Void> settingsUpdater) {
super.applyToAllUnaryMethods(
getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater);
return this;
diff --git a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/JobServiceClient.java b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/JobServiceClient.java
index ca48e36ae..6a883b0ae 100644
--- a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/JobServiceClient.java
+++ b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/JobServiceClient.java
@@ -16,7 +16,6 @@
package com.google.cloud.aiplatform.v1;
-import com.google.api.core.ApiFunction;
import com.google.api.core.ApiFuture;
import com.google.api.core.ApiFutures;
import com.google.api.core.BetaApi;
@@ -2658,12 +2657,7 @@ public static ApiFuture createAsync(
ListCustomJobsPage.createEmptyPage().createPageAsync(context, futureResponse);
return ApiFutures.transform(
futurePage,
- new ApiFunction() {
- @Override
- public ListCustomJobsPagedResponse apply(ListCustomJobsPage input) {
- return new ListCustomJobsPagedResponse(input);
- }
- },
+ input -> new ListCustomJobsPagedResponse(input),
MoreExecutors.directExecutor());
}
@@ -2740,12 +2734,7 @@ public static ApiFuture createAsync(
ListDataLabelingJobsPage.createEmptyPage().createPageAsync(context, futureResponse);
return ApiFutures.transform(
futurePage,
- new ApiFunction() {
- @Override
- public ListDataLabelingJobsPagedResponse apply(ListDataLabelingJobsPage input) {
- return new ListDataLabelingJobsPagedResponse(input);
- }
- },
+ input -> new ListDataLabelingJobsPagedResponse(input),
MoreExecutors.directExecutor());
}
@@ -2833,14 +2822,7 @@ public static ApiFuture createAsync(
.createPageAsync(context, futureResponse);
return ApiFutures.transform(
futurePage,
- new ApiFunction<
- ListHyperparameterTuningJobsPage, ListHyperparameterTuningJobsPagedResponse>() {
- @Override
- public ListHyperparameterTuningJobsPagedResponse apply(
- ListHyperparameterTuningJobsPage input) {
- return new ListHyperparameterTuningJobsPagedResponse(input);
- }
- },
+ input -> new ListHyperparameterTuningJobsPagedResponse(input),
MoreExecutors.directExecutor());
}
@@ -2934,12 +2916,7 @@ public static ApiFuture createAsync(
ListBatchPredictionJobsPage.createEmptyPage().createPageAsync(context, futureResponse);
return ApiFutures.transform(
futurePage,
- new ApiFunction() {
- @Override
- public ListBatchPredictionJobsPagedResponse apply(ListBatchPredictionJobsPage input) {
- return new ListBatchPredictionJobsPagedResponse(input);
- }
- },
+ input -> new ListBatchPredictionJobsPagedResponse(input),
MoreExecutors.directExecutor());
}
diff --git a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/JobServiceSettings.java b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/JobServiceSettings.java
index d06a6f630..9359789cf 100644
--- a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/JobServiceSettings.java
+++ b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/JobServiceSettings.java
@@ -308,14 +308,13 @@ public JobServiceStubSettings.Builder getStubSettingsBuilder() {
return ((JobServiceStubSettings.Builder) getStubSettings());
}
- // NEXT_MAJOR_VER: remove 'throws Exception'.
/**
* Applies the given settings updater function to all of the unary API methods in this service.
*
* Note: This method does not support applying settings to streaming methods.
*/
public Builder applyToAllUnaryMethods(
- ApiFunction, Void> settingsUpdater) throws Exception {
+ ApiFunction, Void> settingsUpdater) {
super.applyToAllUnaryMethods(
getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater);
return this;
diff --git a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/MigrationServiceClient.java b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/MigrationServiceClient.java
index d2985d171..bc641fdb9 100644
--- a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/MigrationServiceClient.java
+++ b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/MigrationServiceClient.java
@@ -16,7 +16,6 @@
package com.google.cloud.aiplatform.v1;
-import com.google.api.core.ApiFunction;
import com.google.api.core.ApiFuture;
import com.google.api.core.ApiFutures;
import com.google.api.core.BetaApi;
@@ -530,13 +529,7 @@ public static ApiFuture createAsync(
SearchMigratableResourcesPage.createEmptyPage().createPageAsync(context, futureResponse);
return ApiFutures.transform(
futurePage,
- new ApiFunction() {
- @Override
- public SearchMigratableResourcesPagedResponse apply(
- SearchMigratableResourcesPage input) {
- return new SearchMigratableResourcesPagedResponse(input);
- }
- },
+ input -> new SearchMigratableResourcesPagedResponse(input),
MoreExecutors.directExecutor());
}
diff --git a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/MigrationServiceSettings.java b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/MigrationServiceSettings.java
index 681ee3f81..7a1ffc106 100644
--- a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/MigrationServiceSettings.java
+++ b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/MigrationServiceSettings.java
@@ -181,14 +181,13 @@ public MigrationServiceStubSettings.Builder getStubSettingsBuilder() {
return ((MigrationServiceStubSettings.Builder) getStubSettings());
}
- // NEXT_MAJOR_VER: remove 'throws Exception'.
/**
* Applies the given settings updater function to all of the unary API methods in this service.
*
* Note: This method does not support applying settings to streaming methods.
*/
public Builder applyToAllUnaryMethods(
- ApiFunction, Void> settingsUpdater) throws Exception {
+ ApiFunction, Void> settingsUpdater) {
super.applyToAllUnaryMethods(
getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater);
return this;
diff --git a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/ModelServiceClient.java b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/ModelServiceClient.java
index 677ad942b..228998581 100644
--- a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/ModelServiceClient.java
+++ b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/ModelServiceClient.java
@@ -16,7 +16,6 @@
package com.google.cloud.aiplatform.v1;
-import com.google.api.core.ApiFunction;
import com.google.api.core.ApiFuture;
import com.google.api.core.ApiFutures;
import com.google.api.core.BetaApi;
@@ -1425,14 +1424,7 @@ public static ApiFuture createAsync(
ApiFuture futurePage =
ListModelsPage.createEmptyPage().createPageAsync(context, futureResponse);
return ApiFutures.transform(
- futurePage,
- new ApiFunction() {
- @Override
- public ListModelsPagedResponse apply(ListModelsPage input) {
- return new ListModelsPagedResponse(input);
- }
- },
- MoreExecutors.directExecutor());
+ futurePage, input -> new ListModelsPagedResponse(input), MoreExecutors.directExecutor());
}
private ListModelsPagedResponse(ListModelsPage page) {
@@ -1507,12 +1499,7 @@ public static ApiFuture createAsync(
ListModelEvaluationsPage.createEmptyPage().createPageAsync(context, futureResponse);
return ApiFutures.transform(
futurePage,
- new ApiFunction() {
- @Override
- public ListModelEvaluationsPagedResponse apply(ListModelEvaluationsPage input) {
- return new ListModelEvaluationsPagedResponse(input);
- }
- },
+ input -> new ListModelEvaluationsPagedResponse(input),
MoreExecutors.directExecutor());
}
@@ -1599,13 +1586,7 @@ public static ApiFuture createAsync(
ListModelEvaluationSlicesPage.createEmptyPage().createPageAsync(context, futureResponse);
return ApiFutures.transform(
futurePage,
- new ApiFunction() {
- @Override
- public ListModelEvaluationSlicesPagedResponse apply(
- ListModelEvaluationSlicesPage input) {
- return new ListModelEvaluationSlicesPagedResponse(input);
- }
- },
+ input -> new ListModelEvaluationSlicesPagedResponse(input),
MoreExecutors.directExecutor());
}
diff --git a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/ModelServiceSettings.java b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/ModelServiceSettings.java
index 105a8809b..c84dbdaf6 100644
--- a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/ModelServiceSettings.java
+++ b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/ModelServiceSettings.java
@@ -239,14 +239,13 @@ public ModelServiceStubSettings.Builder getStubSettingsBuilder() {
return ((ModelServiceStubSettings.Builder) getStubSettings());
}
- // NEXT_MAJOR_VER: remove 'throws Exception'.
/**
* Applies the given settings updater function to all of the unary API methods in this service.
*
* Note: This method does not support applying settings to streaming methods.
*/
public Builder applyToAllUnaryMethods(
- ApiFunction, Void> settingsUpdater) throws Exception {
+ ApiFunction, Void> settingsUpdater) {
super.applyToAllUnaryMethods(
getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater);
return this;
diff --git a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/PipelineServiceClient.java b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/PipelineServiceClient.java
index f99d84536..9264df84d 100644
--- a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/PipelineServiceClient.java
+++ b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/PipelineServiceClient.java
@@ -16,7 +16,6 @@
package com.google.cloud.aiplatform.v1;
-import com.google.api.core.ApiFunction;
import com.google.api.core.ApiFuture;
import com.google.api.core.ApiFutures;
import com.google.api.core.BetaApi;
@@ -803,6 +802,606 @@ public final void cancelTrainingPipeline(CancelTrainingPipelineRequest request)
return stub.cancelTrainingPipelineCallable();
}
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Creates a PipelineJob. A PipelineJob will run immediately when created.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (PipelineServiceClient pipelineServiceClient = PipelineServiceClient.create()) {
+ * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+ * PipelineJob pipelineJob = PipelineJob.newBuilder().build();
+ * String pipelineJobId = "pipelineJobId-1711315914";
+ * PipelineJob response =
+ * pipelineServiceClient.createPipelineJob(parent, pipelineJob, pipelineJobId);
+ * }
+ * }
+ *
+ * @param parent Required. The resource name of the Location to create the PipelineJob in. Format:
+ * `projects/{project}/locations/{location}`
+ * @param pipelineJob Required. The PipelineJob to create.
+ * @param pipelineJobId The ID to use for the PipelineJob, which will become the final component
+ * of the PipelineJob name. If not provided, an ID will be automatically generated.
+ * This value should be less than 128 characters, and valid characters are /[a-z][0-9]-/.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final PipelineJob createPipelineJob(
+ LocationName parent, PipelineJob pipelineJob, String pipelineJobId) {
+ CreatePipelineJobRequest request =
+ CreatePipelineJobRequest.newBuilder()
+ .setParent(parent == null ? null : parent.toString())
+ .setPipelineJob(pipelineJob)
+ .setPipelineJobId(pipelineJobId)
+ .build();
+ return createPipelineJob(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Creates a PipelineJob. A PipelineJob will run immediately when created.
+ *
+ *
Sample code:
+ *
+ *
{@code
+ * try (PipelineServiceClient pipelineServiceClient = PipelineServiceClient.create()) {
+ * String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
+ * PipelineJob pipelineJob = PipelineJob.newBuilder().build();
+ * String pipelineJobId = "pipelineJobId-1711315914";
+ * PipelineJob response =
+ * pipelineServiceClient.createPipelineJob(parent, pipelineJob, pipelineJobId);
+ * }
+ * }
+ *
+ * @param parent Required. The resource name of the Location to create the PipelineJob in. Format:
+ * `projects/{project}/locations/{location}`
+ * @param pipelineJob Required. The PipelineJob to create.
+ * @param pipelineJobId The ID to use for the PipelineJob, which will become the final component
+ * of the PipelineJob name. If not provided, an ID will be automatically generated.
+ * This value should be less than 128 characters, and valid characters are /[a-z][0-9]-/.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final PipelineJob createPipelineJob(
+ String parent, PipelineJob pipelineJob, String pipelineJobId) {
+ CreatePipelineJobRequest request =
+ CreatePipelineJobRequest.newBuilder()
+ .setParent(parent)
+ .setPipelineJob(pipelineJob)
+ .setPipelineJobId(pipelineJobId)
+ .build();
+ return createPipelineJob(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Creates a PipelineJob. A PipelineJob will run immediately when created.
+ *
+ *
Sample code:
+ *
+ *
{@code
+ * try (PipelineServiceClient pipelineServiceClient = PipelineServiceClient.create()) {
+ * CreatePipelineJobRequest request =
+ * CreatePipelineJobRequest.newBuilder()
+ * .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
+ * .setPipelineJob(PipelineJob.newBuilder().build())
+ * .setPipelineJobId("pipelineJobId-1711315914")
+ * .build();
+ * PipelineJob response = pipelineServiceClient.createPipelineJob(request);
+ * }
+ * }
+ *
+ * @param request The request object containing all of the parameters for the API call.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final PipelineJob createPipelineJob(CreatePipelineJobRequest request) {
+ return createPipelineJobCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Creates a PipelineJob. A PipelineJob will run immediately when created.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (PipelineServiceClient pipelineServiceClient = PipelineServiceClient.create()) {
+ * CreatePipelineJobRequest request =
+ * CreatePipelineJobRequest.newBuilder()
+ * .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
+ * .setPipelineJob(PipelineJob.newBuilder().build())
+ * .setPipelineJobId("pipelineJobId-1711315914")
+ * .build();
+ * ApiFuture future =
+ * pipelineServiceClient.createPipelineJobCallable().futureCall(request);
+ * // Do something.
+ * PipelineJob response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable createPipelineJobCallable() {
+ return stub.createPipelineJobCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Gets a PipelineJob.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (PipelineServiceClient pipelineServiceClient = PipelineServiceClient.create()) {
+ * PipelineJobName name = PipelineJobName.of("[PROJECT]", "[LOCATION]", "[PIPELINE_JOB]");
+ * PipelineJob response = pipelineServiceClient.getPipelineJob(name);
+ * }
+ * }
+ *
+ * @param name Required. The name of the PipelineJob resource. Format:
+ * `projects/{project}/locations/{location}/pipelineJobs/{pipeline_job}`
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final PipelineJob getPipelineJob(PipelineJobName name) {
+ GetPipelineJobRequest request =
+ GetPipelineJobRequest.newBuilder().setName(name == null ? null : name.toString()).build();
+ return getPipelineJob(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Gets a PipelineJob.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (PipelineServiceClient pipelineServiceClient = PipelineServiceClient.create()) {
+ * String name = PipelineJobName.of("[PROJECT]", "[LOCATION]", "[PIPELINE_JOB]").toString();
+ * PipelineJob response = pipelineServiceClient.getPipelineJob(name);
+ * }
+ * }
+ *
+ * @param name Required. The name of the PipelineJob resource. Format:
+ * `projects/{project}/locations/{location}/pipelineJobs/{pipeline_job}`
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final PipelineJob getPipelineJob(String name) {
+ GetPipelineJobRequest request = GetPipelineJobRequest.newBuilder().setName(name).build();
+ return getPipelineJob(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Gets a PipelineJob.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (PipelineServiceClient pipelineServiceClient = PipelineServiceClient.create()) {
+ * GetPipelineJobRequest request =
+ * GetPipelineJobRequest.newBuilder()
+ * .setName(PipelineJobName.of("[PROJECT]", "[LOCATION]", "[PIPELINE_JOB]").toString())
+ * .build();
+ * PipelineJob response = pipelineServiceClient.getPipelineJob(request);
+ * }
+ * }
+ *
+ * @param request The request object containing all of the parameters for the API call.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final PipelineJob getPipelineJob(GetPipelineJobRequest request) {
+ return getPipelineJobCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Gets a PipelineJob.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (PipelineServiceClient pipelineServiceClient = PipelineServiceClient.create()) {
+ * GetPipelineJobRequest request =
+ * GetPipelineJobRequest.newBuilder()
+ * .setName(PipelineJobName.of("[PROJECT]", "[LOCATION]", "[PIPELINE_JOB]").toString())
+ * .build();
+ * ApiFuture future =
+ * pipelineServiceClient.getPipelineJobCallable().futureCall(request);
+ * // Do something.
+ * PipelineJob response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable getPipelineJobCallable() {
+ return stub.getPipelineJobCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists PipelineJobs in a Location.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (PipelineServiceClient pipelineServiceClient = PipelineServiceClient.create()) {
+ * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+ * for (PipelineJob element : pipelineServiceClient.listPipelineJobs(parent).iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ * }
+ *
+ * @param parent Required. The resource name of the Location to list the PipelineJobs from.
+ * Format: `projects/{project}/locations/{location}`
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final ListPipelineJobsPagedResponse listPipelineJobs(LocationName parent) {
+ ListPipelineJobsRequest request =
+ ListPipelineJobsRequest.newBuilder()
+ .setParent(parent == null ? null : parent.toString())
+ .build();
+ return listPipelineJobs(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists PipelineJobs in a Location.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (PipelineServiceClient pipelineServiceClient = PipelineServiceClient.create()) {
+ * String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
+ * for (PipelineJob element : pipelineServiceClient.listPipelineJobs(parent).iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ * }
+ *
+ * @param parent Required. The resource name of the Location to list the PipelineJobs from.
+ * Format: `projects/{project}/locations/{location}`
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final ListPipelineJobsPagedResponse listPipelineJobs(String parent) {
+ ListPipelineJobsRequest request =
+ ListPipelineJobsRequest.newBuilder().setParent(parent).build();
+ return listPipelineJobs(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists PipelineJobs in a Location.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (PipelineServiceClient pipelineServiceClient = PipelineServiceClient.create()) {
+ * ListPipelineJobsRequest request =
+ * ListPipelineJobsRequest.newBuilder()
+ * .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
+ * .setFilter("filter-1274492040")
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .build();
+ * for (PipelineJob element : pipelineServiceClient.listPipelineJobs(request).iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ * }
+ *
+ * @param request The request object containing all of the parameters for the API call.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final ListPipelineJobsPagedResponse listPipelineJobs(ListPipelineJobsRequest request) {
+ return listPipelineJobsPagedCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists PipelineJobs in a Location.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (PipelineServiceClient pipelineServiceClient = PipelineServiceClient.create()) {
+ * ListPipelineJobsRequest request =
+ * ListPipelineJobsRequest.newBuilder()
+ * .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
+ * .setFilter("filter-1274492040")
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .build();
+ * ApiFuture future =
+ * pipelineServiceClient.listPipelineJobsPagedCallable().futureCall(request);
+ * // Do something.
+ * for (PipelineJob element : future.get().iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ * }
+ */
+ public final UnaryCallable
+ listPipelineJobsPagedCallable() {
+ return stub.listPipelineJobsPagedCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists PipelineJobs in a Location.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (PipelineServiceClient pipelineServiceClient = PipelineServiceClient.create()) {
+ * ListPipelineJobsRequest request =
+ * ListPipelineJobsRequest.newBuilder()
+ * .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
+ * .setFilter("filter-1274492040")
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .build();
+ * while (true) {
+ * ListPipelineJobsResponse response =
+ * pipelineServiceClient.listPipelineJobsCallable().call(request);
+ * for (PipelineJob element : response.getResponsesList()) {
+ * // doThingsWith(element);
+ * }
+ * String nextPageToken = response.getNextPageToken();
+ * if (!Strings.isNullOrEmpty(nextPageToken)) {
+ * request = request.toBuilder().setPageToken(nextPageToken).build();
+ * } else {
+ * break;
+ * }
+ * }
+ * }
+ * }
+ */
+ public final UnaryCallable
+ listPipelineJobsCallable() {
+ return stub.listPipelineJobsCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Deletes a PipelineJob.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (PipelineServiceClient pipelineServiceClient = PipelineServiceClient.create()) {
+ * PipelineJobName name = PipelineJobName.of("[PROJECT]", "[LOCATION]", "[PIPELINE_JOB]");
+ * pipelineServiceClient.deletePipelineJobAsync(name).get();
+ * }
+ * }
+ *
+ * @param name Required. The name of the PipelineJob resource to be deleted. Format:
+ * `projects/{project}/locations/{location}/pipelineJobs/{pipeline_job}`
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final OperationFuture deletePipelineJobAsync(
+ PipelineJobName name) {
+ DeletePipelineJobRequest request =
+ DeletePipelineJobRequest.newBuilder()
+ .setName(name == null ? null : name.toString())
+ .build();
+ return deletePipelineJobAsync(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Deletes a PipelineJob.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (PipelineServiceClient pipelineServiceClient = PipelineServiceClient.create()) {
+ * String name = PipelineJobName.of("[PROJECT]", "[LOCATION]", "[PIPELINE_JOB]").toString();
+ * pipelineServiceClient.deletePipelineJobAsync(name).get();
+ * }
+ * }
+ *
+ * @param name Required. The name of the PipelineJob resource to be deleted. Format:
+ * `projects/{project}/locations/{location}/pipelineJobs/{pipeline_job}`
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final OperationFuture deletePipelineJobAsync(String name) {
+ DeletePipelineJobRequest request = DeletePipelineJobRequest.newBuilder().setName(name).build();
+ return deletePipelineJobAsync(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Deletes a PipelineJob.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (PipelineServiceClient pipelineServiceClient = PipelineServiceClient.create()) {
+ * DeletePipelineJobRequest request =
+ * DeletePipelineJobRequest.newBuilder()
+ * .setName(PipelineJobName.of("[PROJECT]", "[LOCATION]", "[PIPELINE_JOB]").toString())
+ * .build();
+ * pipelineServiceClient.deletePipelineJobAsync(request).get();
+ * }
+ * }
+ *
+ * @param request The request object containing all of the parameters for the API call.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final OperationFuture deletePipelineJobAsync(
+ DeletePipelineJobRequest request) {
+ return deletePipelineJobOperationCallable().futureCall(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Deletes a PipelineJob.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (PipelineServiceClient pipelineServiceClient = PipelineServiceClient.create()) {
+ * DeletePipelineJobRequest request =
+ * DeletePipelineJobRequest.newBuilder()
+ * .setName(PipelineJobName.of("[PROJECT]", "[LOCATION]", "[PIPELINE_JOB]").toString())
+ * .build();
+ * OperationFuture future =
+ * pipelineServiceClient.deletePipelineJobOperationCallable().futureCall(request);
+ * // Do something.
+ * future.get();
+ * }
+ * }
+ */
+ public final OperationCallable
+ deletePipelineJobOperationCallable() {
+ return stub.deletePipelineJobOperationCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Deletes a PipelineJob.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (PipelineServiceClient pipelineServiceClient = PipelineServiceClient.create()) {
+ * DeletePipelineJobRequest request =
+ * DeletePipelineJobRequest.newBuilder()
+ * .setName(PipelineJobName.of("[PROJECT]", "[LOCATION]", "[PIPELINE_JOB]").toString())
+ * .build();
+ * ApiFuture future =
+ * pipelineServiceClient.deletePipelineJobCallable().futureCall(request);
+ * // Do something.
+ * future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable deletePipelineJobCallable() {
+ return stub.deletePipelineJobCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Cancels a PipelineJob. Starts asynchronous cancellation on the PipelineJob. The server makes a
+ * best effort to cancel the pipeline, but success is not guaranteed. Clients can use
+ * [PipelineService.GetPipelineJob][google.cloud.aiplatform.v1.PipelineService.GetPipelineJob] or
+ * other methods to check whether the cancellation succeeded or whether the pipeline completed
+ * despite cancellation. On successful cancellation, the PipelineJob is not deleted; instead it
+ * becomes a pipeline with a [PipelineJob.error][google.cloud.aiplatform.v1.PipelineJob.error]
+ * value with a [google.rpc.Status.code][google.rpc.Status.code] of 1, corresponding to
+ * `Code.CANCELLED`, and [PipelineJob.state][google.cloud.aiplatform.v1.PipelineJob.state] is set
+ * to `CANCELLED`.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (PipelineServiceClient pipelineServiceClient = PipelineServiceClient.create()) {
+ * PipelineJobName name = PipelineJobName.of("[PROJECT]", "[LOCATION]", "[PIPELINE_JOB]");
+ * pipelineServiceClient.cancelPipelineJob(name);
+ * }
+ * }
+ *
+ * @param name Required. The name of the PipelineJob to cancel. Format:
+ * `projects/{project}/locations/{location}/pipelineJobs/{pipeline_job}`
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final void cancelPipelineJob(PipelineJobName name) {
+ CancelPipelineJobRequest request =
+ CancelPipelineJobRequest.newBuilder()
+ .setName(name == null ? null : name.toString())
+ .build();
+ cancelPipelineJob(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Cancels a PipelineJob. Starts asynchronous cancellation on the PipelineJob. The server makes a
+ * best effort to cancel the pipeline, but success is not guaranteed. Clients can use
+ * [PipelineService.GetPipelineJob][google.cloud.aiplatform.v1.PipelineService.GetPipelineJob] or
+ * other methods to check whether the cancellation succeeded or whether the pipeline completed
+ * despite cancellation. On successful cancellation, the PipelineJob is not deleted; instead it
+ * becomes a pipeline with a [PipelineJob.error][google.cloud.aiplatform.v1.PipelineJob.error]
+ * value with a [google.rpc.Status.code][google.rpc.Status.code] of 1, corresponding to
+ * `Code.CANCELLED`, and [PipelineJob.state][google.cloud.aiplatform.v1.PipelineJob.state] is set
+ * to `CANCELLED`.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (PipelineServiceClient pipelineServiceClient = PipelineServiceClient.create()) {
+ * String name = PipelineJobName.of("[PROJECT]", "[LOCATION]", "[PIPELINE_JOB]").toString();
+ * pipelineServiceClient.cancelPipelineJob(name);
+ * }
+ * }
+ *
+ * @param name Required. The name of the PipelineJob to cancel. Format:
+ * `projects/{project}/locations/{location}/pipelineJobs/{pipeline_job}`
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final void cancelPipelineJob(String name) {
+ CancelPipelineJobRequest request = CancelPipelineJobRequest.newBuilder().setName(name).build();
+ cancelPipelineJob(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Cancels a PipelineJob. Starts asynchronous cancellation on the PipelineJob. The server makes a
+ * best effort to cancel the pipeline, but success is not guaranteed. Clients can use
+ * [PipelineService.GetPipelineJob][google.cloud.aiplatform.v1.PipelineService.GetPipelineJob] or
+ * other methods to check whether the cancellation succeeded or whether the pipeline completed
+ * despite cancellation. On successful cancellation, the PipelineJob is not deleted; instead it
+ * becomes a pipeline with a [PipelineJob.error][google.cloud.aiplatform.v1.PipelineJob.error]
+ * value with a [google.rpc.Status.code][google.rpc.Status.code] of 1, corresponding to
+ * `Code.CANCELLED`, and [PipelineJob.state][google.cloud.aiplatform.v1.PipelineJob.state] is set
+ * to `CANCELLED`.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (PipelineServiceClient pipelineServiceClient = PipelineServiceClient.create()) {
+ * CancelPipelineJobRequest request =
+ * CancelPipelineJobRequest.newBuilder()
+ * .setName(PipelineJobName.of("[PROJECT]", "[LOCATION]", "[PIPELINE_JOB]").toString())
+ * .build();
+ * pipelineServiceClient.cancelPipelineJob(request);
+ * }
+ * }
+ *
+ * @param request The request object containing all of the parameters for the API call.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final void cancelPipelineJob(CancelPipelineJobRequest request) {
+ cancelPipelineJobCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Cancels a PipelineJob. Starts asynchronous cancellation on the PipelineJob. The server makes a
+ * best effort to cancel the pipeline, but success is not guaranteed. Clients can use
+ * [PipelineService.GetPipelineJob][google.cloud.aiplatform.v1.PipelineService.GetPipelineJob] or
+ * other methods to check whether the cancellation succeeded or whether the pipeline completed
+ * despite cancellation. On successful cancellation, the PipelineJob is not deleted; instead it
+ * becomes a pipeline with a [PipelineJob.error][google.cloud.aiplatform.v1.PipelineJob.error]
+ * value with a [google.rpc.Status.code][google.rpc.Status.code] of 1, corresponding to
+ * `Code.CANCELLED`, and [PipelineJob.state][google.cloud.aiplatform.v1.PipelineJob.state] is set
+ * to `CANCELLED`.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (PipelineServiceClient pipelineServiceClient = PipelineServiceClient.create()) {
+ * CancelPipelineJobRequest request =
+ * CancelPipelineJobRequest.newBuilder()
+ * .setName(PipelineJobName.of("[PROJECT]", "[LOCATION]", "[PIPELINE_JOB]").toString())
+ * .build();
+ * ApiFuture future =
+ * pipelineServiceClient.cancelPipelineJobCallable().futureCall(request);
+ * // Do something.
+ * future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable cancelPipelineJobCallable() {
+ return stub.cancelPipelineJobCallable();
+ }
+
@Override
public final void close() {
stub.close();
@@ -849,12 +1448,7 @@ public static ApiFuture createAsync(
ListTrainingPipelinesPage.createEmptyPage().createPageAsync(context, futureResponse);
return ApiFutures.transform(
futurePage,
- new ApiFunction() {
- @Override
- public ListTrainingPipelinesPagedResponse apply(ListTrainingPipelinesPage input) {
- return new ListTrainingPipelinesPagedResponse(input);
- }
- },
+ input -> new ListTrainingPipelinesPagedResponse(input),
MoreExecutors.directExecutor());
}
@@ -921,4 +1515,81 @@ protected ListTrainingPipelinesFixedSizeCollection createCollection(
return new ListTrainingPipelinesFixedSizeCollection(pages, collectionSize);
}
}
+
+ public static class ListPipelineJobsPagedResponse
+ extends AbstractPagedListResponse<
+ ListPipelineJobsRequest,
+ ListPipelineJobsResponse,
+ PipelineJob,
+ ListPipelineJobsPage,
+ ListPipelineJobsFixedSizeCollection> {
+
+ public static ApiFuture createAsync(
+ PageContext context,
+ ApiFuture futureResponse) {
+ ApiFuture futurePage =
+ ListPipelineJobsPage.createEmptyPage().createPageAsync(context, futureResponse);
+ return ApiFutures.transform(
+ futurePage,
+ input -> new ListPipelineJobsPagedResponse(input),
+ MoreExecutors.directExecutor());
+ }
+
+ private ListPipelineJobsPagedResponse(ListPipelineJobsPage page) {
+ super(page, ListPipelineJobsFixedSizeCollection.createEmptyCollection());
+ }
+ }
+
+ public static class ListPipelineJobsPage
+ extends AbstractPage<
+ ListPipelineJobsRequest, ListPipelineJobsResponse, PipelineJob, ListPipelineJobsPage> {
+
+ private ListPipelineJobsPage(
+ PageContext context,
+ ListPipelineJobsResponse response) {
+ super(context, response);
+ }
+
+ private static ListPipelineJobsPage createEmptyPage() {
+ return new ListPipelineJobsPage(null, null);
+ }
+
+ @Override
+ protected ListPipelineJobsPage createPage(
+ PageContext context,
+ ListPipelineJobsResponse response) {
+ return new ListPipelineJobsPage(context, response);
+ }
+
+ @Override
+ public ApiFuture createPageAsync(
+ PageContext context,
+ ApiFuture futureResponse) {
+ return super.createPageAsync(context, futureResponse);
+ }
+ }
+
+ public static class ListPipelineJobsFixedSizeCollection
+ extends AbstractFixedSizeCollection<
+ ListPipelineJobsRequest,
+ ListPipelineJobsResponse,
+ PipelineJob,
+ ListPipelineJobsPage,
+ ListPipelineJobsFixedSizeCollection> {
+
+ private ListPipelineJobsFixedSizeCollection(
+ List pages, int collectionSize) {
+ super(pages, collectionSize);
+ }
+
+ private static ListPipelineJobsFixedSizeCollection createEmptyCollection() {
+ return new ListPipelineJobsFixedSizeCollection(null, 0);
+ }
+
+ @Override
+ protected ListPipelineJobsFixedSizeCollection createCollection(
+ List pages, int collectionSize) {
+ return new ListPipelineJobsFixedSizeCollection(pages, collectionSize);
+ }
+ }
}
diff --git a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/PipelineServiceSettings.java b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/PipelineServiceSettings.java
index 362490ee6..ce4beaeed 100644
--- a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/PipelineServiceSettings.java
+++ b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/PipelineServiceSettings.java
@@ -16,6 +16,7 @@
package com.google.cloud.aiplatform.v1;
+import static com.google.cloud.aiplatform.v1.PipelineServiceClient.ListPipelineJobsPagedResponse;
import static com.google.cloud.aiplatform.v1.PipelineServiceClient.ListTrainingPipelinesPagedResponse;
import com.google.api.core.ApiFunction;
@@ -111,6 +112,39 @@ public UnaryCallSettings cancelTrainingPip
return ((PipelineServiceStubSettings) getStubSettings()).cancelTrainingPipelineSettings();
}
+ /** Returns the object with the settings used for calls to createPipelineJob. */
+ public UnaryCallSettings createPipelineJobSettings() {
+ return ((PipelineServiceStubSettings) getStubSettings()).createPipelineJobSettings();
+ }
+
+ /** Returns the object with the settings used for calls to getPipelineJob. */
+ public UnaryCallSettings getPipelineJobSettings() {
+ return ((PipelineServiceStubSettings) getStubSettings()).getPipelineJobSettings();
+ }
+
+ /** Returns the object with the settings used for calls to listPipelineJobs. */
+ public PagedCallSettings<
+ ListPipelineJobsRequest, ListPipelineJobsResponse, ListPipelineJobsPagedResponse>
+ listPipelineJobsSettings() {
+ return ((PipelineServiceStubSettings) getStubSettings()).listPipelineJobsSettings();
+ }
+
+ /** Returns the object with the settings used for calls to deletePipelineJob. */
+ public UnaryCallSettings deletePipelineJobSettings() {
+ return ((PipelineServiceStubSettings) getStubSettings()).deletePipelineJobSettings();
+ }
+
+ /** Returns the object with the settings used for calls to deletePipelineJob. */
+ public OperationCallSettings
+ deletePipelineJobOperationSettings() {
+ return ((PipelineServiceStubSettings) getStubSettings()).deletePipelineJobOperationSettings();
+ }
+
+ /** Returns the object with the settings used for calls to cancelPipelineJob. */
+ public UnaryCallSettings cancelPipelineJobSettings() {
+ return ((PipelineServiceStubSettings) getStubSettings()).cancelPipelineJobSettings();
+ }
+
public static final PipelineServiceSettings create(PipelineServiceStubSettings stub)
throws IOException {
return new PipelineServiceSettings.Builder(stub.toBuilder()).build();
@@ -196,14 +230,13 @@ public PipelineServiceStubSettings.Builder getStubSettingsBuilder() {
return ((PipelineServiceStubSettings.Builder) getStubSettings());
}
- // NEXT_MAJOR_VER: remove 'throws Exception'.
/**
* Applies the given settings updater function to all of the unary API methods in this service.
*
* Note: This method does not support applying settings to streaming methods.
*/
public Builder applyToAllUnaryMethods(
- ApiFunction, Void> settingsUpdater) throws Exception {
+ ApiFunction, Void> settingsUpdater) {
super.applyToAllUnaryMethods(
getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater);
return this;
@@ -249,6 +282,41 @@ public Builder applyToAllUnaryMethods(
return getStubSettingsBuilder().cancelTrainingPipelineSettings();
}
+ /** Returns the builder for the settings used for calls to createPipelineJob. */
+ public UnaryCallSettings.Builder
+ createPipelineJobSettings() {
+ return getStubSettingsBuilder().createPipelineJobSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to getPipelineJob. */
+ public UnaryCallSettings.Builder getPipelineJobSettings() {
+ return getStubSettingsBuilder().getPipelineJobSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to listPipelineJobs. */
+ public PagedCallSettings.Builder<
+ ListPipelineJobsRequest, ListPipelineJobsResponse, ListPipelineJobsPagedResponse>
+ listPipelineJobsSettings() {
+ return getStubSettingsBuilder().listPipelineJobsSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to deletePipelineJob. */
+ public UnaryCallSettings.Builder
+ deletePipelineJobSettings() {
+ return getStubSettingsBuilder().deletePipelineJobSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to deletePipelineJob. */
+ public OperationCallSettings.Builder
+ deletePipelineJobOperationSettings() {
+ return getStubSettingsBuilder().deletePipelineJobOperationSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to cancelPipelineJob. */
+ public UnaryCallSettings.Builder cancelPipelineJobSettings() {
+ return getStubSettingsBuilder().cancelPipelineJobSettings();
+ }
+
@Override
public PipelineServiceSettings build() throws IOException {
return new PipelineServiceSettings(this);
diff --git a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/PredictionServiceSettings.java b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/PredictionServiceSettings.java
index 912152a44..ae1d1c469 100644
--- a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/PredictionServiceSettings.java
+++ b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/PredictionServiceSettings.java
@@ -156,14 +156,13 @@ public PredictionServiceStubSettings.Builder getStubSettingsBuilder() {
return ((PredictionServiceStubSettings.Builder) getStubSettings());
}
- // NEXT_MAJOR_VER: remove 'throws Exception'.
/**
* Applies the given settings updater function to all of the unary API methods in this service.
*
* Note: This method does not support applying settings to streaming methods.
*/
public Builder applyToAllUnaryMethods(
- ApiFunction, Void> settingsUpdater) throws Exception {
+ ApiFunction, Void> settingsUpdater) {
super.applyToAllUnaryMethods(
getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater);
return this;
diff --git a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/SpecialistPoolServiceClient.java b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/SpecialistPoolServiceClient.java
index 52400fdf2..fecbc9906 100644
--- a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/SpecialistPoolServiceClient.java
+++ b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/SpecialistPoolServiceClient.java
@@ -16,7 +16,6 @@
package com.google.cloud.aiplatform.v1;
-import com.google.api.core.ApiFunction;
import com.google.api.core.ApiFuture;
import com.google.api.core.ApiFutures;
import com.google.api.core.BetaApi;
@@ -861,12 +860,7 @@ public static ApiFuture createAsync(
ListSpecialistPoolsPage.createEmptyPage().createPageAsync(context, futureResponse);
return ApiFutures.transform(
futurePage,
- new ApiFunction() {
- @Override
- public ListSpecialistPoolsPagedResponse apply(ListSpecialistPoolsPage input) {
- return new ListSpecialistPoolsPagedResponse(input);
- }
- },
+ input -> new ListSpecialistPoolsPagedResponse(input),
MoreExecutors.directExecutor());
}
diff --git a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/SpecialistPoolServiceSettings.java b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/SpecialistPoolServiceSettings.java
index fb702d153..24a946135 100644
--- a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/SpecialistPoolServiceSettings.java
+++ b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/SpecialistPoolServiceSettings.java
@@ -209,14 +209,13 @@ public SpecialistPoolServiceStubSettings.Builder getStubSettingsBuilder() {
return ((SpecialistPoolServiceStubSettings.Builder) getStubSettings());
}
- // NEXT_MAJOR_VER: remove 'throws Exception'.
/**
* Applies the given settings updater function to all of the unary API methods in this service.
*
* Note: This method does not support applying settings to streaming methods.
*/
public Builder applyToAllUnaryMethods(
- ApiFunction, Void> settingsUpdater) throws Exception {
+ ApiFunction, Void> settingsUpdater) {
super.applyToAllUnaryMethods(
getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater);
return this;
diff --git a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/gapic_metadata.json b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/gapic_metadata.json
index b22619036..3df6d4d02 100644
--- a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/gapic_metadata.json
+++ b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/gapic_metadata.json
@@ -202,18 +202,33 @@
"grpc": {
"libraryClient": "PipelineServiceClient",
"rpcs": {
+ "CancelPipelineJob": {
+ "methods": ["cancelPipelineJob", "cancelPipelineJob", "cancelPipelineJob", "cancelPipelineJobCallable"]
+ },
"CancelTrainingPipeline": {
"methods": ["cancelTrainingPipeline", "cancelTrainingPipeline", "cancelTrainingPipeline", "cancelTrainingPipelineCallable"]
},
+ "CreatePipelineJob": {
+ "methods": ["createPipelineJob", "createPipelineJob", "createPipelineJob", "createPipelineJobCallable"]
+ },
"CreateTrainingPipeline": {
"methods": ["createTrainingPipeline", "createTrainingPipeline", "createTrainingPipeline", "createTrainingPipelineCallable"]
},
+ "DeletePipelineJob": {
+ "methods": ["deletePipelineJobAsync", "deletePipelineJobAsync", "deletePipelineJobAsync", "deletePipelineJobOperationCallable", "deletePipelineJobCallable"]
+ },
"DeleteTrainingPipeline": {
"methods": ["deleteTrainingPipelineAsync", "deleteTrainingPipelineAsync", "deleteTrainingPipelineAsync", "deleteTrainingPipelineOperationCallable", "deleteTrainingPipelineCallable"]
},
+ "GetPipelineJob": {
+ "methods": ["getPipelineJob", "getPipelineJob", "getPipelineJob", "getPipelineJobCallable"]
+ },
"GetTrainingPipeline": {
"methods": ["getTrainingPipeline", "getTrainingPipeline", "getTrainingPipeline", "getTrainingPipelineCallable"]
},
+ "ListPipelineJobs": {
+ "methods": ["listPipelineJobs", "listPipelineJobs", "listPipelineJobs", "listPipelineJobsPagedCallable", "listPipelineJobsCallable"]
+ },
"ListTrainingPipelines": {
"methods": ["listTrainingPipelines", "listTrainingPipelines", "listTrainingPipelines", "listTrainingPipelinesPagedCallable", "listTrainingPipelinesCallable"]
}
diff --git a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/stub/DatasetServiceStubSettings.java b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/stub/DatasetServiceStubSettings.java
index 6e89bd0dc..4e37011a0 100644
--- a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/stub/DatasetServiceStubSettings.java
+++ b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/stub/DatasetServiceStubSettings.java
@@ -768,14 +768,13 @@ private static Builder initDefaults(Builder builder) {
return builder;
}
- // NEXT_MAJOR_VER: remove 'throws Exception'.
/**
* Applies the given settings updater function to all of the unary API methods in this service.
*
* Note: This method does not support applying settings to streaming methods.
*/
public Builder applyToAllUnaryMethods(
- ApiFunction, Void> settingsUpdater) throws Exception {
+ ApiFunction, Void> settingsUpdater) {
super.applyToAllUnaryMethods(unaryMethodSettingsBuilders, settingsUpdater);
return this;
}
diff --git a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/stub/EndpointServiceStubSettings.java b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/stub/EndpointServiceStubSettings.java
index b2e1d97d7..0eef52b4c 100644
--- a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/stub/EndpointServiceStubSettings.java
+++ b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/stub/EndpointServiceStubSettings.java
@@ -591,14 +591,13 @@ private static Builder initDefaults(Builder builder) {
return builder;
}
- // NEXT_MAJOR_VER: remove 'throws Exception'.
/**
* Applies the given settings updater function to all of the unary API methods in this service.
*
* Note: This method does not support applying settings to streaming methods.
*/
public Builder applyToAllUnaryMethods(
- ApiFunction, Void> settingsUpdater) throws Exception {
+ ApiFunction, Void> settingsUpdater) {
super.applyToAllUnaryMethods(unaryMethodSettingsBuilders, settingsUpdater);
return this;
}
diff --git a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/stub/GrpcDatasetServiceStub.java b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/stub/GrpcDatasetServiceStub.java
index da638eb17..552a4764f 100644
--- a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/stub/GrpcDatasetServiceStub.java
+++ b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/stub/GrpcDatasetServiceStub.java
@@ -26,7 +26,6 @@
import com.google.api.gax.grpc.GrpcStubCallableFactory;
import com.google.api.gax.rpc.ClientContext;
import com.google.api.gax.rpc.OperationCallable;
-import com.google.api.gax.rpc.RequestParamsExtractor;
import com.google.api.gax.rpc.UnaryCallable;
import com.google.cloud.aiplatform.v1.AnnotationSpec;
import com.google.cloud.aiplatform.v1.CreateDatasetOperationMetadata;
@@ -56,7 +55,6 @@
import io.grpc.MethodDescriptor;
import io.grpc.protobuf.ProtoUtils;
import java.io.IOException;
-import java.util.Map;
import java.util.concurrent.TimeUnit;
import javax.annotation.Generated;
@@ -240,117 +238,90 @@ protected GrpcDatasetServiceStub(
GrpcCallSettings.newBuilder()
.setMethodDescriptor(createDatasetMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(CreateDatasetRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("parent", String.valueOf(request.getParent()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("parent", String.valueOf(request.getParent()));
+ return params.build();
})
.build();
GrpcCallSettings getDatasetTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(getDatasetMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(GetDatasetRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("name", String.valueOf(request.getName()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("name", String.valueOf(request.getName()));
+ return params.build();
})
.build();
GrpcCallSettings updateDatasetTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(updateDatasetMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(UpdateDatasetRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("dataset.name", String.valueOf(request.getDataset().getName()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("dataset.name", String.valueOf(request.getDataset().getName()));
+ return params.build();
})
.build();
GrpcCallSettings listDatasetsTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(listDatasetsMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(ListDatasetsRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("parent", String.valueOf(request.getParent()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("parent", String.valueOf(request.getParent()));
+ return params.build();
})
.build();
GrpcCallSettings deleteDatasetTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(deleteDatasetMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(DeleteDatasetRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("name", String.valueOf(request.getName()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("name", String.valueOf(request.getName()));
+ return params.build();
})
.build();
GrpcCallSettings importDataTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(importDataMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(ImportDataRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("name", String.valueOf(request.getName()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("name", String.valueOf(request.getName()));
+ return params.build();
})
.build();
GrpcCallSettings exportDataTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(exportDataMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(ExportDataRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("name", String.valueOf(request.getName()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("name", String.valueOf(request.getName()));
+ return params.build();
})
.build();
GrpcCallSettings listDataItemsTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(listDataItemsMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(ListDataItemsRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("parent", String.valueOf(request.getParent()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("parent", String.valueOf(request.getParent()));
+ return params.build();
})
.build();
GrpcCallSettings getAnnotationSpecTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(getAnnotationSpecMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(GetAnnotationSpecRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("name", String.valueOf(request.getName()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("name", String.valueOf(request.getName()));
+ return params.build();
})
.build();
GrpcCallSettings
@@ -358,13 +329,10 @@ public Map extract(GetAnnotationSpecRequest request) {
GrpcCallSettings.newBuilder()
.setMethodDescriptor(listAnnotationsMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(ListAnnotationsRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("parent", String.valueOf(request.getParent()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("parent", String.valueOf(request.getParent()));
+ return params.build();
})
.build();
@@ -535,7 +503,13 @@ public UnaryCallable listAnnota
@Override
public final void close() {
- shutdown();
+ try {
+ backgroundResources.close();
+ } catch (RuntimeException e) {
+ throw e;
+ } catch (Exception e) {
+ throw new IllegalStateException("Failed to close resource", e);
+ }
}
@Override
diff --git a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/stub/GrpcEndpointServiceStub.java b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/stub/GrpcEndpointServiceStub.java
index df0fa2cf0..e89167e45 100644
--- a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/stub/GrpcEndpointServiceStub.java
+++ b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/stub/GrpcEndpointServiceStub.java
@@ -24,7 +24,6 @@
import com.google.api.gax.grpc.GrpcStubCallableFactory;
import com.google.api.gax.rpc.ClientContext;
import com.google.api.gax.rpc.OperationCallable;
-import com.google.api.gax.rpc.RequestParamsExtractor;
import com.google.api.gax.rpc.UnaryCallable;
import com.google.cloud.aiplatform.v1.CreateEndpointOperationMetadata;
import com.google.cloud.aiplatform.v1.CreateEndpointRequest;
@@ -48,7 +47,6 @@
import io.grpc.MethodDescriptor;
import io.grpc.protobuf.ProtoUtils;
import java.io.IOException;
-import java.util.Map;
import java.util.concurrent.TimeUnit;
import javax.annotation.Generated;
@@ -195,91 +193,70 @@ protected GrpcEndpointServiceStub(
GrpcCallSettings.newBuilder()
.setMethodDescriptor(createEndpointMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(CreateEndpointRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("parent", String.valueOf(request.getParent()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("parent", String.valueOf(request.getParent()));
+ return params.build();
})
.build();
GrpcCallSettings getEndpointTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(getEndpointMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(GetEndpointRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("name", String.valueOf(request.getName()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("name", String.valueOf(request.getName()));
+ return params.build();
})
.build();
GrpcCallSettings listEndpointsTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(listEndpointsMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(ListEndpointsRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("parent", String.valueOf(request.getParent()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("parent", String.valueOf(request.getParent()));
+ return params.build();
})
.build();
GrpcCallSettings updateEndpointTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(updateEndpointMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(UpdateEndpointRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("endpoint.name", String.valueOf(request.getEndpoint().getName()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("endpoint.name", String.valueOf(request.getEndpoint().getName()));
+ return params.build();
})
.build();
GrpcCallSettings deleteEndpointTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(deleteEndpointMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(DeleteEndpointRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("name", String.valueOf(request.getName()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("name", String.valueOf(request.getName()));
+ return params.build();
})
.build();
GrpcCallSettings deployModelTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(deployModelMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(DeployModelRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("endpoint", String.valueOf(request.getEndpoint()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("endpoint", String.valueOf(request.getEndpoint()));
+ return params.build();
})
.build();
GrpcCallSettings undeployModelTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(undeployModelMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(UndeployModelRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("endpoint", String.valueOf(request.getEndpoint()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("endpoint", String.valueOf(request.getEndpoint()));
+ return params.build();
})
.build();
@@ -408,7 +385,13 @@ public UnaryCallable undeployModelCallable() {
@Override
public final void close() {
- shutdown();
+ try {
+ backgroundResources.close();
+ } catch (RuntimeException e) {
+ throw e;
+ } catch (Exception e) {
+ throw new IllegalStateException("Failed to close resource", e);
+ }
}
@Override
diff --git a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/stub/GrpcJobServiceStub.java b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/stub/GrpcJobServiceStub.java
index 2db26b4da..3b7a20c95 100644
--- a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/stub/GrpcJobServiceStub.java
+++ b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/stub/GrpcJobServiceStub.java
@@ -27,7 +27,6 @@
import com.google.api.gax.grpc.GrpcStubCallableFactory;
import com.google.api.gax.rpc.ClientContext;
import com.google.api.gax.rpc.OperationCallable;
-import com.google.api.gax.rpc.RequestParamsExtractor;
import com.google.api.gax.rpc.UnaryCallable;
import com.google.cloud.aiplatform.v1.BatchPredictionJob;
import com.google.cloud.aiplatform.v1.CancelBatchPredictionJobRequest;
@@ -65,7 +64,6 @@
import io.grpc.MethodDescriptor;
import io.grpc.protobuf.ProtoUtils;
import java.io.IOException;
-import java.util.Map;
import java.util.concurrent.TimeUnit;
import javax.annotation.Generated;
@@ -393,26 +391,20 @@ protected GrpcJobServiceStub(
GrpcCallSettings.newBuilder()
.setMethodDescriptor(createCustomJobMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(CreateCustomJobRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("parent", String.valueOf(request.getParent()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("parent", String.valueOf(request.getParent()));
+ return params.build();
})
.build();
GrpcCallSettings getCustomJobTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(getCustomJobMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(GetCustomJobRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("name", String.valueOf(request.getName()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("name", String.valueOf(request.getName()));
+ return params.build();
})
.build();
GrpcCallSettings
@@ -420,39 +412,30 @@ public Map extract(GetCustomJobRequest request) {
GrpcCallSettings.newBuilder()
.setMethodDescriptor(listCustomJobsMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(ListCustomJobsRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("parent", String.valueOf(request.getParent()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("parent", String.valueOf(request.getParent()));
+ return params.build();
})
.build();
GrpcCallSettings deleteCustomJobTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(deleteCustomJobMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(DeleteCustomJobRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("name", String.valueOf(request.getName()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("name", String.valueOf(request.getName()));
+ return params.build();
})
.build();
GrpcCallSettings cancelCustomJobTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(cancelCustomJobMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(CancelCustomJobRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("name", String.valueOf(request.getName()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("name", String.valueOf(request.getName()));
+ return params.build();
})
.build();
GrpcCallSettings
@@ -460,13 +443,10 @@ public Map extract(CancelCustomJobRequest request) {
GrpcCallSettings.newBuilder()
.setMethodDescriptor(createDataLabelingJobMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(CreateDataLabelingJobRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("parent", String.valueOf(request.getParent()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("parent", String.valueOf(request.getParent()));
+ return params.build();
})
.build();
GrpcCallSettings
@@ -474,13 +454,10 @@ public Map extract(CreateDataLabelingJobRequest request) {
GrpcCallSettings.newBuilder()
.setMethodDescriptor(getDataLabelingJobMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(GetDataLabelingJobRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("name", String.valueOf(request.getName()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("name", String.valueOf(request.getName()));
+ return params.build();
})
.build();
GrpcCallSettings
@@ -488,13 +465,10 @@ public Map extract(GetDataLabelingJobRequest request) {
GrpcCallSettings.newBuilder()
.setMethodDescriptor(listDataLabelingJobsMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(ListDataLabelingJobsRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("parent", String.valueOf(request.getParent()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("parent", String.valueOf(request.getParent()));
+ return params.build();
})
.build();
GrpcCallSettings
@@ -502,26 +476,20 @@ public Map extract(ListDataLabelingJobsRequest request) {
GrpcCallSettings.newBuilder()
.setMethodDescriptor(deleteDataLabelingJobMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(DeleteDataLabelingJobRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("name", String.valueOf(request.getName()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("name", String.valueOf(request.getName()));
+ return params.build();
})
.build();
GrpcCallSettings cancelDataLabelingJobTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(cancelDataLabelingJobMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor