+ evaluateProcessorVersionCallable() {
+ return stub.evaluateProcessorVersionCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Retrieves a specific evaluation.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (DocumentProcessorServiceClient documentProcessorServiceClient =
+ * DocumentProcessorServiceClient.create()) {
+ * EvaluationName name =
+ * EvaluationName.of(
+ * "[PROJECT]", "[LOCATION]", "[PROCESSOR]", "[PROCESSOR_VERSION]", "[EVALUATION]");
+ * Evaluation response = documentProcessorServiceClient.getEvaluation(name);
+ * }
+ * }
+ *
+ * @param name Required. The resource name of the
+ * [Evaluation][google.cloud.documentai.v1.Evaluation] to get.
+ * `projects/{project}/locations/{location}/processors/{processor}/processorVersions/{processorVersion}/evaluations/{evaluation}`
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final Evaluation getEvaluation(EvaluationName name) {
+ GetEvaluationRequest request =
+ GetEvaluationRequest.newBuilder().setName(name == null ? null : name.toString()).build();
+ return getEvaluation(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Retrieves a specific evaluation.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (DocumentProcessorServiceClient documentProcessorServiceClient =
+ * DocumentProcessorServiceClient.create()) {
+ * String name =
+ * EvaluationName.of(
+ * "[PROJECT]", "[LOCATION]", "[PROCESSOR]", "[PROCESSOR_VERSION]", "[EVALUATION]")
+ * .toString();
+ * Evaluation response = documentProcessorServiceClient.getEvaluation(name);
+ * }
+ * }
+ *
+ * @param name Required. The resource name of the
+ * [Evaluation][google.cloud.documentai.v1.Evaluation] to get.
+ * `projects/{project}/locations/{location}/processors/{processor}/processorVersions/{processorVersion}/evaluations/{evaluation}`
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final Evaluation getEvaluation(String name) {
+ GetEvaluationRequest request = GetEvaluationRequest.newBuilder().setName(name).build();
+ return getEvaluation(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Retrieves a specific evaluation.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (DocumentProcessorServiceClient documentProcessorServiceClient =
+ * DocumentProcessorServiceClient.create()) {
+ * GetEvaluationRequest request =
+ * GetEvaluationRequest.newBuilder()
+ * .setName(
+ * EvaluationName.of(
+ * "[PROJECT]",
+ * "[LOCATION]",
+ * "[PROCESSOR]",
+ * "[PROCESSOR_VERSION]",
+ * "[EVALUATION]")
+ * .toString())
+ * .build();
+ * Evaluation response = documentProcessorServiceClient.getEvaluation(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 Evaluation getEvaluation(GetEvaluationRequest request) {
+ return getEvaluationCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Retrieves a specific evaluation.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (DocumentProcessorServiceClient documentProcessorServiceClient =
+ * DocumentProcessorServiceClient.create()) {
+ * GetEvaluationRequest request =
+ * GetEvaluationRequest.newBuilder()
+ * .setName(
+ * EvaluationName.of(
+ * "[PROJECT]",
+ * "[LOCATION]",
+ * "[PROCESSOR]",
+ * "[PROCESSOR_VERSION]",
+ * "[EVALUATION]")
+ * .toString())
+ * .build();
+ * ApiFuture future =
+ * documentProcessorServiceClient.getEvaluationCallable().futureCall(request);
+ * // Do something.
+ * Evaluation response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable getEvaluationCallable() {
+ return stub.getEvaluationCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Retrieves a set of evaluations for a given processor version.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (DocumentProcessorServiceClient documentProcessorServiceClient =
+ * DocumentProcessorServiceClient.create()) {
+ * ProcessorVersionName parent =
+ * ProcessorVersionName.of("[PROJECT]", "[LOCATION]", "[PROCESSOR]", "[PROCESSOR_VERSION]");
+ * for (Evaluation element :
+ * documentProcessorServiceClient.listEvaluations(parent).iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ * }
+ *
+ * @param parent Required. The resource name of the
+ * [ProcessorVersion][google.cloud.documentai.v1.ProcessorVersion] to list evaluations for.
+ * `projects/{project}/locations/{location}/processors/{processor}/processorVersions/{processorVersion}`
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final ListEvaluationsPagedResponse listEvaluations(ProcessorVersionName parent) {
+ ListEvaluationsRequest request =
+ ListEvaluationsRequest.newBuilder()
+ .setParent(parent == null ? null : parent.toString())
+ .build();
+ return listEvaluations(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Retrieves a set of evaluations for a given processor version.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (DocumentProcessorServiceClient documentProcessorServiceClient =
+ * DocumentProcessorServiceClient.create()) {
+ * String parent =
+ * ProcessorVersionName.of("[PROJECT]", "[LOCATION]", "[PROCESSOR]", "[PROCESSOR_VERSION]")
+ * .toString();
+ * for (Evaluation element :
+ * documentProcessorServiceClient.listEvaluations(parent).iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ * }
+ *
+ * @param parent Required. The resource name of the
+ * [ProcessorVersion][google.cloud.documentai.v1.ProcessorVersion] to list evaluations for.
+ * `projects/{project}/locations/{location}/processors/{processor}/processorVersions/{processorVersion}`
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final ListEvaluationsPagedResponse listEvaluations(String parent) {
+ ListEvaluationsRequest request = ListEvaluationsRequest.newBuilder().setParent(parent).build();
+ return listEvaluations(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Retrieves a set of evaluations for a given processor version.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (DocumentProcessorServiceClient documentProcessorServiceClient =
+ * DocumentProcessorServiceClient.create()) {
+ * ListEvaluationsRequest request =
+ * ListEvaluationsRequest.newBuilder()
+ * .setParent(
+ * ProcessorVersionName.of(
+ * "[PROJECT]", "[LOCATION]", "[PROCESSOR]", "[PROCESSOR_VERSION]")
+ * .toString())
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .build();
+ * for (Evaluation element :
+ * documentProcessorServiceClient.listEvaluations(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 ListEvaluationsPagedResponse listEvaluations(ListEvaluationsRequest request) {
+ return listEvaluationsPagedCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Retrieves a set of evaluations for a given processor version.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (DocumentProcessorServiceClient documentProcessorServiceClient =
+ * DocumentProcessorServiceClient.create()) {
+ * ListEvaluationsRequest request =
+ * ListEvaluationsRequest.newBuilder()
+ * .setParent(
+ * ProcessorVersionName.of(
+ * "[PROJECT]", "[LOCATION]", "[PROCESSOR]", "[PROCESSOR_VERSION]")
+ * .toString())
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .build();
+ * ApiFuture future =
+ * documentProcessorServiceClient.listEvaluationsPagedCallable().futureCall(request);
+ * // Do something.
+ * for (Evaluation element : future.get().iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ * }
+ */
+ public final UnaryCallable
+ listEvaluationsPagedCallable() {
+ return stub.listEvaluationsPagedCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Retrieves a set of evaluations for a given processor version.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (DocumentProcessorServiceClient documentProcessorServiceClient =
+ * DocumentProcessorServiceClient.create()) {
+ * ListEvaluationsRequest request =
+ * ListEvaluationsRequest.newBuilder()
+ * .setParent(
+ * ProcessorVersionName.of(
+ * "[PROJECT]", "[LOCATION]", "[PROCESSOR]", "[PROCESSOR_VERSION]")
+ * .toString())
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .build();
+ * while (true) {
+ * ListEvaluationsResponse response =
+ * documentProcessorServiceClient.listEvaluationsCallable().call(request);
+ * for (Evaluation element : response.getEvaluationsList()) {
+ * // doThingsWith(element);
+ * }
+ * String nextPageToken = response.getNextPageToken();
+ * if (!Strings.isNullOrEmpty(nextPageToken)) {
+ * request = request.toBuilder().setPageToken(nextPageToken).build();
+ * } else {
+ * break;
+ * }
+ * }
+ * }
+ * }
+ */
+ public final UnaryCallable
+ listEvaluationsCallable() {
+ return stub.listEvaluationsCallable();
+ }
+
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Lists information about the supported locations for this service.
@@ -3215,6 +3907,83 @@ protected ListProcessorVersionsFixedSizeCollection createCollection(
}
}
+ public static class ListEvaluationsPagedResponse
+ extends AbstractPagedListResponse<
+ ListEvaluationsRequest,
+ ListEvaluationsResponse,
+ Evaluation,
+ ListEvaluationsPage,
+ ListEvaluationsFixedSizeCollection> {
+
+ public static ApiFuture createAsync(
+ PageContext context,
+ ApiFuture futureResponse) {
+ ApiFuture futurePage =
+ ListEvaluationsPage.createEmptyPage().createPageAsync(context, futureResponse);
+ return ApiFutures.transform(
+ futurePage,
+ input -> new ListEvaluationsPagedResponse(input),
+ MoreExecutors.directExecutor());
+ }
+
+ private ListEvaluationsPagedResponse(ListEvaluationsPage page) {
+ super(page, ListEvaluationsFixedSizeCollection.createEmptyCollection());
+ }
+ }
+
+ public static class ListEvaluationsPage
+ extends AbstractPage<
+ ListEvaluationsRequest, ListEvaluationsResponse, Evaluation, ListEvaluationsPage> {
+
+ private ListEvaluationsPage(
+ PageContext context,
+ ListEvaluationsResponse response) {
+ super(context, response);
+ }
+
+ private static ListEvaluationsPage createEmptyPage() {
+ return new ListEvaluationsPage(null, null);
+ }
+
+ @Override
+ protected ListEvaluationsPage createPage(
+ PageContext context,
+ ListEvaluationsResponse response) {
+ return new ListEvaluationsPage(context, response);
+ }
+
+ @Override
+ public ApiFuture createPageAsync(
+ PageContext context,
+ ApiFuture futureResponse) {
+ return super.createPageAsync(context, futureResponse);
+ }
+ }
+
+ public static class ListEvaluationsFixedSizeCollection
+ extends AbstractFixedSizeCollection<
+ ListEvaluationsRequest,
+ ListEvaluationsResponse,
+ Evaluation,
+ ListEvaluationsPage,
+ ListEvaluationsFixedSizeCollection> {
+
+ private ListEvaluationsFixedSizeCollection(
+ List pages, int collectionSize) {
+ super(pages, collectionSize);
+ }
+
+ private static ListEvaluationsFixedSizeCollection createEmptyCollection() {
+ return new ListEvaluationsFixedSizeCollection(null, 0);
+ }
+
+ @Override
+ protected ListEvaluationsFixedSizeCollection createCollection(
+ List pages, int collectionSize) {
+ return new ListEvaluationsFixedSizeCollection(pages, collectionSize);
+ }
+ }
+
public static class ListLocationsPagedResponse
extends AbstractPagedListResponse<
ListLocationsRequest,
diff --git a/java-document-ai/google-cloud-document-ai/src/main/java/com/google/cloud/documentai/v1/DocumentProcessorServiceSettings.java b/java-document-ai/google-cloud-document-ai/src/main/java/com/google/cloud/documentai/v1/DocumentProcessorServiceSettings.java
index f9ca094c1be0..b6cd1af358ed 100644
--- a/java-document-ai/google-cloud-document-ai/src/main/java/com/google/cloud/documentai/v1/DocumentProcessorServiceSettings.java
+++ b/java-document-ai/google-cloud-document-ai/src/main/java/com/google/cloud/documentai/v1/DocumentProcessorServiceSettings.java
@@ -16,6 +16,7 @@
package com.google.cloud.documentai.v1;
+import static com.google.cloud.documentai.v1.DocumentProcessorServiceClient.ListEvaluationsPagedResponse;
import static com.google.cloud.documentai.v1.DocumentProcessorServiceClient.ListLocationsPagedResponse;
import static com.google.cloud.documentai.v1.DocumentProcessorServiceClient.ListProcessorTypesPagedResponse;
import static com.google.cloud.documentai.v1.DocumentProcessorServiceClient.ListProcessorVersionsPagedResponse;
@@ -135,6 +136,23 @@ public UnaryCallSettings getProcessorSettings()
return ((DocumentProcessorServiceStubSettings) getStubSettings()).getProcessorSettings();
}
+ /** Returns the object with the settings used for calls to trainProcessorVersion. */
+ public UnaryCallSettings
+ trainProcessorVersionSettings() {
+ return ((DocumentProcessorServiceStubSettings) getStubSettings())
+ .trainProcessorVersionSettings();
+ }
+
+ /** Returns the object with the settings used for calls to trainProcessorVersion. */
+ public OperationCallSettings<
+ TrainProcessorVersionRequest,
+ TrainProcessorVersionResponse,
+ TrainProcessorVersionMetadata>
+ trainProcessorVersionOperationSettings() {
+ return ((DocumentProcessorServiceStubSettings) getStubSettings())
+ .trainProcessorVersionOperationSettings();
+ }
+
/** Returns the object with the settings used for calls to getProcessorVersion. */
public UnaryCallSettings
getProcessorVersionSettings() {
@@ -272,6 +290,35 @@ public UnaryCallSettings reviewDocumentSetting
.reviewDocumentOperationSettings();
}
+ /** Returns the object with the settings used for calls to evaluateProcessorVersion. */
+ public UnaryCallSettings
+ evaluateProcessorVersionSettings() {
+ return ((DocumentProcessorServiceStubSettings) getStubSettings())
+ .evaluateProcessorVersionSettings();
+ }
+
+ /** Returns the object with the settings used for calls to evaluateProcessorVersion. */
+ public OperationCallSettings<
+ EvaluateProcessorVersionRequest,
+ EvaluateProcessorVersionResponse,
+ EvaluateProcessorVersionMetadata>
+ evaluateProcessorVersionOperationSettings() {
+ return ((DocumentProcessorServiceStubSettings) getStubSettings())
+ .evaluateProcessorVersionOperationSettings();
+ }
+
+ /** Returns the object with the settings used for calls to getEvaluation. */
+ public UnaryCallSettings getEvaluationSettings() {
+ return ((DocumentProcessorServiceStubSettings) getStubSettings()).getEvaluationSettings();
+ }
+
+ /** Returns the object with the settings used for calls to listEvaluations. */
+ public PagedCallSettings<
+ ListEvaluationsRequest, ListEvaluationsResponse, ListEvaluationsPagedResponse>
+ listEvaluationsSettings() {
+ return ((DocumentProcessorServiceStubSettings) getStubSettings()).listEvaluationsSettings();
+ }
+
/** Returns the object with the settings used for calls to listLocations. */
public PagedCallSettings
listLocationsSettings() {
@@ -448,6 +495,21 @@ public UnaryCallSettings.Builder getProcessorSet
return getStubSettingsBuilder().getProcessorSettings();
}
+ /** Returns the builder for the settings used for calls to trainProcessorVersion. */
+ public UnaryCallSettings.Builder
+ trainProcessorVersionSettings() {
+ return getStubSettingsBuilder().trainProcessorVersionSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to trainProcessorVersion. */
+ public OperationCallSettings.Builder<
+ TrainProcessorVersionRequest,
+ TrainProcessorVersionResponse,
+ TrainProcessorVersionMetadata>
+ trainProcessorVersionOperationSettings() {
+ return getStubSettingsBuilder().trainProcessorVersionOperationSettings();
+ }
+
/** Returns the builder for the settings used for calls to getProcessorVersion. */
public UnaryCallSettings.Builder
getProcessorVersionSettings() {
@@ -574,6 +636,33 @@ public UnaryCallSettings.Builder reviewDocumen
return getStubSettingsBuilder().reviewDocumentOperationSettings();
}
+ /** Returns the builder for the settings used for calls to evaluateProcessorVersion. */
+ public UnaryCallSettings.Builder
+ evaluateProcessorVersionSettings() {
+ return getStubSettingsBuilder().evaluateProcessorVersionSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to evaluateProcessorVersion. */
+ public OperationCallSettings.Builder<
+ EvaluateProcessorVersionRequest,
+ EvaluateProcessorVersionResponse,
+ EvaluateProcessorVersionMetadata>
+ evaluateProcessorVersionOperationSettings() {
+ return getStubSettingsBuilder().evaluateProcessorVersionOperationSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to getEvaluation. */
+ public UnaryCallSettings.Builder getEvaluationSettings() {
+ return getStubSettingsBuilder().getEvaluationSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to listEvaluations. */
+ public PagedCallSettings.Builder<
+ ListEvaluationsRequest, ListEvaluationsResponse, ListEvaluationsPagedResponse>
+ listEvaluationsSettings() {
+ return getStubSettingsBuilder().listEvaluationsSettings();
+ }
+
/** Returns the builder for the settings used for calls to listLocations. */
public PagedCallSettings.Builder<
ListLocationsRequest, ListLocationsResponse, ListLocationsPagedResponse>
diff --git a/java-document-ai/google-cloud-document-ai/src/main/java/com/google/cloud/documentai/v1/gapic_metadata.json b/java-document-ai/google-cloud-document-ai/src/main/java/com/google/cloud/documentai/v1/gapic_metadata.json
index 892bb4377e8a..4700b003434d 100644
--- a/java-document-ai/google-cloud-document-ai/src/main/java/com/google/cloud/documentai/v1/gapic_metadata.json
+++ b/java-document-ai/google-cloud-document-ai/src/main/java/com/google/cloud/documentai/v1/gapic_metadata.json
@@ -31,9 +31,15 @@
"EnableProcessor": {
"methods": ["enableProcessorAsync", "enableProcessorOperationCallable", "enableProcessorCallable"]
},
+ "EvaluateProcessorVersion": {
+ "methods": ["evaluateProcessorVersionAsync", "evaluateProcessorVersionAsync", "evaluateProcessorVersionAsync", "evaluateProcessorVersionOperationCallable", "evaluateProcessorVersionCallable"]
+ },
"FetchProcessorTypes": {
"methods": ["fetchProcessorTypes", "fetchProcessorTypes", "fetchProcessorTypes", "fetchProcessorTypesCallable"]
},
+ "GetEvaluation": {
+ "methods": ["getEvaluation", "getEvaluation", "getEvaluation", "getEvaluationCallable"]
+ },
"GetLocation": {
"methods": ["getLocation", "getLocationCallable"]
},
@@ -46,6 +52,9 @@
"GetProcessorVersion": {
"methods": ["getProcessorVersion", "getProcessorVersion", "getProcessorVersion", "getProcessorVersionCallable"]
},
+ "ListEvaluations": {
+ "methods": ["listEvaluations", "listEvaluations", "listEvaluations", "listEvaluationsPagedCallable", "listEvaluationsCallable"]
+ },
"ListLocations": {
"methods": ["listLocations", "listLocationsPagedCallable", "listLocationsCallable"]
},
@@ -67,6 +76,9 @@
"SetDefaultProcessorVersion": {
"methods": ["setDefaultProcessorVersionAsync", "setDefaultProcessorVersionOperationCallable", "setDefaultProcessorVersionCallable"]
},
+ "TrainProcessorVersion": {
+ "methods": ["trainProcessorVersionAsync", "trainProcessorVersionAsync", "trainProcessorVersionAsync", "trainProcessorVersionOperationCallable", "trainProcessorVersionCallable"]
+ },
"UndeployProcessorVersion": {
"methods": ["undeployProcessorVersionAsync", "undeployProcessorVersionAsync", "undeployProcessorVersionAsync", "undeployProcessorVersionOperationCallable", "undeployProcessorVersionCallable"]
}
diff --git a/java-document-ai/google-cloud-document-ai/src/main/java/com/google/cloud/documentai/v1/stub/DocumentProcessorServiceStub.java b/java-document-ai/google-cloud-document-ai/src/main/java/com/google/cloud/documentai/v1/stub/DocumentProcessorServiceStub.java
index ee87ad7b766b..c81306309a5c 100644
--- a/java-document-ai/google-cloud-document-ai/src/main/java/com/google/cloud/documentai/v1/stub/DocumentProcessorServiceStub.java
+++ b/java-document-ai/google-cloud-document-ai/src/main/java/com/google/cloud/documentai/v1/stub/DocumentProcessorServiceStub.java
@@ -16,6 +16,7 @@
package com.google.cloud.documentai.v1.stub;
+import static com.google.cloud.documentai.v1.DocumentProcessorServiceClient.ListEvaluationsPagedResponse;
import static com.google.cloud.documentai.v1.DocumentProcessorServiceClient.ListLocationsPagedResponse;
import static com.google.cloud.documentai.v1.DocumentProcessorServiceClient.ListProcessorTypesPagedResponse;
import static com.google.cloud.documentai.v1.DocumentProcessorServiceClient.ListProcessorVersionsPagedResponse;
@@ -41,11 +42,18 @@
import com.google.cloud.documentai.v1.EnableProcessorMetadata;
import com.google.cloud.documentai.v1.EnableProcessorRequest;
import com.google.cloud.documentai.v1.EnableProcessorResponse;
+import com.google.cloud.documentai.v1.EvaluateProcessorVersionMetadata;
+import com.google.cloud.documentai.v1.EvaluateProcessorVersionRequest;
+import com.google.cloud.documentai.v1.EvaluateProcessorVersionResponse;
+import com.google.cloud.documentai.v1.Evaluation;
import com.google.cloud.documentai.v1.FetchProcessorTypesRequest;
import com.google.cloud.documentai.v1.FetchProcessorTypesResponse;
+import com.google.cloud.documentai.v1.GetEvaluationRequest;
import com.google.cloud.documentai.v1.GetProcessorRequest;
import com.google.cloud.documentai.v1.GetProcessorTypeRequest;
import com.google.cloud.documentai.v1.GetProcessorVersionRequest;
+import com.google.cloud.documentai.v1.ListEvaluationsRequest;
+import com.google.cloud.documentai.v1.ListEvaluationsResponse;
import com.google.cloud.documentai.v1.ListProcessorTypesRequest;
import com.google.cloud.documentai.v1.ListProcessorTypesResponse;
import com.google.cloud.documentai.v1.ListProcessorVersionsRequest;
@@ -63,6 +71,9 @@
import com.google.cloud.documentai.v1.SetDefaultProcessorVersionMetadata;
import com.google.cloud.documentai.v1.SetDefaultProcessorVersionRequest;
import com.google.cloud.documentai.v1.SetDefaultProcessorVersionResponse;
+import com.google.cloud.documentai.v1.TrainProcessorVersionMetadata;
+import com.google.cloud.documentai.v1.TrainProcessorVersionRequest;
+import com.google.cloud.documentai.v1.TrainProcessorVersionResponse;
import com.google.cloud.documentai.v1.UndeployProcessorVersionMetadata;
import com.google.cloud.documentai.v1.UndeployProcessorVersionRequest;
import com.google.cloud.documentai.v1.UndeployProcessorVersionResponse;
@@ -138,6 +149,19 @@ public UnaryCallable getProcessorCallable() {
throw new UnsupportedOperationException("Not implemented: getProcessorCallable()");
}
+ public OperationCallable<
+ TrainProcessorVersionRequest,
+ TrainProcessorVersionResponse,
+ TrainProcessorVersionMetadata>
+ trainProcessorVersionOperationCallable() {
+ throw new UnsupportedOperationException(
+ "Not implemented: trainProcessorVersionOperationCallable()");
+ }
+
+ public UnaryCallable trainProcessorVersionCallable() {
+ throw new UnsupportedOperationException("Not implemented: trainProcessorVersionCallable()");
+ }
+
public UnaryCallable getProcessorVersionCallable() {
throw new UnsupportedOperationException("Not implemented: getProcessorVersionCallable()");
}
@@ -247,6 +271,33 @@ public UnaryCallable reviewDocumentCallable()
throw new UnsupportedOperationException("Not implemented: reviewDocumentCallable()");
}
+ public OperationCallable<
+ EvaluateProcessorVersionRequest,
+ EvaluateProcessorVersionResponse,
+ EvaluateProcessorVersionMetadata>
+ evaluateProcessorVersionOperationCallable() {
+ throw new UnsupportedOperationException(
+ "Not implemented: evaluateProcessorVersionOperationCallable()");
+ }
+
+ public UnaryCallable
+ evaluateProcessorVersionCallable() {
+ throw new UnsupportedOperationException("Not implemented: evaluateProcessorVersionCallable()");
+ }
+
+ public UnaryCallable getEvaluationCallable() {
+ throw new UnsupportedOperationException("Not implemented: getEvaluationCallable()");
+ }
+
+ public UnaryCallable
+ listEvaluationsPagedCallable() {
+ throw new UnsupportedOperationException("Not implemented: listEvaluationsPagedCallable()");
+ }
+
+ public UnaryCallable listEvaluationsCallable() {
+ throw new UnsupportedOperationException("Not implemented: listEvaluationsCallable()");
+ }
+
public UnaryCallable
listLocationsPagedCallable() {
throw new UnsupportedOperationException("Not implemented: listLocationsPagedCallable()");
diff --git a/java-document-ai/google-cloud-document-ai/src/main/java/com/google/cloud/documentai/v1/stub/DocumentProcessorServiceStubSettings.java b/java-document-ai/google-cloud-document-ai/src/main/java/com/google/cloud/documentai/v1/stub/DocumentProcessorServiceStubSettings.java
index 97fce3e2d036..170fa298548f 100644
--- a/java-document-ai/google-cloud-document-ai/src/main/java/com/google/cloud/documentai/v1/stub/DocumentProcessorServiceStubSettings.java
+++ b/java-document-ai/google-cloud-document-ai/src/main/java/com/google/cloud/documentai/v1/stub/DocumentProcessorServiceStubSettings.java
@@ -16,6 +16,7 @@
package com.google.cloud.documentai.v1.stub;
+import static com.google.cloud.documentai.v1.DocumentProcessorServiceClient.ListEvaluationsPagedResponse;
import static com.google.cloud.documentai.v1.DocumentProcessorServiceClient.ListLocationsPagedResponse;
import static com.google.cloud.documentai.v1.DocumentProcessorServiceClient.ListProcessorTypesPagedResponse;
import static com.google.cloud.documentai.v1.DocumentProcessorServiceClient.ListProcessorVersionsPagedResponse;
@@ -67,11 +68,18 @@
import com.google.cloud.documentai.v1.EnableProcessorMetadata;
import com.google.cloud.documentai.v1.EnableProcessorRequest;
import com.google.cloud.documentai.v1.EnableProcessorResponse;
+import com.google.cloud.documentai.v1.EvaluateProcessorVersionMetadata;
+import com.google.cloud.documentai.v1.EvaluateProcessorVersionRequest;
+import com.google.cloud.documentai.v1.EvaluateProcessorVersionResponse;
+import com.google.cloud.documentai.v1.Evaluation;
import com.google.cloud.documentai.v1.FetchProcessorTypesRequest;
import com.google.cloud.documentai.v1.FetchProcessorTypesResponse;
+import com.google.cloud.documentai.v1.GetEvaluationRequest;
import com.google.cloud.documentai.v1.GetProcessorRequest;
import com.google.cloud.documentai.v1.GetProcessorTypeRequest;
import com.google.cloud.documentai.v1.GetProcessorVersionRequest;
+import com.google.cloud.documentai.v1.ListEvaluationsRequest;
+import com.google.cloud.documentai.v1.ListEvaluationsResponse;
import com.google.cloud.documentai.v1.ListProcessorTypesRequest;
import com.google.cloud.documentai.v1.ListProcessorTypesResponse;
import com.google.cloud.documentai.v1.ListProcessorVersionsRequest;
@@ -89,6 +97,9 @@
import com.google.cloud.documentai.v1.SetDefaultProcessorVersionMetadata;
import com.google.cloud.documentai.v1.SetDefaultProcessorVersionRequest;
import com.google.cloud.documentai.v1.SetDefaultProcessorVersionResponse;
+import com.google.cloud.documentai.v1.TrainProcessorVersionMetadata;
+import com.google.cloud.documentai.v1.TrainProcessorVersionRequest;
+import com.google.cloud.documentai.v1.TrainProcessorVersionResponse;
import com.google.cloud.documentai.v1.UndeployProcessorVersionMetadata;
import com.google.cloud.documentai.v1.UndeployProcessorVersionRequest;
import com.google.cloud.documentai.v1.UndeployProcessorVersionResponse;
@@ -167,6 +178,13 @@ public class DocumentProcessorServiceStubSettings
ListProcessorsRequest, ListProcessorsResponse, ListProcessorsPagedResponse>
listProcessorsSettings;
private final UnaryCallSettings getProcessorSettings;
+ private final UnaryCallSettings
+ trainProcessorVersionSettings;
+ private final OperationCallSettings<
+ TrainProcessorVersionRequest,
+ TrainProcessorVersionResponse,
+ TrainProcessorVersionMetadata>
+ trainProcessorVersionOperationSettings;
private final UnaryCallSettings
getProcessorVersionSettings;
private final PagedCallSettings<
@@ -216,6 +234,17 @@ public class DocumentProcessorServiceStubSettings
private final OperationCallSettings<
ReviewDocumentRequest, ReviewDocumentResponse, ReviewDocumentOperationMetadata>
reviewDocumentOperationSettings;
+ private final UnaryCallSettings
+ evaluateProcessorVersionSettings;
+ private final OperationCallSettings<
+ EvaluateProcessorVersionRequest,
+ EvaluateProcessorVersionResponse,
+ EvaluateProcessorVersionMetadata>
+ evaluateProcessorVersionOperationSettings;
+ private final UnaryCallSettings getEvaluationSettings;
+ private final PagedCallSettings<
+ ListEvaluationsRequest, ListEvaluationsResponse, ListEvaluationsPagedResponse>
+ listEvaluationsSettings;
private final PagedCallSettings<
ListLocationsRequest, ListLocationsResponse, ListLocationsPagedResponse>
listLocationsSettings;
@@ -339,6 +368,45 @@ public Iterable extractResources(
}
};
+ private static final PagedListDescriptor<
+ ListEvaluationsRequest, ListEvaluationsResponse, Evaluation>
+ LIST_EVALUATIONS_PAGE_STR_DESC =
+ new PagedListDescriptor() {
+ @Override
+ public String emptyToken() {
+ return "";
+ }
+
+ @Override
+ public ListEvaluationsRequest injectToken(
+ ListEvaluationsRequest payload, String token) {
+ return ListEvaluationsRequest.newBuilder(payload).setPageToken(token).build();
+ }
+
+ @Override
+ public ListEvaluationsRequest injectPageSize(
+ ListEvaluationsRequest payload, int pageSize) {
+ return ListEvaluationsRequest.newBuilder(payload).setPageSize(pageSize).build();
+ }
+
+ @Override
+ public Integer extractPageSize(ListEvaluationsRequest payload) {
+ return payload.getPageSize();
+ }
+
+ @Override
+ public String extractNextToken(ListEvaluationsResponse payload) {
+ return payload.getNextPageToken();
+ }
+
+ @Override
+ public Iterable extractResources(ListEvaluationsResponse payload) {
+ return payload.getEvaluationsList() == null
+ ? ImmutableList.of()
+ : payload.getEvaluationsList();
+ }
+ };
+
private static final PagedListDescriptor
LIST_LOCATIONS_PAGE_STR_DESC =
new PagedListDescriptor() {
@@ -437,6 +505,23 @@ public ApiFuture getFuturePagedResponse(
}
};
+ private static final PagedListResponseFactory<
+ ListEvaluationsRequest, ListEvaluationsResponse, ListEvaluationsPagedResponse>
+ LIST_EVALUATIONS_PAGE_STR_FACT =
+ new PagedListResponseFactory<
+ ListEvaluationsRequest, ListEvaluationsResponse, ListEvaluationsPagedResponse>() {
+ @Override
+ public ApiFuture getFuturePagedResponse(
+ UnaryCallable callable,
+ ListEvaluationsRequest request,
+ ApiCallContext context,
+ ApiFuture futureResponse) {
+ PageContext pageContext =
+ PageContext.create(callable, LIST_EVALUATIONS_PAGE_STR_DESC, request, context);
+ return ListEvaluationsPagedResponse.createAsync(pageContext, futureResponse);
+ }
+ };
+
private static final PagedListResponseFactory<
ListLocationsRequest, ListLocationsResponse, ListLocationsPagedResponse>
LIST_LOCATIONS_PAGE_STR_FACT =
@@ -500,6 +585,21 @@ public UnaryCallSettings getProcessorSettings()
return getProcessorSettings;
}
+ /** Returns the object with the settings used for calls to trainProcessorVersion. */
+ public UnaryCallSettings
+ trainProcessorVersionSettings() {
+ return trainProcessorVersionSettings;
+ }
+
+ /** Returns the object with the settings used for calls to trainProcessorVersion. */
+ public OperationCallSettings<
+ TrainProcessorVersionRequest,
+ TrainProcessorVersionResponse,
+ TrainProcessorVersionMetadata>
+ trainProcessorVersionOperationSettings() {
+ return trainProcessorVersionOperationSettings;
+ }
+
/** Returns the object with the settings used for calls to getProcessorVersion. */
public UnaryCallSettings
getProcessorVersionSettings() {
@@ -624,6 +724,33 @@ public UnaryCallSettings reviewDocumentSetting
return reviewDocumentOperationSettings;
}
+ /** Returns the object with the settings used for calls to evaluateProcessorVersion. */
+ public UnaryCallSettings
+ evaluateProcessorVersionSettings() {
+ return evaluateProcessorVersionSettings;
+ }
+
+ /** Returns the object with the settings used for calls to evaluateProcessorVersion. */
+ public OperationCallSettings<
+ EvaluateProcessorVersionRequest,
+ EvaluateProcessorVersionResponse,
+ EvaluateProcessorVersionMetadata>
+ evaluateProcessorVersionOperationSettings() {
+ return evaluateProcessorVersionOperationSettings;
+ }
+
+ /** Returns the object with the settings used for calls to getEvaluation. */
+ public UnaryCallSettings getEvaluationSettings() {
+ return getEvaluationSettings;
+ }
+
+ /** Returns the object with the settings used for calls to listEvaluations. */
+ public PagedCallSettings<
+ ListEvaluationsRequest, ListEvaluationsResponse, ListEvaluationsPagedResponse>
+ listEvaluationsSettings() {
+ return listEvaluationsSettings;
+ }
+
/** Returns the object with the settings used for calls to listLocations. */
public PagedCallSettings
listLocationsSettings() {
@@ -750,6 +877,9 @@ protected DocumentProcessorServiceStubSettings(Builder settingsBuilder) throws I
getProcessorTypeSettings = settingsBuilder.getProcessorTypeSettings().build();
listProcessorsSettings = settingsBuilder.listProcessorsSettings().build();
getProcessorSettings = settingsBuilder.getProcessorSettings().build();
+ trainProcessorVersionSettings = settingsBuilder.trainProcessorVersionSettings().build();
+ trainProcessorVersionOperationSettings =
+ settingsBuilder.trainProcessorVersionOperationSettings().build();
getProcessorVersionSettings = settingsBuilder.getProcessorVersionSettings().build();
listProcessorVersionsSettings = settingsBuilder.listProcessorVersionsSettings().build();
deleteProcessorVersionSettings = settingsBuilder.deleteProcessorVersionSettings().build();
@@ -774,6 +904,11 @@ protected DocumentProcessorServiceStubSettings(Builder settingsBuilder) throws I
settingsBuilder.setDefaultProcessorVersionOperationSettings().build();
reviewDocumentSettings = settingsBuilder.reviewDocumentSettings().build();
reviewDocumentOperationSettings = settingsBuilder.reviewDocumentOperationSettings().build();
+ evaluateProcessorVersionSettings = settingsBuilder.evaluateProcessorVersionSettings().build();
+ evaluateProcessorVersionOperationSettings =
+ settingsBuilder.evaluateProcessorVersionOperationSettings().build();
+ getEvaluationSettings = settingsBuilder.getEvaluationSettings().build();
+ listEvaluationsSettings = settingsBuilder.listEvaluationsSettings().build();
listLocationsSettings = settingsBuilder.listLocationsSettings().build();
getLocationSettings = settingsBuilder.getLocationSettings().build();
}
@@ -800,6 +935,13 @@ public static class Builder
ListProcessorsRequest, ListProcessorsResponse, ListProcessorsPagedResponse>
listProcessorsSettings;
private final UnaryCallSettings.Builder getProcessorSettings;
+ private final UnaryCallSettings.Builder
+ trainProcessorVersionSettings;
+ private final OperationCallSettings.Builder<
+ TrainProcessorVersionRequest,
+ TrainProcessorVersionResponse,
+ TrainProcessorVersionMetadata>
+ trainProcessorVersionOperationSettings;
private final UnaryCallSettings.Builder
getProcessorVersionSettings;
private final PagedCallSettings.Builder<
@@ -855,6 +997,17 @@ public static class Builder
private final OperationCallSettings.Builder<
ReviewDocumentRequest, ReviewDocumentResponse, ReviewDocumentOperationMetadata>
reviewDocumentOperationSettings;
+ private final UnaryCallSettings.Builder
+ evaluateProcessorVersionSettings;
+ private final OperationCallSettings.Builder<
+ EvaluateProcessorVersionRequest,
+ EvaluateProcessorVersionResponse,
+ EvaluateProcessorVersionMetadata>
+ evaluateProcessorVersionOperationSettings;
+ private final UnaryCallSettings.Builder getEvaluationSettings;
+ private final PagedCallSettings.Builder<
+ ListEvaluationsRequest, ListEvaluationsResponse, ListEvaluationsPagedResponse>
+ listEvaluationsSettings;
private final PagedCallSettings.Builder<
ListLocationsRequest, ListLocationsResponse, ListLocationsPagedResponse>
listLocationsSettings;
@@ -910,6 +1063,8 @@ protected Builder(ClientContext clientContext) {
getProcessorTypeSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
listProcessorsSettings = PagedCallSettings.newBuilder(LIST_PROCESSORS_PAGE_STR_FACT);
getProcessorSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ trainProcessorVersionSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ trainProcessorVersionOperationSettings = OperationCallSettings.newBuilder();
getProcessorVersionSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
listProcessorVersionsSettings =
PagedCallSettings.newBuilder(LIST_PROCESSOR_VERSIONS_PAGE_STR_FACT);
@@ -930,6 +1085,10 @@ protected Builder(ClientContext clientContext) {
setDefaultProcessorVersionOperationSettings = OperationCallSettings.newBuilder();
reviewDocumentSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
reviewDocumentOperationSettings = OperationCallSettings.newBuilder();
+ evaluateProcessorVersionSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ evaluateProcessorVersionOperationSettings = OperationCallSettings.newBuilder();
+ getEvaluationSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ listEvaluationsSettings = PagedCallSettings.newBuilder(LIST_EVALUATIONS_PAGE_STR_FACT);
listLocationsSettings = PagedCallSettings.newBuilder(LIST_LOCATIONS_PAGE_STR_FACT);
getLocationSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
@@ -942,6 +1101,7 @@ protected Builder(ClientContext clientContext) {
getProcessorTypeSettings,
listProcessorsSettings,
getProcessorSettings,
+ trainProcessorVersionSettings,
getProcessorVersionSettings,
listProcessorVersionsSettings,
deleteProcessorVersionSettings,
@@ -953,6 +1113,9 @@ protected Builder(ClientContext clientContext) {
disableProcessorSettings,
setDefaultProcessorVersionSettings,
reviewDocumentSettings,
+ evaluateProcessorVersionSettings,
+ getEvaluationSettings,
+ listEvaluationsSettings,
listLocationsSettings,
getLocationSettings);
initDefaults(this);
@@ -970,6 +1133,9 @@ protected Builder(DocumentProcessorServiceStubSettings settings) {
getProcessorTypeSettings = settings.getProcessorTypeSettings.toBuilder();
listProcessorsSettings = settings.listProcessorsSettings.toBuilder();
getProcessorSettings = settings.getProcessorSettings.toBuilder();
+ trainProcessorVersionSettings = settings.trainProcessorVersionSettings.toBuilder();
+ trainProcessorVersionOperationSettings =
+ settings.trainProcessorVersionOperationSettings.toBuilder();
getProcessorVersionSettings = settings.getProcessorVersionSettings.toBuilder();
listProcessorVersionsSettings = settings.listProcessorVersionsSettings.toBuilder();
deleteProcessorVersionSettings = settings.deleteProcessorVersionSettings.toBuilder();
@@ -993,6 +1159,11 @@ protected Builder(DocumentProcessorServiceStubSettings settings) {
settings.setDefaultProcessorVersionOperationSettings.toBuilder();
reviewDocumentSettings = settings.reviewDocumentSettings.toBuilder();
reviewDocumentOperationSettings = settings.reviewDocumentOperationSettings.toBuilder();
+ evaluateProcessorVersionSettings = settings.evaluateProcessorVersionSettings.toBuilder();
+ evaluateProcessorVersionOperationSettings =
+ settings.evaluateProcessorVersionOperationSettings.toBuilder();
+ getEvaluationSettings = settings.getEvaluationSettings.toBuilder();
+ listEvaluationsSettings = settings.listEvaluationsSettings.toBuilder();
listLocationsSettings = settings.listLocationsSettings.toBuilder();
getLocationSettings = settings.getLocationSettings.toBuilder();
@@ -1005,6 +1176,7 @@ protected Builder(DocumentProcessorServiceStubSettings settings) {
getProcessorTypeSettings,
listProcessorsSettings,
getProcessorSettings,
+ trainProcessorVersionSettings,
getProcessorVersionSettings,
listProcessorVersionsSettings,
deleteProcessorVersionSettings,
@@ -1016,6 +1188,9 @@ protected Builder(DocumentProcessorServiceStubSettings settings) {
disableProcessorSettings,
setDefaultProcessorVersionSettings,
reviewDocumentSettings,
+ evaluateProcessorVersionSettings,
+ getEvaluationSettings,
+ listEvaluationsSettings,
listLocationsSettings,
getLocationSettings);
}
@@ -1082,6 +1257,11 @@ private static Builder initDefaults(Builder builder) {
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
+ builder
+ .trainProcessorVersionSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
+
builder
.getProcessorVersionSettings()
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
@@ -1137,6 +1317,21 @@ private static Builder initDefaults(Builder builder) {
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_0_codes"))
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_0_params"));
+ builder
+ .evaluateProcessorVersionSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
+
+ builder
+ .getEvaluationSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
+
+ builder
+ .listEvaluationsSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
+
builder
.listLocationsSettings()
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
@@ -1171,6 +1366,32 @@ private static Builder initDefaults(Builder builder) {
.setTotalTimeout(Duration.ofMillis(300000L))
.build()));
+ builder
+ .trainProcessorVersionOperationSettings()
+ .setInitialCallSettings(
+ UnaryCallSettings
+ .newUnaryCallSettingsBuilder()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"))
+ .build())
+ .setResponseTransformer(
+ ProtoOperationTransformers.ResponseTransformer.create(
+ TrainProcessorVersionResponse.class))
+ .setMetadataTransformer(
+ ProtoOperationTransformers.MetadataTransformer.create(
+ TrainProcessorVersionMetadata.class))
+ .setPollingAlgorithm(
+ OperationTimedPollAlgorithm.create(
+ RetrySettings.newBuilder()
+ .setInitialRetryDelay(Duration.ofMillis(5000L))
+ .setRetryDelayMultiplier(1.5)
+ .setMaxRetryDelay(Duration.ofMillis(45000L))
+ .setInitialRpcTimeout(Duration.ZERO)
+ .setRpcTimeoutMultiplier(1.0)
+ .setMaxRpcTimeout(Duration.ZERO)
+ .setTotalTimeout(Duration.ofMillis(300000L))
+ .build()));
+
builder
.deleteProcessorVersionOperationSettings()
.setInitialCallSettings(
@@ -1372,6 +1593,32 @@ private static Builder initDefaults(Builder builder) {
.setTotalTimeout(Duration.ofMillis(300000L))
.build()));
+ builder
+ .evaluateProcessorVersionOperationSettings()
+ .setInitialCallSettings(
+ UnaryCallSettings
+ .newUnaryCallSettingsBuilder()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"))
+ .build())
+ .setResponseTransformer(
+ ProtoOperationTransformers.ResponseTransformer.create(
+ EvaluateProcessorVersionResponse.class))
+ .setMetadataTransformer(
+ ProtoOperationTransformers.MetadataTransformer.create(
+ EvaluateProcessorVersionMetadata.class))
+ .setPollingAlgorithm(
+ OperationTimedPollAlgorithm.create(
+ RetrySettings.newBuilder()
+ .setInitialRetryDelay(Duration.ofMillis(5000L))
+ .setRetryDelayMultiplier(1.5)
+ .setMaxRetryDelay(Duration.ofMillis(45000L))
+ .setInitialRpcTimeout(Duration.ZERO)
+ .setRpcTimeoutMultiplier(1.0)
+ .setMaxRpcTimeout(Duration.ZERO)
+ .setTotalTimeout(Duration.ofMillis(300000L))
+ .build()));
+
return builder;
}
@@ -1441,6 +1688,23 @@ public UnaryCallSettings.Builder getProcessorSet
return getProcessorSettings;
}
+ /** Returns the builder for the settings used for calls to trainProcessorVersion. */
+ public UnaryCallSettings.Builder
+ trainProcessorVersionSettings() {
+ return trainProcessorVersionSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to trainProcessorVersion. */
+ @BetaApi(
+ "The surface for use by generated code is not stable yet and may change in the future.")
+ public OperationCallSettings.Builder<
+ TrainProcessorVersionRequest,
+ TrainProcessorVersionResponse,
+ TrainProcessorVersionMetadata>
+ trainProcessorVersionOperationSettings() {
+ return trainProcessorVersionOperationSettings;
+ }
+
/** Returns the builder for the settings used for calls to getProcessorVersion. */
public UnaryCallSettings.Builder
getProcessorVersionSettings() {
@@ -1583,6 +1847,35 @@ public UnaryCallSettings.Builder reviewDocumen
return reviewDocumentOperationSettings;
}
+ /** Returns the builder for the settings used for calls to evaluateProcessorVersion. */
+ public UnaryCallSettings.Builder
+ evaluateProcessorVersionSettings() {
+ return evaluateProcessorVersionSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to evaluateProcessorVersion. */
+ @BetaApi(
+ "The surface for use by generated code is not stable yet and may change in the future.")
+ public OperationCallSettings.Builder<
+ EvaluateProcessorVersionRequest,
+ EvaluateProcessorVersionResponse,
+ EvaluateProcessorVersionMetadata>
+ evaluateProcessorVersionOperationSettings() {
+ return evaluateProcessorVersionOperationSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to getEvaluation. */
+ public UnaryCallSettings.Builder getEvaluationSettings() {
+ return getEvaluationSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to listEvaluations. */
+ public PagedCallSettings.Builder<
+ ListEvaluationsRequest, ListEvaluationsResponse, ListEvaluationsPagedResponse>
+ listEvaluationsSettings() {
+ return listEvaluationsSettings;
+ }
+
/** Returns the builder for the settings used for calls to listLocations. */
public PagedCallSettings.Builder<
ListLocationsRequest, ListLocationsResponse, ListLocationsPagedResponse>
diff --git a/java-document-ai/google-cloud-document-ai/src/main/java/com/google/cloud/documentai/v1/stub/GrpcDocumentProcessorServiceStub.java b/java-document-ai/google-cloud-document-ai/src/main/java/com/google/cloud/documentai/v1/stub/GrpcDocumentProcessorServiceStub.java
index 84b62a036f52..b123bb76061d 100644
--- a/java-document-ai/google-cloud-document-ai/src/main/java/com/google/cloud/documentai/v1/stub/GrpcDocumentProcessorServiceStub.java
+++ b/java-document-ai/google-cloud-document-ai/src/main/java/com/google/cloud/documentai/v1/stub/GrpcDocumentProcessorServiceStub.java
@@ -16,6 +16,7 @@
package com.google.cloud.documentai.v1.stub;
+import static com.google.cloud.documentai.v1.DocumentProcessorServiceClient.ListEvaluationsPagedResponse;
import static com.google.cloud.documentai.v1.DocumentProcessorServiceClient.ListLocationsPagedResponse;
import static com.google.cloud.documentai.v1.DocumentProcessorServiceClient.ListProcessorTypesPagedResponse;
import static com.google.cloud.documentai.v1.DocumentProcessorServiceClient.ListProcessorVersionsPagedResponse;
@@ -45,11 +46,18 @@
import com.google.cloud.documentai.v1.EnableProcessorMetadata;
import com.google.cloud.documentai.v1.EnableProcessorRequest;
import com.google.cloud.documentai.v1.EnableProcessorResponse;
+import com.google.cloud.documentai.v1.EvaluateProcessorVersionMetadata;
+import com.google.cloud.documentai.v1.EvaluateProcessorVersionRequest;
+import com.google.cloud.documentai.v1.EvaluateProcessorVersionResponse;
+import com.google.cloud.documentai.v1.Evaluation;
import com.google.cloud.documentai.v1.FetchProcessorTypesRequest;
import com.google.cloud.documentai.v1.FetchProcessorTypesResponse;
+import com.google.cloud.documentai.v1.GetEvaluationRequest;
import com.google.cloud.documentai.v1.GetProcessorRequest;
import com.google.cloud.documentai.v1.GetProcessorTypeRequest;
import com.google.cloud.documentai.v1.GetProcessorVersionRequest;
+import com.google.cloud.documentai.v1.ListEvaluationsRequest;
+import com.google.cloud.documentai.v1.ListEvaluationsResponse;
import com.google.cloud.documentai.v1.ListProcessorTypesRequest;
import com.google.cloud.documentai.v1.ListProcessorTypesResponse;
import com.google.cloud.documentai.v1.ListProcessorVersionsRequest;
@@ -67,6 +75,9 @@
import com.google.cloud.documentai.v1.SetDefaultProcessorVersionMetadata;
import com.google.cloud.documentai.v1.SetDefaultProcessorVersionRequest;
import com.google.cloud.documentai.v1.SetDefaultProcessorVersionResponse;
+import com.google.cloud.documentai.v1.TrainProcessorVersionMetadata;
+import com.google.cloud.documentai.v1.TrainProcessorVersionRequest;
+import com.google.cloud.documentai.v1.TrainProcessorVersionResponse;
import com.google.cloud.documentai.v1.UndeployProcessorVersionMetadata;
import com.google.cloud.documentai.v1.UndeployProcessorVersionRequest;
import com.google.cloud.documentai.v1.UndeployProcessorVersionResponse;
@@ -168,6 +179,17 @@ public class GrpcDocumentProcessorServiceStub extends DocumentProcessorServiceSt
.setResponseMarshaller(ProtoUtils.marshaller(Processor.getDefaultInstance()))
.build();
+ private static final MethodDescriptor
+ trainProcessorVersionMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(
+ "google.cloud.documentai.v1.DocumentProcessorService/TrainProcessorVersion")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(TrainProcessorVersionRequest.getDefaultInstance()))
+ .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance()))
+ .build();
+
private static final MethodDescriptor
getProcessorVersionMethodDescriptor =
MethodDescriptor.newBuilder()
@@ -290,6 +312,40 @@ public class GrpcDocumentProcessorServiceStub extends DocumentProcessorServiceSt
.setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance()))
.build();
+ private static final MethodDescriptor
+ evaluateProcessorVersionMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(
+ "google.cloud.documentai.v1.DocumentProcessorService/EvaluateProcessorVersion")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(EvaluateProcessorVersionRequest.getDefaultInstance()))
+ .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance()))
+ .build();
+
+ private static final MethodDescriptor
+ getEvaluationMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(
+ "google.cloud.documentai.v1.DocumentProcessorService/GetEvaluation")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(GetEvaluationRequest.getDefaultInstance()))
+ .setResponseMarshaller(ProtoUtils.marshaller(Evaluation.getDefaultInstance()))
+ .build();
+
+ private static final MethodDescriptor
+ listEvaluationsMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(
+ "google.cloud.documentai.v1.DocumentProcessorService/ListEvaluations")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(ListEvaluationsRequest.getDefaultInstance()))
+ .setResponseMarshaller(
+ ProtoUtils.marshaller(ListEvaluationsResponse.getDefaultInstance()))
+ .build();
+
private static final MethodDescriptor
listLocationsMethodDescriptor =
MethodDescriptor.newBuilder()
@@ -324,6 +380,13 @@ public class GrpcDocumentProcessorServiceStub extends DocumentProcessorServiceSt
private final UnaryCallable
listProcessorsPagedCallable;
private final UnaryCallable getProcessorCallable;
+ private final UnaryCallable
+ trainProcessorVersionCallable;
+ private final OperationCallable<
+ TrainProcessorVersionRequest,
+ TrainProcessorVersionResponse,
+ TrainProcessorVersionMetadata>
+ trainProcessorVersionOperationCallable;
private final UnaryCallable
getProcessorVersionCallable;
private final UnaryCallable
@@ -372,6 +435,18 @@ public class GrpcDocumentProcessorServiceStub extends DocumentProcessorServiceSt
private final OperationCallable<
ReviewDocumentRequest, ReviewDocumentResponse, ReviewDocumentOperationMetadata>
reviewDocumentOperationCallable;
+ private final UnaryCallable
+ evaluateProcessorVersionCallable;
+ private final OperationCallable<
+ EvaluateProcessorVersionRequest,
+ EvaluateProcessorVersionResponse,
+ EvaluateProcessorVersionMetadata>
+ evaluateProcessorVersionOperationCallable;
+ private final UnaryCallable getEvaluationCallable;
+ private final UnaryCallable
+ listEvaluationsCallable;
+ private final UnaryCallable
+ listEvaluationsPagedCallable;
private final UnaryCallable listLocationsCallable;
private final UnaryCallable
listLocationsPagedCallable;
@@ -495,6 +570,17 @@ protected GrpcDocumentProcessorServiceStub(
return params.build();
})
.build();
+ GrpcCallSettings
+ trainProcessorVersionTransportSettings =
+ GrpcCallSettings.newBuilder()
+ .setMethodDescriptor(trainProcessorVersionMethodDescriptor)
+ .setParamsExtractor(
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("parent", String.valueOf(request.getParent()));
+ return params.build();
+ })
+ .build();
GrpcCallSettings
getProcessorVersionTransportSettings =
GrpcCallSettings.newBuilder()
@@ -612,6 +698,39 @@ protected GrpcDocumentProcessorServiceStub(
return params.build();
})
.build();
+ GrpcCallSettings
+ evaluateProcessorVersionTransportSettings =
+ GrpcCallSettings.newBuilder()
+ .setMethodDescriptor(evaluateProcessorVersionMethodDescriptor)
+ .setParamsExtractor(
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put(
+ "processor_version", String.valueOf(request.getProcessorVersion()));
+ return params.build();
+ })
+ .build();
+ GrpcCallSettings getEvaluationTransportSettings =
+ GrpcCallSettings.newBuilder()
+ .setMethodDescriptor(getEvaluationMethodDescriptor)
+ .setParamsExtractor(
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("name", String.valueOf(request.getName()));
+ return params.build();
+ })
+ .build();
+ GrpcCallSettings
+ listEvaluationsTransportSettings =
+ GrpcCallSettings.newBuilder()
+ .setMethodDescriptor(listEvaluationsMethodDescriptor)
+ .setParamsExtractor(
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("parent", String.valueOf(request.getParent()));
+ return params.build();
+ })
+ .build();
GrpcCallSettings listLocationsTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(listLocationsMethodDescriptor)
@@ -674,6 +793,17 @@ protected GrpcDocumentProcessorServiceStub(
this.getProcessorCallable =
callableFactory.createUnaryCallable(
getProcessorTransportSettings, settings.getProcessorSettings(), clientContext);
+ this.trainProcessorVersionCallable =
+ callableFactory.createUnaryCallable(
+ trainProcessorVersionTransportSettings,
+ settings.trainProcessorVersionSettings(),
+ clientContext);
+ this.trainProcessorVersionOperationCallable =
+ callableFactory.createOperationCallable(
+ trainProcessorVersionTransportSettings,
+ settings.trainProcessorVersionOperationSettings(),
+ clientContext,
+ operationsStub);
this.getProcessorVersionCallable =
callableFactory.createUnaryCallable(
getProcessorVersionTransportSettings,
@@ -772,6 +902,26 @@ protected GrpcDocumentProcessorServiceStub(
settings.reviewDocumentOperationSettings(),
clientContext,
operationsStub);
+ this.evaluateProcessorVersionCallable =
+ callableFactory.createUnaryCallable(
+ evaluateProcessorVersionTransportSettings,
+ settings.evaluateProcessorVersionSettings(),
+ clientContext);
+ this.evaluateProcessorVersionOperationCallable =
+ callableFactory.createOperationCallable(
+ evaluateProcessorVersionTransportSettings,
+ settings.evaluateProcessorVersionOperationSettings(),
+ clientContext,
+ operationsStub);
+ this.getEvaluationCallable =
+ callableFactory.createUnaryCallable(
+ getEvaluationTransportSettings, settings.getEvaluationSettings(), clientContext);
+ this.listEvaluationsCallable =
+ callableFactory.createUnaryCallable(
+ listEvaluationsTransportSettings, settings.listEvaluationsSettings(), clientContext);
+ this.listEvaluationsPagedCallable =
+ callableFactory.createPagedCallable(
+ listEvaluationsTransportSettings, settings.listEvaluationsSettings(), clientContext);
this.listLocationsCallable =
callableFactory.createUnaryCallable(
listLocationsTransportSettings, settings.listLocationsSettings(), clientContext);
@@ -845,6 +995,20 @@ public UnaryCallable getProcessorCallable() {
return getProcessorCallable;
}
+ @Override
+ public UnaryCallable trainProcessorVersionCallable() {
+ return trainProcessorVersionCallable;
+ }
+
+ @Override
+ public OperationCallable<
+ TrainProcessorVersionRequest,
+ TrainProcessorVersionResponse,
+ TrainProcessorVersionMetadata>
+ trainProcessorVersionOperationCallable() {
+ return trainProcessorVersionOperationCallable;
+ }
+
@Override
public UnaryCallable getProcessorVersionCallable() {
return getProcessorVersionCallable;
@@ -968,6 +1132,37 @@ public UnaryCallable reviewDocumentCallable()
return reviewDocumentOperationCallable;
}
+ @Override
+ public UnaryCallable
+ evaluateProcessorVersionCallable() {
+ return evaluateProcessorVersionCallable;
+ }
+
+ @Override
+ public OperationCallable<
+ EvaluateProcessorVersionRequest,
+ EvaluateProcessorVersionResponse,
+ EvaluateProcessorVersionMetadata>
+ evaluateProcessorVersionOperationCallable() {
+ return evaluateProcessorVersionOperationCallable;
+ }
+
+ @Override
+ public UnaryCallable getEvaluationCallable() {
+ return getEvaluationCallable;
+ }
+
+ @Override
+ public UnaryCallable listEvaluationsCallable() {
+ return listEvaluationsCallable;
+ }
+
+ @Override
+ public UnaryCallable
+ listEvaluationsPagedCallable() {
+ return listEvaluationsPagedCallable;
+ }
+
@Override
public UnaryCallable listLocationsCallable() {
return listLocationsCallable;
diff --git a/java-document-ai/google-cloud-document-ai/src/main/java/com/google/cloud/documentai/v1/stub/HttpJsonDocumentProcessorServiceStub.java b/java-document-ai/google-cloud-document-ai/src/main/java/com/google/cloud/documentai/v1/stub/HttpJsonDocumentProcessorServiceStub.java
index 8064035cecaf..3286d44b32aa 100644
--- a/java-document-ai/google-cloud-document-ai/src/main/java/com/google/cloud/documentai/v1/stub/HttpJsonDocumentProcessorServiceStub.java
+++ b/java-document-ai/google-cloud-document-ai/src/main/java/com/google/cloud/documentai/v1/stub/HttpJsonDocumentProcessorServiceStub.java
@@ -16,6 +16,7 @@
package com.google.cloud.documentai.v1.stub;
+import static com.google.cloud.documentai.v1.DocumentProcessorServiceClient.ListEvaluationsPagedResponse;
import static com.google.cloud.documentai.v1.DocumentProcessorServiceClient.ListLocationsPagedResponse;
import static com.google.cloud.documentai.v1.DocumentProcessorServiceClient.ListProcessorTypesPagedResponse;
import static com.google.cloud.documentai.v1.DocumentProcessorServiceClient.ListProcessorVersionsPagedResponse;
@@ -53,11 +54,18 @@
import com.google.cloud.documentai.v1.EnableProcessorMetadata;
import com.google.cloud.documentai.v1.EnableProcessorRequest;
import com.google.cloud.documentai.v1.EnableProcessorResponse;
+import com.google.cloud.documentai.v1.EvaluateProcessorVersionMetadata;
+import com.google.cloud.documentai.v1.EvaluateProcessorVersionRequest;
+import com.google.cloud.documentai.v1.EvaluateProcessorVersionResponse;
+import com.google.cloud.documentai.v1.Evaluation;
import com.google.cloud.documentai.v1.FetchProcessorTypesRequest;
import com.google.cloud.documentai.v1.FetchProcessorTypesResponse;
+import com.google.cloud.documentai.v1.GetEvaluationRequest;
import com.google.cloud.documentai.v1.GetProcessorRequest;
import com.google.cloud.documentai.v1.GetProcessorTypeRequest;
import com.google.cloud.documentai.v1.GetProcessorVersionRequest;
+import com.google.cloud.documentai.v1.ListEvaluationsRequest;
+import com.google.cloud.documentai.v1.ListEvaluationsResponse;
import com.google.cloud.documentai.v1.ListProcessorTypesRequest;
import com.google.cloud.documentai.v1.ListProcessorTypesResponse;
import com.google.cloud.documentai.v1.ListProcessorVersionsRequest;
@@ -75,6 +83,9 @@
import com.google.cloud.documentai.v1.SetDefaultProcessorVersionMetadata;
import com.google.cloud.documentai.v1.SetDefaultProcessorVersionRequest;
import com.google.cloud.documentai.v1.SetDefaultProcessorVersionResponse;
+import com.google.cloud.documentai.v1.TrainProcessorVersionMetadata;
+import com.google.cloud.documentai.v1.TrainProcessorVersionRequest;
+import com.google.cloud.documentai.v1.TrainProcessorVersionResponse;
import com.google.cloud.documentai.v1.UndeployProcessorVersionMetadata;
import com.google.cloud.documentai.v1.UndeployProcessorVersionRequest;
import com.google.cloud.documentai.v1.UndeployProcessorVersionResponse;
@@ -107,6 +118,7 @@ public class HttpJsonDocumentProcessorServiceStub extends DocumentProcessorServi
.add(UndeployProcessorVersionResponse.getDescriptor())
.add(EnableProcessorResponse.getDescriptor())
.add(SetDefaultProcessorVersionMetadata.getDescriptor())
+ .add(EvaluateProcessorVersionResponse.getDescriptor())
.add(EnableProcessorMetadata.getDescriptor())
.add(ReviewDocumentOperationMetadata.getDescriptor())
.add(SetDefaultProcessorVersionResponse.getDescriptor())
@@ -117,10 +129,13 @@ public class HttpJsonDocumentProcessorServiceStub extends DocumentProcessorServi
.add(DeployProcessorVersionResponse.getDescriptor())
.add(DisableProcessorResponse.getDescriptor())
.add(BatchProcessResponse.getDescriptor())
+ .add(TrainProcessorVersionResponse.getDescriptor())
.add(ReviewDocumentResponse.getDescriptor())
+ .add(EvaluateProcessorVersionMetadata.getDescriptor())
.add(UndeployProcessorVersionMetadata.getDescriptor())
.add(DeployProcessorVersionMetadata.getDescriptor())
.add(DisableProcessorMetadata.getDescriptor())
+ .add(TrainProcessorVersionMetadata.getDescriptor())
.build();
private static final ApiMethodDescriptor
@@ -384,6 +399,47 @@ public class HttpJsonDocumentProcessorServiceStub extends DocumentProcessorServi
.build())
.build();
+ private static final ApiMethodDescriptor
+ trainProcessorVersionMethodDescriptor =
+ ApiMethodDescriptor.newBuilder()
+ .setFullMethodName(
+ "google.cloud.documentai.v1.DocumentProcessorService/TrainProcessorVersion")
+ .setHttpMethod("POST")
+ .setType(ApiMethodDescriptor.MethodType.UNARY)
+ .setRequestFormatter(
+ ProtoMessageRequestFormatter.newBuilder()
+ .setPath(
+ "/v1/{parent=projects/*/locations/*/processors/*}/processorVersions:train",
+ request -> {
+ Map fields = new HashMap<>();
+ ProtoRestSerializer serializer =
+ ProtoRestSerializer.create();
+ serializer.putPathParam(fields, "parent", request.getParent());
+ return fields;
+ })
+ .setQueryParamsExtractor(
+ request -> {
+ Map> fields = new HashMap<>();
+ ProtoRestSerializer serializer =
+ ProtoRestSerializer.create();
+ serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int");
+ return fields;
+ })
+ .setRequestBodyExtractor(
+ request ->
+ ProtoRestSerializer.create()
+ .toBody("*", request.toBuilder().clearParent().build(), true))
+ .build())
+ .setResponseParser(
+ ProtoMessageResponseParser.newBuilder()
+ .setDefaultInstance(Operation.getDefaultInstance())
+ .setDefaultTypeRegistry(typeRegistry)
+ .build())
+ .setOperationSnapshotFactory(
+ (TrainProcessorVersionRequest request, Operation response) ->
+ HttpJsonOperationSnapshot.create(response))
+ .build();
+
private static final ApiMethodDescriptor
getProcessorVersionMethodDescriptor =
ApiMethodDescriptor.newBuilder()
@@ -822,6 +878,123 @@ public class HttpJsonDocumentProcessorServiceStub extends DocumentProcessorServi
HttpJsonOperationSnapshot.create(response))
.build();
+ private static final ApiMethodDescriptor
+ evaluateProcessorVersionMethodDescriptor =
+ ApiMethodDescriptor.newBuilder()
+ .setFullMethodName(
+ "google.cloud.documentai.v1.DocumentProcessorService/EvaluateProcessorVersion")
+ .setHttpMethod("POST")
+ .setType(ApiMethodDescriptor.MethodType.UNARY)
+ .setRequestFormatter(
+ ProtoMessageRequestFormatter.newBuilder()
+ .setPath(
+ "/v1/{processorVersion=projects/*/locations/*/processors/*/processorVersions/*}:evaluateProcessorVersion",
+ request -> {
+ Map fields = new HashMap<>();
+ ProtoRestSerializer serializer =
+ ProtoRestSerializer.create();
+ serializer.putPathParam(
+ fields, "processorVersion", request.getProcessorVersion());
+ return fields;
+ })
+ .setQueryParamsExtractor(
+ request -> {
+ Map> fields = new HashMap<>();
+ ProtoRestSerializer serializer =
+ ProtoRestSerializer.create();
+ serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int");
+ return fields;
+ })
+ .setRequestBodyExtractor(
+ request ->
+ ProtoRestSerializer.create()
+ .toBody(
+ "*",
+ request.toBuilder().clearProcessorVersion().build(),
+ true))
+ .build())
+ .setResponseParser(
+ ProtoMessageResponseParser.newBuilder()
+ .setDefaultInstance(Operation.getDefaultInstance())
+ .setDefaultTypeRegistry(typeRegistry)
+ .build())
+ .setOperationSnapshotFactory(
+ (EvaluateProcessorVersionRequest request, Operation response) ->
+ HttpJsonOperationSnapshot.create(response))
+ .build();
+
+ private static final ApiMethodDescriptor
+ getEvaluationMethodDescriptor =
+ ApiMethodDescriptor.newBuilder()
+ .setFullMethodName(
+ "google.cloud.documentai.v1.DocumentProcessorService/GetEvaluation")
+ .setHttpMethod("GET")
+ .setType(ApiMethodDescriptor.MethodType.UNARY)
+ .setRequestFormatter(
+ ProtoMessageRequestFormatter.newBuilder()
+ .setPath(
+ "/v1/{name=projects/*/locations/*/processors/*/processorVersions/*/evaluations/*}",
+ request -> {
+ Map fields = new HashMap<>();
+ ProtoRestSerializer serializer =
+ ProtoRestSerializer.create();
+ serializer.putPathParam(fields, "name", request.getName());
+ return fields;
+ })
+ .setQueryParamsExtractor(
+ request -> {
+ Map> fields = new HashMap<>();
+ ProtoRestSerializer serializer =
+ ProtoRestSerializer.create();
+ serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int");
+ return fields;
+ })
+ .setRequestBodyExtractor(request -> null)
+ .build())
+ .setResponseParser(
+ ProtoMessageResponseParser.newBuilder()
+ .setDefaultInstance(Evaluation.getDefaultInstance())
+ .setDefaultTypeRegistry(typeRegistry)
+ .build())
+ .build();
+
+ private static final ApiMethodDescriptor
+ listEvaluationsMethodDescriptor =
+ ApiMethodDescriptor.newBuilder()
+ .setFullMethodName(
+ "google.cloud.documentai.v1.DocumentProcessorService/ListEvaluations")
+ .setHttpMethod("GET")
+ .setType(ApiMethodDescriptor.MethodType.UNARY)
+ .setRequestFormatter(
+ ProtoMessageRequestFormatter.newBuilder()
+ .setPath(
+ "/v1/{parent=projects/*/locations/*/processors/*/processorVersions/*}/evaluations",
+ request -> {
+ Map fields = new HashMap<>();
+ ProtoRestSerializer serializer =
+ ProtoRestSerializer.create();
+ serializer.putPathParam(fields, "parent", request.getParent());
+ return fields;
+ })
+ .setQueryParamsExtractor(
+ request -> {
+ Map> fields = new HashMap<>();
+ ProtoRestSerializer serializer =
+ ProtoRestSerializer.create();
+ serializer.putQueryParam(fields, "pageSize", request.getPageSize());
+ serializer.putQueryParam(fields, "pageToken", request.getPageToken());
+ serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int");
+ return fields;
+ })
+ .setRequestBodyExtractor(request -> null)
+ .build())
+ .setResponseParser(
+ ProtoMessageResponseParser.newBuilder()
+ .setDefaultInstance(ListEvaluationsResponse.getDefaultInstance())
+ .setDefaultTypeRegistry(typeRegistry)
+ .build())
+ .build();
+
private static final ApiMethodDescriptor
listLocationsMethodDescriptor =
ApiMethodDescriptor.newBuilder()
@@ -907,6 +1080,13 @@ public class HttpJsonDocumentProcessorServiceStub extends DocumentProcessorServi
private final UnaryCallable
listProcessorsPagedCallable;
private final UnaryCallable getProcessorCallable;
+ private final UnaryCallable
+ trainProcessorVersionCallable;
+ private final OperationCallable<
+ TrainProcessorVersionRequest,
+ TrainProcessorVersionResponse,
+ TrainProcessorVersionMetadata>
+ trainProcessorVersionOperationCallable;
private final UnaryCallable
getProcessorVersionCallable;
private final UnaryCallable
@@ -955,6 +1135,18 @@ public class HttpJsonDocumentProcessorServiceStub extends DocumentProcessorServi
private final OperationCallable<
ReviewDocumentRequest, ReviewDocumentResponse, ReviewDocumentOperationMetadata>
reviewDocumentOperationCallable;
+ private final UnaryCallable
+ evaluateProcessorVersionCallable;
+ private final OperationCallable<
+ EvaluateProcessorVersionRequest,
+ EvaluateProcessorVersionResponse,
+ EvaluateProcessorVersionMetadata>
+ evaluateProcessorVersionOperationCallable;
+ private final UnaryCallable getEvaluationCallable;
+ private final UnaryCallable
+ listEvaluationsCallable;
+ private final UnaryCallable
+ listEvaluationsPagedCallable;
private final UnaryCallable listLocationsCallable;
private final UnaryCallable
listLocationsPagedCallable;
@@ -1047,6 +1239,12 @@ protected HttpJsonDocumentProcessorServiceStub(
.setMethodDescriptor(getProcessorMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
+ HttpJsonCallSettings
+ trainProcessorVersionTransportSettings =
+ HttpJsonCallSettings.newBuilder()
+ .setMethodDescriptor(trainProcessorVersionMethodDescriptor)
+ .setTypeRegistry(typeRegistry)
+ .build();
HttpJsonCallSettings
getProcessorVersionTransportSettings =
HttpJsonCallSettings.newBuilder()
@@ -1109,6 +1307,23 @@ protected HttpJsonDocumentProcessorServiceStub(
.setMethodDescriptor(reviewDocumentMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
+ HttpJsonCallSettings
+ evaluateProcessorVersionTransportSettings =
+ HttpJsonCallSettings.newBuilder()
+ .setMethodDescriptor(evaluateProcessorVersionMethodDescriptor)
+ .setTypeRegistry(typeRegistry)
+ .build();
+ HttpJsonCallSettings getEvaluationTransportSettings =
+ HttpJsonCallSettings.newBuilder()
+ .setMethodDescriptor(getEvaluationMethodDescriptor)
+ .setTypeRegistry(typeRegistry)
+ .build();
+ HttpJsonCallSettings
+ listEvaluationsTransportSettings =
+ HttpJsonCallSettings.newBuilder()
+ .setMethodDescriptor(listEvaluationsMethodDescriptor)
+ .setTypeRegistry(typeRegistry)
+ .build();
HttpJsonCallSettings
listLocationsTransportSettings =
HttpJsonCallSettings.newBuilder()
@@ -1162,6 +1377,17 @@ protected HttpJsonDocumentProcessorServiceStub(
this.getProcessorCallable =
callableFactory.createUnaryCallable(
getProcessorTransportSettings, settings.getProcessorSettings(), clientContext);
+ this.trainProcessorVersionCallable =
+ callableFactory.createUnaryCallable(
+ trainProcessorVersionTransportSettings,
+ settings.trainProcessorVersionSettings(),
+ clientContext);
+ this.trainProcessorVersionOperationCallable =
+ callableFactory.createOperationCallable(
+ trainProcessorVersionTransportSettings,
+ settings.trainProcessorVersionOperationSettings(),
+ clientContext,
+ httpJsonOperationsStub);
this.getProcessorVersionCallable =
callableFactory.createUnaryCallable(
getProcessorVersionTransportSettings,
@@ -1260,6 +1486,26 @@ protected HttpJsonDocumentProcessorServiceStub(
settings.reviewDocumentOperationSettings(),
clientContext,
httpJsonOperationsStub);
+ this.evaluateProcessorVersionCallable =
+ callableFactory.createUnaryCallable(
+ evaluateProcessorVersionTransportSettings,
+ settings.evaluateProcessorVersionSettings(),
+ clientContext);
+ this.evaluateProcessorVersionOperationCallable =
+ callableFactory.createOperationCallable(
+ evaluateProcessorVersionTransportSettings,
+ settings.evaluateProcessorVersionOperationSettings(),
+ clientContext,
+ httpJsonOperationsStub);
+ this.getEvaluationCallable =
+ callableFactory.createUnaryCallable(
+ getEvaluationTransportSettings, settings.getEvaluationSettings(), clientContext);
+ this.listEvaluationsCallable =
+ callableFactory.createUnaryCallable(
+ listEvaluationsTransportSettings, settings.listEvaluationsSettings(), clientContext);
+ this.listEvaluationsPagedCallable =
+ callableFactory.createPagedCallable(
+ listEvaluationsTransportSettings, settings.listEvaluationsSettings(), clientContext);
this.listLocationsCallable =
callableFactory.createUnaryCallable(
listLocationsTransportSettings, settings.listLocationsSettings(), clientContext);
@@ -1284,6 +1530,7 @@ public static List getMethodDescriptors() {
methodDescriptors.add(getProcessorTypeMethodDescriptor);
methodDescriptors.add(listProcessorsMethodDescriptor);
methodDescriptors.add(getProcessorMethodDescriptor);
+ methodDescriptors.add(trainProcessorVersionMethodDescriptor);
methodDescriptors.add(getProcessorVersionMethodDescriptor);
methodDescriptors.add(listProcessorVersionsMethodDescriptor);
methodDescriptors.add(deleteProcessorVersionMethodDescriptor);
@@ -1295,6 +1542,9 @@ public static List getMethodDescriptors() {
methodDescriptors.add(disableProcessorMethodDescriptor);
methodDescriptors.add(setDefaultProcessorVersionMethodDescriptor);
methodDescriptors.add(reviewDocumentMethodDescriptor);
+ methodDescriptors.add(evaluateProcessorVersionMethodDescriptor);
+ methodDescriptors.add(getEvaluationMethodDescriptor);
+ methodDescriptors.add(listEvaluationsMethodDescriptor);
methodDescriptors.add(listLocationsMethodDescriptor);
methodDescriptors.add(getLocationMethodDescriptor);
return methodDescriptors;
@@ -1359,6 +1609,20 @@ public UnaryCallable getProcessorCallable() {
return getProcessorCallable;
}
+ @Override
+ public UnaryCallable trainProcessorVersionCallable() {
+ return trainProcessorVersionCallable;
+ }
+
+ @Override
+ public OperationCallable<
+ TrainProcessorVersionRequest,
+ TrainProcessorVersionResponse,
+ TrainProcessorVersionMetadata>
+ trainProcessorVersionOperationCallable() {
+ return trainProcessorVersionOperationCallable;
+ }
+
@Override
public UnaryCallable getProcessorVersionCallable() {
return getProcessorVersionCallable;
@@ -1482,6 +1746,37 @@ public UnaryCallable reviewDocumentCallable()
return reviewDocumentOperationCallable;
}
+ @Override
+ public UnaryCallable
+ evaluateProcessorVersionCallable() {
+ return evaluateProcessorVersionCallable;
+ }
+
+ @Override
+ public OperationCallable<
+ EvaluateProcessorVersionRequest,
+ EvaluateProcessorVersionResponse,
+ EvaluateProcessorVersionMetadata>
+ evaluateProcessorVersionOperationCallable() {
+ return evaluateProcessorVersionOperationCallable;
+ }
+
+ @Override
+ public UnaryCallable getEvaluationCallable() {
+ return getEvaluationCallable;
+ }
+
+ @Override
+ public UnaryCallable listEvaluationsCallable() {
+ return listEvaluationsCallable;
+ }
+
+ @Override
+ public UnaryCallable
+ listEvaluationsPagedCallable() {
+ return listEvaluationsPagedCallable;
+ }
+
@Override
public UnaryCallable listLocationsCallable() {
return listLocationsCallable;
diff --git a/java-document-ai/google-cloud-document-ai/src/test/java/com/google/cloud/documentai/v1/DocumentProcessorServiceClientHttpJsonTest.java b/java-document-ai/google-cloud-document-ai/src/test/java/com/google/cloud/documentai/v1/DocumentProcessorServiceClientHttpJsonTest.java
index 1ff939b15982..4c75615c3afc 100644
--- a/java-document-ai/google-cloud-document-ai/src/test/java/com/google/cloud/documentai/v1/DocumentProcessorServiceClientHttpJsonTest.java
+++ b/java-document-ai/google-cloud-document-ai/src/test/java/com/google/cloud/documentai/v1/DocumentProcessorServiceClientHttpJsonTest.java
@@ -16,6 +16,7 @@
package com.google.cloud.documentai.v1;
+import static com.google.cloud.documentai.v1.DocumentProcessorServiceClient.ListEvaluationsPagedResponse;
import static com.google.cloud.documentai.v1.DocumentProcessorServiceClient.ListLocationsPagedResponse;
import static com.google.cloud.documentai.v1.DocumentProcessorServiceClient.ListProcessorTypesPagedResponse;
import static com.google.cloud.documentai.v1.DocumentProcessorServiceClient.ListProcessorVersionsPagedResponse;
@@ -768,6 +769,110 @@ public void getProcessorExceptionTest2() throws Exception {
}
}
+ @Test
+ public void trainProcessorVersionTest() throws Exception {
+ TrainProcessorVersionResponse expectedResponse =
+ TrainProcessorVersionResponse.newBuilder()
+ .setProcessorVersion("processorVersion-1941143578")
+ .build();
+ Operation resultOperation =
+ Operation.newBuilder()
+ .setName("trainProcessorVersionTest")
+ .setDone(true)
+ .setResponse(Any.pack(expectedResponse))
+ .build();
+ mockService.addResponse(resultOperation);
+
+ ProcessorName parent = ProcessorName.of("[PROJECT]", "[LOCATION]", "[PROCESSOR]");
+ ProcessorVersion processorVersion = ProcessorVersion.newBuilder().build();
+
+ TrainProcessorVersionResponse actualResponse =
+ client.trainProcessorVersionAsync(parent, processorVersion).get();
+ Assert.assertEquals(expectedResponse, actualResponse);
+
+ List actualRequests = mockService.getRequestPaths();
+ Assert.assertEquals(1, actualRequests.size());
+
+ String apiClientHeaderKey =
+ mockService
+ .getRequestHeaders()
+ .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey())
+ .iterator()
+ .next();
+ Assert.assertTrue(
+ GaxHttpJsonProperties.getDefaultApiClientHeaderPattern()
+ .matcher(apiClientHeaderKey)
+ .matches());
+ }
+
+ @Test
+ public void trainProcessorVersionExceptionTest() throws Exception {
+ ApiException exception =
+ ApiExceptionFactory.createException(
+ new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false);
+ mockService.addException(exception);
+
+ try {
+ ProcessorName parent = ProcessorName.of("[PROJECT]", "[LOCATION]", "[PROCESSOR]");
+ ProcessorVersion processorVersion = ProcessorVersion.newBuilder().build();
+ client.trainProcessorVersionAsync(parent, processorVersion).get();
+ Assert.fail("No exception raised");
+ } catch (ExecutionException e) {
+ }
+ }
+
+ @Test
+ public void trainProcessorVersionTest2() throws Exception {
+ TrainProcessorVersionResponse expectedResponse =
+ TrainProcessorVersionResponse.newBuilder()
+ .setProcessorVersion("processorVersion-1941143578")
+ .build();
+ Operation resultOperation =
+ Operation.newBuilder()
+ .setName("trainProcessorVersionTest")
+ .setDone(true)
+ .setResponse(Any.pack(expectedResponse))
+ .build();
+ mockService.addResponse(resultOperation);
+
+ String parent = "projects/project-3198/locations/location-3198/processors/processor-3198";
+ ProcessorVersion processorVersion = ProcessorVersion.newBuilder().build();
+
+ TrainProcessorVersionResponse actualResponse =
+ client.trainProcessorVersionAsync(parent, processorVersion).get();
+ Assert.assertEquals(expectedResponse, actualResponse);
+
+ List actualRequests = mockService.getRequestPaths();
+ Assert.assertEquals(1, actualRequests.size());
+
+ String apiClientHeaderKey =
+ mockService
+ .getRequestHeaders()
+ .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey())
+ .iterator()
+ .next();
+ Assert.assertTrue(
+ GaxHttpJsonProperties.getDefaultApiClientHeaderPattern()
+ .matcher(apiClientHeaderKey)
+ .matches());
+ }
+
+ @Test
+ public void trainProcessorVersionExceptionTest2() throws Exception {
+ ApiException exception =
+ ApiExceptionFactory.createException(
+ new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false);
+ mockService.addException(exception);
+
+ try {
+ String parent = "projects/project-3198/locations/location-3198/processors/processor-3198";
+ ProcessorVersion processorVersion = ProcessorVersion.newBuilder().build();
+ client.trainProcessorVersionAsync(parent, processorVersion).get();
+ Assert.fail("No exception raised");
+ } catch (ExecutionException e) {
+ }
+ }
+
@Test
public void getProcessorVersionTest() throws Exception {
ProcessorVersion expectedResponse =
@@ -779,6 +884,7 @@ public void getProcessorVersionTest() throws Exception {
.setDisplayName("displayName1714148973")
.setDocumentSchema(DocumentSchema.newBuilder().build())
.setCreateTime(Timestamp.newBuilder().build())
+ .setLatestEvaluation(EvaluationReference.newBuilder().build())
.setKmsKeyName("kmsKeyName412586233")
.setKmsKeyVersionName("kmsKeyVersionName-1798811307")
.setGoogleManaged(true)
@@ -835,6 +941,7 @@ public void getProcessorVersionTest2() throws Exception {
.setDisplayName("displayName1714148973")
.setDocumentSchema(DocumentSchema.newBuilder().build())
.setCreateTime(Timestamp.newBuilder().build())
+ .setLatestEvaluation(EvaluationReference.newBuilder().build())
.setKmsKeyName("kmsKeyName412586233")
.setKmsKeyVersionName("kmsKeyVersionName-1798811307")
.setGoogleManaged(true)
@@ -1742,6 +1849,330 @@ public void reviewDocumentExceptionTest2() throws Exception {
}
}
+ @Test
+ public void evaluateProcessorVersionTest() throws Exception {
+ EvaluateProcessorVersionResponse expectedResponse =
+ EvaluateProcessorVersionResponse.newBuilder().setEvaluation("evaluation858523452").build();
+ Operation resultOperation =
+ Operation.newBuilder()
+ .setName("evaluateProcessorVersionTest")
+ .setDone(true)
+ .setResponse(Any.pack(expectedResponse))
+ .build();
+ mockService.addResponse(resultOperation);
+
+ ProcessorVersionName processorVersion =
+ ProcessorVersionName.of("[PROJECT]", "[LOCATION]", "[PROCESSOR]", "[PROCESSOR_VERSION]");
+
+ EvaluateProcessorVersionResponse actualResponse =
+ client.evaluateProcessorVersionAsync(processorVersion).get();
+ Assert.assertEquals(expectedResponse, actualResponse);
+
+ List actualRequests = mockService.getRequestPaths();
+ Assert.assertEquals(1, actualRequests.size());
+
+ String apiClientHeaderKey =
+ mockService
+ .getRequestHeaders()
+ .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey())
+ .iterator()
+ .next();
+ Assert.assertTrue(
+ GaxHttpJsonProperties.getDefaultApiClientHeaderPattern()
+ .matcher(apiClientHeaderKey)
+ .matches());
+ }
+
+ @Test
+ public void evaluateProcessorVersionExceptionTest() throws Exception {
+ ApiException exception =
+ ApiExceptionFactory.createException(
+ new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false);
+ mockService.addException(exception);
+
+ try {
+ ProcessorVersionName processorVersion =
+ ProcessorVersionName.of("[PROJECT]", "[LOCATION]", "[PROCESSOR]", "[PROCESSOR_VERSION]");
+ client.evaluateProcessorVersionAsync(processorVersion).get();
+ Assert.fail("No exception raised");
+ } catch (ExecutionException e) {
+ }
+ }
+
+ @Test
+ public void evaluateProcessorVersionTest2() throws Exception {
+ EvaluateProcessorVersionResponse expectedResponse =
+ EvaluateProcessorVersionResponse.newBuilder().setEvaluation("evaluation858523452").build();
+ Operation resultOperation =
+ Operation.newBuilder()
+ .setName("evaluateProcessorVersionTest")
+ .setDone(true)
+ .setResponse(Any.pack(expectedResponse))
+ .build();
+ mockService.addResponse(resultOperation);
+
+ String processorVersion =
+ "projects/project-7729/locations/location-7729/processors/processor-7729/processorVersions/processorVersion-7729";
+
+ EvaluateProcessorVersionResponse actualResponse =
+ client.evaluateProcessorVersionAsync(processorVersion).get();
+ Assert.assertEquals(expectedResponse, actualResponse);
+
+ List actualRequests = mockService.getRequestPaths();
+ Assert.assertEquals(1, actualRequests.size());
+
+ String apiClientHeaderKey =
+ mockService
+ .getRequestHeaders()
+ .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey())
+ .iterator()
+ .next();
+ Assert.assertTrue(
+ GaxHttpJsonProperties.getDefaultApiClientHeaderPattern()
+ .matcher(apiClientHeaderKey)
+ .matches());
+ }
+
+ @Test
+ public void evaluateProcessorVersionExceptionTest2() throws Exception {
+ ApiException exception =
+ ApiExceptionFactory.createException(
+ new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false);
+ mockService.addException(exception);
+
+ try {
+ String processorVersion =
+ "projects/project-7729/locations/location-7729/processors/processor-7729/processorVersions/processorVersion-7729";
+ client.evaluateProcessorVersionAsync(processorVersion).get();
+ Assert.fail("No exception raised");
+ } catch (ExecutionException e) {
+ }
+ }
+
+ @Test
+ public void getEvaluationTest() throws Exception {
+ Evaluation expectedResponse =
+ Evaluation.newBuilder()
+ .setName(
+ EvaluationName.of(
+ "[PROJECT]",
+ "[LOCATION]",
+ "[PROCESSOR]",
+ "[PROCESSOR_VERSION]",
+ "[EVALUATION]")
+ .toString())
+ .setCreateTime(Timestamp.newBuilder().build())
+ .setDocumentCounters(Evaluation.Counters.newBuilder().build())
+ .setAllEntitiesMetrics(Evaluation.MultiConfidenceMetrics.newBuilder().build())
+ .putAllEntityMetrics(new HashMap())
+ .setKmsKeyName("kmsKeyName412586233")
+ .setKmsKeyVersionName("kmsKeyVersionName-1798811307")
+ .build();
+ mockService.addResponse(expectedResponse);
+
+ EvaluationName name =
+ EvaluationName.of(
+ "[PROJECT]", "[LOCATION]", "[PROCESSOR]", "[PROCESSOR_VERSION]", "[EVALUATION]");
+
+ Evaluation actualResponse = client.getEvaluation(name);
+ Assert.assertEquals(expectedResponse, actualResponse);
+
+ List actualRequests = mockService.getRequestPaths();
+ Assert.assertEquals(1, actualRequests.size());
+
+ String apiClientHeaderKey =
+ mockService
+ .getRequestHeaders()
+ .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey())
+ .iterator()
+ .next();
+ Assert.assertTrue(
+ GaxHttpJsonProperties.getDefaultApiClientHeaderPattern()
+ .matcher(apiClientHeaderKey)
+ .matches());
+ }
+
+ @Test
+ public void getEvaluationExceptionTest() throws Exception {
+ ApiException exception =
+ ApiExceptionFactory.createException(
+ new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false);
+ mockService.addException(exception);
+
+ try {
+ EvaluationName name =
+ EvaluationName.of(
+ "[PROJECT]", "[LOCATION]", "[PROCESSOR]", "[PROCESSOR_VERSION]", "[EVALUATION]");
+ client.getEvaluation(name);
+ Assert.fail("No exception raised");
+ } catch (InvalidArgumentException e) {
+ // Expected exception.
+ }
+ }
+
+ @Test
+ public void getEvaluationTest2() throws Exception {
+ Evaluation expectedResponse =
+ Evaluation.newBuilder()
+ .setName(
+ EvaluationName.of(
+ "[PROJECT]",
+ "[LOCATION]",
+ "[PROCESSOR]",
+ "[PROCESSOR_VERSION]",
+ "[EVALUATION]")
+ .toString())
+ .setCreateTime(Timestamp.newBuilder().build())
+ .setDocumentCounters(Evaluation.Counters.newBuilder().build())
+ .setAllEntitiesMetrics(Evaluation.MultiConfidenceMetrics.newBuilder().build())
+ .putAllEntityMetrics(new HashMap())
+ .setKmsKeyName("kmsKeyName412586233")
+ .setKmsKeyVersionName("kmsKeyVersionName-1798811307")
+ .build();
+ mockService.addResponse(expectedResponse);
+
+ String name =
+ "projects/project-6701/locations/location-6701/processors/processor-6701/processorVersions/processorVersion-6701/evaluations/evaluation-6701";
+
+ Evaluation actualResponse = client.getEvaluation(name);
+ Assert.assertEquals(expectedResponse, actualResponse);
+
+ List actualRequests = mockService.getRequestPaths();
+ Assert.assertEquals(1, actualRequests.size());
+
+ String apiClientHeaderKey =
+ mockService
+ .getRequestHeaders()
+ .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey())
+ .iterator()
+ .next();
+ Assert.assertTrue(
+ GaxHttpJsonProperties.getDefaultApiClientHeaderPattern()
+ .matcher(apiClientHeaderKey)
+ .matches());
+ }
+
+ @Test
+ public void getEvaluationExceptionTest2() throws Exception {
+ ApiException exception =
+ ApiExceptionFactory.createException(
+ new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false);
+ mockService.addException(exception);
+
+ try {
+ String name =
+ "projects/project-6701/locations/location-6701/processors/processor-6701/processorVersions/processorVersion-6701/evaluations/evaluation-6701";
+ client.getEvaluation(name);
+ Assert.fail("No exception raised");
+ } catch (InvalidArgumentException e) {
+ // Expected exception.
+ }
+ }
+
+ @Test
+ public void listEvaluationsTest() throws Exception {
+ Evaluation responsesElement = Evaluation.newBuilder().build();
+ ListEvaluationsResponse expectedResponse =
+ ListEvaluationsResponse.newBuilder()
+ .setNextPageToken("")
+ .addAllEvaluations(Arrays.asList(responsesElement))
+ .build();
+ mockService.addResponse(expectedResponse);
+
+ ProcessorVersionName parent =
+ ProcessorVersionName.of("[PROJECT]", "[LOCATION]", "[PROCESSOR]", "[PROCESSOR_VERSION]");
+
+ ListEvaluationsPagedResponse pagedListResponse = client.listEvaluations(parent);
+
+ List resources = Lists.newArrayList(pagedListResponse.iterateAll());
+
+ Assert.assertEquals(1, resources.size());
+ Assert.assertEquals(expectedResponse.getEvaluationsList().get(0), resources.get(0));
+
+ List actualRequests = mockService.getRequestPaths();
+ Assert.assertEquals(1, actualRequests.size());
+
+ String apiClientHeaderKey =
+ mockService
+ .getRequestHeaders()
+ .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey())
+ .iterator()
+ .next();
+ Assert.assertTrue(
+ GaxHttpJsonProperties.getDefaultApiClientHeaderPattern()
+ .matcher(apiClientHeaderKey)
+ .matches());
+ }
+
+ @Test
+ public void listEvaluationsExceptionTest() throws Exception {
+ ApiException exception =
+ ApiExceptionFactory.createException(
+ new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false);
+ mockService.addException(exception);
+
+ try {
+ ProcessorVersionName parent =
+ ProcessorVersionName.of("[PROJECT]", "[LOCATION]", "[PROCESSOR]", "[PROCESSOR_VERSION]");
+ client.listEvaluations(parent);
+ Assert.fail("No exception raised");
+ } catch (InvalidArgumentException e) {
+ // Expected exception.
+ }
+ }
+
+ @Test
+ public void listEvaluationsTest2() throws Exception {
+ Evaluation responsesElement = Evaluation.newBuilder().build();
+ ListEvaluationsResponse expectedResponse =
+ ListEvaluationsResponse.newBuilder()
+ .setNextPageToken("")
+ .addAllEvaluations(Arrays.asList(responsesElement))
+ .build();
+ mockService.addResponse(expectedResponse);
+
+ String parent =
+ "projects/project-1781/locations/location-1781/processors/processor-1781/processorVersions/processorVersion-1781";
+
+ ListEvaluationsPagedResponse pagedListResponse = client.listEvaluations(parent);
+
+ List resources = Lists.newArrayList(pagedListResponse.iterateAll());
+
+ Assert.assertEquals(1, resources.size());
+ Assert.assertEquals(expectedResponse.getEvaluationsList().get(0), resources.get(0));
+
+ List actualRequests = mockService.getRequestPaths();
+ Assert.assertEquals(1, actualRequests.size());
+
+ String apiClientHeaderKey =
+ mockService
+ .getRequestHeaders()
+ .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey())
+ .iterator()
+ .next();
+ Assert.assertTrue(
+ GaxHttpJsonProperties.getDefaultApiClientHeaderPattern()
+ .matcher(apiClientHeaderKey)
+ .matches());
+ }
+
+ @Test
+ public void listEvaluationsExceptionTest2() throws Exception {
+ ApiException exception =
+ ApiExceptionFactory.createException(
+ new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false);
+ mockService.addException(exception);
+
+ try {
+ String parent =
+ "projects/project-1781/locations/location-1781/processors/processor-1781/processorVersions/processorVersion-1781";
+ client.listEvaluations(parent);
+ Assert.fail("No exception raised");
+ } catch (InvalidArgumentException e) {
+ // Expected exception.
+ }
+ }
+
@Test
public void listLocationsTest() throws Exception {
Location responsesElement = Location.newBuilder().build();
diff --git a/java-document-ai/google-cloud-document-ai/src/test/java/com/google/cloud/documentai/v1/DocumentProcessorServiceClientTest.java b/java-document-ai/google-cloud-document-ai/src/test/java/com/google/cloud/documentai/v1/DocumentProcessorServiceClientTest.java
index 852a81eec9c8..46ddc51c46fd 100644
--- a/java-document-ai/google-cloud-document-ai/src/test/java/com/google/cloud/documentai/v1/DocumentProcessorServiceClientTest.java
+++ b/java-document-ai/google-cloud-document-ai/src/test/java/com/google/cloud/documentai/v1/DocumentProcessorServiceClientTest.java
@@ -16,6 +16,7 @@
package com.google.cloud.documentai.v1;
+import static com.google.cloud.documentai.v1.DocumentProcessorServiceClient.ListEvaluationsPagedResponse;
import static com.google.cloud.documentai.v1.DocumentProcessorServiceClient.ListLocationsPagedResponse;
import static com.google.cloud.documentai.v1.DocumentProcessorServiceClient.ListProcessorTypesPagedResponse;
import static com.google.cloud.documentai.v1.DocumentProcessorServiceClient.ListProcessorVersionsPagedResponse;
@@ -696,6 +697,108 @@ public void getProcessorExceptionTest2() throws Exception {
}
}
+ @Test
+ public void trainProcessorVersionTest() throws Exception {
+ TrainProcessorVersionResponse expectedResponse =
+ TrainProcessorVersionResponse.newBuilder()
+ .setProcessorVersion("processorVersion-1941143578")
+ .build();
+ Operation resultOperation =
+ Operation.newBuilder()
+ .setName("trainProcessorVersionTest")
+ .setDone(true)
+ .setResponse(Any.pack(expectedResponse))
+ .build();
+ mockDocumentProcessorService.addResponse(resultOperation);
+
+ ProcessorName parent = ProcessorName.of("[PROJECT]", "[LOCATION]", "[PROCESSOR]");
+ ProcessorVersion processorVersion = ProcessorVersion.newBuilder().build();
+
+ TrainProcessorVersionResponse actualResponse =
+ client.trainProcessorVersionAsync(parent, processorVersion).get();
+ Assert.assertEquals(expectedResponse, actualResponse);
+
+ List actualRequests = mockDocumentProcessorService.getRequests();
+ Assert.assertEquals(1, actualRequests.size());
+ TrainProcessorVersionRequest actualRequest =
+ ((TrainProcessorVersionRequest) actualRequests.get(0));
+
+ Assert.assertEquals(parent.toString(), actualRequest.getParent());
+ Assert.assertEquals(processorVersion, actualRequest.getProcessorVersion());
+ Assert.assertTrue(
+ channelProvider.isHeaderSent(
+ ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
+ GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
+ }
+
+ @Test
+ public void trainProcessorVersionExceptionTest() throws Exception {
+ StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
+ mockDocumentProcessorService.addException(exception);
+
+ try {
+ ProcessorName parent = ProcessorName.of("[PROJECT]", "[LOCATION]", "[PROCESSOR]");
+ ProcessorVersion processorVersion = ProcessorVersion.newBuilder().build();
+ client.trainProcessorVersionAsync(parent, processorVersion).get();
+ Assert.fail("No exception raised");
+ } catch (ExecutionException e) {
+ Assert.assertEquals(InvalidArgumentException.class, e.getCause().getClass());
+ InvalidArgumentException apiException = ((InvalidArgumentException) e.getCause());
+ Assert.assertEquals(StatusCode.Code.INVALID_ARGUMENT, apiException.getStatusCode().getCode());
+ }
+ }
+
+ @Test
+ public void trainProcessorVersionTest2() throws Exception {
+ TrainProcessorVersionResponse expectedResponse =
+ TrainProcessorVersionResponse.newBuilder()
+ .setProcessorVersion("processorVersion-1941143578")
+ .build();
+ Operation resultOperation =
+ Operation.newBuilder()
+ .setName("trainProcessorVersionTest")
+ .setDone(true)
+ .setResponse(Any.pack(expectedResponse))
+ .build();
+ mockDocumentProcessorService.addResponse(resultOperation);
+
+ String parent = "parent-995424086";
+ ProcessorVersion processorVersion = ProcessorVersion.newBuilder().build();
+
+ TrainProcessorVersionResponse actualResponse =
+ client.trainProcessorVersionAsync(parent, processorVersion).get();
+ Assert.assertEquals(expectedResponse, actualResponse);
+
+ List actualRequests = mockDocumentProcessorService.getRequests();
+ Assert.assertEquals(1, actualRequests.size());
+ TrainProcessorVersionRequest actualRequest =
+ ((TrainProcessorVersionRequest) actualRequests.get(0));
+
+ Assert.assertEquals(parent, actualRequest.getParent());
+ Assert.assertEquals(processorVersion, actualRequest.getProcessorVersion());
+ Assert.assertTrue(
+ channelProvider.isHeaderSent(
+ ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
+ GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
+ }
+
+ @Test
+ public void trainProcessorVersionExceptionTest2() throws Exception {
+ StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
+ mockDocumentProcessorService.addException(exception);
+
+ try {
+ String parent = "parent-995424086";
+ ProcessorVersion processorVersion = ProcessorVersion.newBuilder().build();
+ client.trainProcessorVersionAsync(parent, processorVersion).get();
+ Assert.fail("No exception raised");
+ } catch (ExecutionException e) {
+ Assert.assertEquals(InvalidArgumentException.class, e.getCause().getClass());
+ InvalidArgumentException apiException = ((InvalidArgumentException) e.getCause());
+ Assert.assertEquals(StatusCode.Code.INVALID_ARGUMENT, apiException.getStatusCode().getCode());
+ }
+ }
+
@Test
public void getProcessorVersionTest() throws Exception {
ProcessorVersion expectedResponse =
@@ -707,6 +810,7 @@ public void getProcessorVersionTest() throws Exception {
.setDisplayName("displayName1714148973")
.setDocumentSchema(DocumentSchema.newBuilder().build())
.setCreateTime(Timestamp.newBuilder().build())
+ .setLatestEvaluation(EvaluationReference.newBuilder().build())
.setKmsKeyName("kmsKeyName412586233")
.setKmsKeyVersionName("kmsKeyVersionName-1798811307")
.setGoogleManaged(true)
@@ -757,6 +861,7 @@ public void getProcessorVersionTest2() throws Exception {
.setDisplayName("displayName1714148973")
.setDocumentSchema(DocumentSchema.newBuilder().build())
.setCreateTime(Timestamp.newBuilder().build())
+ .setLatestEvaluation(EvaluationReference.newBuilder().build())
.setKmsKeyName("kmsKeyName412586233")
.setKmsKeyVersionName("kmsKeyVersionName-1798811307")
.setGoogleManaged(true)
@@ -1598,6 +1703,296 @@ public void reviewDocumentExceptionTest2() throws Exception {
}
}
+ @Test
+ public void evaluateProcessorVersionTest() throws Exception {
+ EvaluateProcessorVersionResponse expectedResponse =
+ EvaluateProcessorVersionResponse.newBuilder().setEvaluation("evaluation858523452").build();
+ Operation resultOperation =
+ Operation.newBuilder()
+ .setName("evaluateProcessorVersionTest")
+ .setDone(true)
+ .setResponse(Any.pack(expectedResponse))
+ .build();
+ mockDocumentProcessorService.addResponse(resultOperation);
+
+ ProcessorVersionName processorVersion =
+ ProcessorVersionName.of("[PROJECT]", "[LOCATION]", "[PROCESSOR]", "[PROCESSOR_VERSION]");
+
+ EvaluateProcessorVersionResponse actualResponse =
+ client.evaluateProcessorVersionAsync(processorVersion).get();
+ Assert.assertEquals(expectedResponse, actualResponse);
+
+ List actualRequests = mockDocumentProcessorService.getRequests();
+ Assert.assertEquals(1, actualRequests.size());
+ EvaluateProcessorVersionRequest actualRequest =
+ ((EvaluateProcessorVersionRequest) actualRequests.get(0));
+
+ Assert.assertEquals(processorVersion.toString(), actualRequest.getProcessorVersion());
+ Assert.assertTrue(
+ channelProvider.isHeaderSent(
+ ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
+ GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
+ }
+
+ @Test
+ public void evaluateProcessorVersionExceptionTest() throws Exception {
+ StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
+ mockDocumentProcessorService.addException(exception);
+
+ try {
+ ProcessorVersionName processorVersion =
+ ProcessorVersionName.of("[PROJECT]", "[LOCATION]", "[PROCESSOR]", "[PROCESSOR_VERSION]");
+ client.evaluateProcessorVersionAsync(processorVersion).get();
+ Assert.fail("No exception raised");
+ } catch (ExecutionException e) {
+ Assert.assertEquals(InvalidArgumentException.class, e.getCause().getClass());
+ InvalidArgumentException apiException = ((InvalidArgumentException) e.getCause());
+ Assert.assertEquals(StatusCode.Code.INVALID_ARGUMENT, apiException.getStatusCode().getCode());
+ }
+ }
+
+ @Test
+ public void evaluateProcessorVersionTest2() throws Exception {
+ EvaluateProcessorVersionResponse expectedResponse =
+ EvaluateProcessorVersionResponse.newBuilder().setEvaluation("evaluation858523452").build();
+ Operation resultOperation =
+ Operation.newBuilder()
+ .setName("evaluateProcessorVersionTest")
+ .setDone(true)
+ .setResponse(Any.pack(expectedResponse))
+ .build();
+ mockDocumentProcessorService.addResponse(resultOperation);
+
+ String processorVersion = "processorVersion-1941143578";
+
+ EvaluateProcessorVersionResponse actualResponse =
+ client.evaluateProcessorVersionAsync(processorVersion).get();
+ Assert.assertEquals(expectedResponse, actualResponse);
+
+ List actualRequests = mockDocumentProcessorService.getRequests();
+ Assert.assertEquals(1, actualRequests.size());
+ EvaluateProcessorVersionRequest actualRequest =
+ ((EvaluateProcessorVersionRequest) actualRequests.get(0));
+
+ Assert.assertEquals(processorVersion, actualRequest.getProcessorVersion());
+ Assert.assertTrue(
+ channelProvider.isHeaderSent(
+ ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
+ GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
+ }
+
+ @Test
+ public void evaluateProcessorVersionExceptionTest2() throws Exception {
+ StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
+ mockDocumentProcessorService.addException(exception);
+
+ try {
+ String processorVersion = "processorVersion-1941143578";
+ client.evaluateProcessorVersionAsync(processorVersion).get();
+ Assert.fail("No exception raised");
+ } catch (ExecutionException e) {
+ Assert.assertEquals(InvalidArgumentException.class, e.getCause().getClass());
+ InvalidArgumentException apiException = ((InvalidArgumentException) e.getCause());
+ Assert.assertEquals(StatusCode.Code.INVALID_ARGUMENT, apiException.getStatusCode().getCode());
+ }
+ }
+
+ @Test
+ public void getEvaluationTest() throws Exception {
+ Evaluation expectedResponse =
+ Evaluation.newBuilder()
+ .setName(
+ EvaluationName.of(
+ "[PROJECT]",
+ "[LOCATION]",
+ "[PROCESSOR]",
+ "[PROCESSOR_VERSION]",
+ "[EVALUATION]")
+ .toString())
+ .setCreateTime(Timestamp.newBuilder().build())
+ .setDocumentCounters(Evaluation.Counters.newBuilder().build())
+ .setAllEntitiesMetrics(Evaluation.MultiConfidenceMetrics.newBuilder().build())
+ .putAllEntityMetrics(new HashMap())
+ .setKmsKeyName("kmsKeyName412586233")
+ .setKmsKeyVersionName("kmsKeyVersionName-1798811307")
+ .build();
+ mockDocumentProcessorService.addResponse(expectedResponse);
+
+ EvaluationName name =
+ EvaluationName.of(
+ "[PROJECT]", "[LOCATION]", "[PROCESSOR]", "[PROCESSOR_VERSION]", "[EVALUATION]");
+
+ Evaluation actualResponse = client.getEvaluation(name);
+ Assert.assertEquals(expectedResponse, actualResponse);
+
+ List actualRequests = mockDocumentProcessorService.getRequests();
+ Assert.assertEquals(1, actualRequests.size());
+ GetEvaluationRequest actualRequest = ((GetEvaluationRequest) actualRequests.get(0));
+
+ Assert.assertEquals(name.toString(), actualRequest.getName());
+ Assert.assertTrue(
+ channelProvider.isHeaderSent(
+ ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
+ GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
+ }
+
+ @Test
+ public void getEvaluationExceptionTest() throws Exception {
+ StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
+ mockDocumentProcessorService.addException(exception);
+
+ try {
+ EvaluationName name =
+ EvaluationName.of(
+ "[PROJECT]", "[LOCATION]", "[PROCESSOR]", "[PROCESSOR_VERSION]", "[EVALUATION]");
+ client.getEvaluation(name);
+ Assert.fail("No exception raised");
+ } catch (InvalidArgumentException e) {
+ // Expected exception.
+ }
+ }
+
+ @Test
+ public void getEvaluationTest2() throws Exception {
+ Evaluation expectedResponse =
+ Evaluation.newBuilder()
+ .setName(
+ EvaluationName.of(
+ "[PROJECT]",
+ "[LOCATION]",
+ "[PROCESSOR]",
+ "[PROCESSOR_VERSION]",
+ "[EVALUATION]")
+ .toString())
+ .setCreateTime(Timestamp.newBuilder().build())
+ .setDocumentCounters(Evaluation.Counters.newBuilder().build())
+ .setAllEntitiesMetrics(Evaluation.MultiConfidenceMetrics.newBuilder().build())
+ .putAllEntityMetrics(new HashMap())
+ .setKmsKeyName("kmsKeyName412586233")
+ .setKmsKeyVersionName("kmsKeyVersionName-1798811307")
+ .build();
+ mockDocumentProcessorService.addResponse(expectedResponse);
+
+ String name = "name3373707";
+
+ Evaluation actualResponse = client.getEvaluation(name);
+ Assert.assertEquals(expectedResponse, actualResponse);
+
+ List actualRequests = mockDocumentProcessorService.getRequests();
+ Assert.assertEquals(1, actualRequests.size());
+ GetEvaluationRequest actualRequest = ((GetEvaluationRequest) actualRequests.get(0));
+
+ Assert.assertEquals(name, actualRequest.getName());
+ Assert.assertTrue(
+ channelProvider.isHeaderSent(
+ ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
+ GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
+ }
+
+ @Test
+ public void getEvaluationExceptionTest2() throws Exception {
+ StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
+ mockDocumentProcessorService.addException(exception);
+
+ try {
+ String name = "name3373707";
+ client.getEvaluation(name);
+ Assert.fail("No exception raised");
+ } catch (InvalidArgumentException e) {
+ // Expected exception.
+ }
+ }
+
+ @Test
+ public void listEvaluationsTest() throws Exception {
+ Evaluation responsesElement = Evaluation.newBuilder().build();
+ ListEvaluationsResponse expectedResponse =
+ ListEvaluationsResponse.newBuilder()
+ .setNextPageToken("")
+ .addAllEvaluations(Arrays.asList(responsesElement))
+ .build();
+ mockDocumentProcessorService.addResponse(expectedResponse);
+
+ ProcessorVersionName parent =
+ ProcessorVersionName.of("[PROJECT]", "[LOCATION]", "[PROCESSOR]", "[PROCESSOR_VERSION]");
+
+ ListEvaluationsPagedResponse pagedListResponse = client.listEvaluations(parent);
+
+ List resources = Lists.newArrayList(pagedListResponse.iterateAll());
+
+ Assert.assertEquals(1, resources.size());
+ Assert.assertEquals(expectedResponse.getEvaluationsList().get(0), resources.get(0));
+
+ List actualRequests = mockDocumentProcessorService.getRequests();
+ Assert.assertEquals(1, actualRequests.size());
+ ListEvaluationsRequest actualRequest = ((ListEvaluationsRequest) actualRequests.get(0));
+
+ Assert.assertEquals(parent.toString(), actualRequest.getParent());
+ Assert.assertTrue(
+ channelProvider.isHeaderSent(
+ ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
+ GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
+ }
+
+ @Test
+ public void listEvaluationsExceptionTest() throws Exception {
+ StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
+ mockDocumentProcessorService.addException(exception);
+
+ try {
+ ProcessorVersionName parent =
+ ProcessorVersionName.of("[PROJECT]", "[LOCATION]", "[PROCESSOR]", "[PROCESSOR_VERSION]");
+ client.listEvaluations(parent);
+ Assert.fail("No exception raised");
+ } catch (InvalidArgumentException e) {
+ // Expected exception.
+ }
+ }
+
+ @Test
+ public void listEvaluationsTest2() throws Exception {
+ Evaluation responsesElement = Evaluation.newBuilder().build();
+ ListEvaluationsResponse expectedResponse =
+ ListEvaluationsResponse.newBuilder()
+ .setNextPageToken("")
+ .addAllEvaluations(Arrays.asList(responsesElement))
+ .build();
+ mockDocumentProcessorService.addResponse(expectedResponse);
+
+ String parent = "parent-995424086";
+
+ ListEvaluationsPagedResponse pagedListResponse = client.listEvaluations(parent);
+
+ List resources = Lists.newArrayList(pagedListResponse.iterateAll());
+
+ Assert.assertEquals(1, resources.size());
+ Assert.assertEquals(expectedResponse.getEvaluationsList().get(0), resources.get(0));
+
+ List actualRequests = mockDocumentProcessorService.getRequests();
+ Assert.assertEquals(1, actualRequests.size());
+ ListEvaluationsRequest actualRequest = ((ListEvaluationsRequest) actualRequests.get(0));
+
+ Assert.assertEquals(parent, actualRequest.getParent());
+ Assert.assertTrue(
+ channelProvider.isHeaderSent(
+ ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
+ GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
+ }
+
+ @Test
+ public void listEvaluationsExceptionTest2() throws Exception {
+ StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
+ mockDocumentProcessorService.addException(exception);
+
+ try {
+ String parent = "parent-995424086";
+ client.listEvaluations(parent);
+ Assert.fail("No exception raised");
+ } catch (InvalidArgumentException e) {
+ // Expected exception.
+ }
+ }
+
@Test
public void listLocationsTest() throws Exception {
Location responsesElement = Location.newBuilder().build();
diff --git a/java-document-ai/google-cloud-document-ai/src/test/java/com/google/cloud/documentai/v1/MockDocumentProcessorServiceImpl.java b/java-document-ai/google-cloud-document-ai/src/test/java/com/google/cloud/documentai/v1/MockDocumentProcessorServiceImpl.java
index 99fb06cbee5c..3c5f1a32abba 100644
--- a/java-document-ai/google-cloud-document-ai/src/test/java/com/google/cloud/documentai/v1/MockDocumentProcessorServiceImpl.java
+++ b/java-document-ai/google-cloud-document-ai/src/test/java/com/google/cloud/documentai/v1/MockDocumentProcessorServiceImpl.java
@@ -208,6 +208,27 @@ public void getProcessor(
}
}
+ @Override
+ public void trainProcessorVersion(
+ TrainProcessorVersionRequest request, StreamObserver responseObserver) {
+ Object response = responses.poll();
+ if (response instanceof Operation) {
+ requests.add(request);
+ responseObserver.onNext(((Operation) response));
+ responseObserver.onCompleted();
+ } else if (response instanceof Exception) {
+ responseObserver.onError(((Exception) response));
+ } else {
+ responseObserver.onError(
+ new IllegalArgumentException(
+ String.format(
+ "Unrecognized response type %s for method TrainProcessorVersion, expected %s or %s",
+ response == null ? "null" : response.getClass().getName(),
+ Operation.class.getName(),
+ Exception.class.getName())));
+ }
+ }
+
@Override
public void getProcessorVersion(
GetProcessorVersionRequest request, StreamObserver responseObserver) {
@@ -439,4 +460,67 @@ public void reviewDocument(
Exception.class.getName())));
}
}
+
+ @Override
+ public void evaluateProcessorVersion(
+ EvaluateProcessorVersionRequest request, StreamObserver responseObserver) {
+ Object response = responses.poll();
+ if (response instanceof Operation) {
+ requests.add(request);
+ responseObserver.onNext(((Operation) response));
+ responseObserver.onCompleted();
+ } else if (response instanceof Exception) {
+ responseObserver.onError(((Exception) response));
+ } else {
+ responseObserver.onError(
+ new IllegalArgumentException(
+ String.format(
+ "Unrecognized response type %s for method EvaluateProcessorVersion, expected %s or %s",
+ response == null ? "null" : response.getClass().getName(),
+ Operation.class.getName(),
+ Exception.class.getName())));
+ }
+ }
+
+ @Override
+ public void getEvaluation(
+ GetEvaluationRequest request, StreamObserver responseObserver) {
+ Object response = responses.poll();
+ if (response instanceof Evaluation) {
+ requests.add(request);
+ responseObserver.onNext(((Evaluation) response));
+ responseObserver.onCompleted();
+ } else if (response instanceof Exception) {
+ responseObserver.onError(((Exception) response));
+ } else {
+ responseObserver.onError(
+ new IllegalArgumentException(
+ String.format(
+ "Unrecognized response type %s for method GetEvaluation, expected %s or %s",
+ response == null ? "null" : response.getClass().getName(),
+ Evaluation.class.getName(),
+ Exception.class.getName())));
+ }
+ }
+
+ @Override
+ public void listEvaluations(
+ ListEvaluationsRequest request, StreamObserver responseObserver) {
+ Object response = responses.poll();
+ if (response instanceof ListEvaluationsResponse) {
+ requests.add(request);
+ responseObserver.onNext(((ListEvaluationsResponse) response));
+ responseObserver.onCompleted();
+ } else if (response instanceof Exception) {
+ responseObserver.onError(((Exception) response));
+ } else {
+ responseObserver.onError(
+ new IllegalArgumentException(
+ String.format(
+ "Unrecognized response type %s for method ListEvaluations, expected %s or %s",
+ response == null ? "null" : response.getClass().getName(),
+ ListEvaluationsResponse.class.getName(),
+ Exception.class.getName())));
+ }
+ }
}
diff --git a/java-document-ai/grpc-google-cloud-document-ai-v1/src/main/java/com/google/cloud/documentai/v1/DocumentProcessorServiceGrpc.java b/java-document-ai/grpc-google-cloud-document-ai-v1/src/main/java/com/google/cloud/documentai/v1/DocumentProcessorServiceGrpc.java
index 1e7b6dfa946b..5de5fa4ee1bb 100644
--- a/java-document-ai/grpc-google-cloud-document-ai-v1/src/main/java/com/google/cloud/documentai/v1/DocumentProcessorServiceGrpc.java
+++ b/java-document-ai/grpc-google-cloud-document-ai-v1/src/main/java/com/google/cloud/documentai/v1/DocumentProcessorServiceGrpc.java
@@ -378,6 +378,58 @@ private DocumentProcessorServiceGrpc() {}
return getGetProcessorMethod;
}
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.cloud.documentai.v1.TrainProcessorVersionRequest,
+ com.google.longrunning.Operation>
+ getTrainProcessorVersionMethod;
+
+ @io.grpc.stub.annotations.RpcMethod(
+ fullMethodName = SERVICE_NAME + '/' + "TrainProcessorVersion",
+ requestType = com.google.cloud.documentai.v1.TrainProcessorVersionRequest.class,
+ responseType = com.google.longrunning.Operation.class,
+ methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
+ public static io.grpc.MethodDescriptor<
+ com.google.cloud.documentai.v1.TrainProcessorVersionRequest,
+ com.google.longrunning.Operation>
+ getTrainProcessorVersionMethod() {
+ io.grpc.MethodDescriptor<
+ com.google.cloud.documentai.v1.TrainProcessorVersionRequest,
+ com.google.longrunning.Operation>
+ getTrainProcessorVersionMethod;
+ if ((getTrainProcessorVersionMethod =
+ DocumentProcessorServiceGrpc.getTrainProcessorVersionMethod)
+ == null) {
+ synchronized (DocumentProcessorServiceGrpc.class) {
+ if ((getTrainProcessorVersionMethod =
+ DocumentProcessorServiceGrpc.getTrainProcessorVersionMethod)
+ == null) {
+ DocumentProcessorServiceGrpc.getTrainProcessorVersionMethod =
+ getTrainProcessorVersionMethod =
+ io.grpc.MethodDescriptor
+ .
+ newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(
+ generateFullMethodName(SERVICE_NAME, "TrainProcessorVersion"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.documentai.v1.TrainProcessorVersionRequest
+ .getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.longrunning.Operation.getDefaultInstance()))
+ .setSchemaDescriptor(
+ new DocumentProcessorServiceMethodDescriptorSupplier(
+ "TrainProcessorVersion"))
+ .build();
+ }
+ }
+ }
+ return getTrainProcessorVersionMethod;
+ }
+
private static volatile io.grpc.MethodDescriptor<
com.google.cloud.documentai.v1.GetProcessorVersionRequest,
com.google.cloud.documentai.v1.ProcessorVersion>
@@ -918,6 +970,154 @@ private DocumentProcessorServiceGrpc() {}
return getReviewDocumentMethod;
}
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.cloud.documentai.v1.EvaluateProcessorVersionRequest,
+ com.google.longrunning.Operation>
+ getEvaluateProcessorVersionMethod;
+
+ @io.grpc.stub.annotations.RpcMethod(
+ fullMethodName = SERVICE_NAME + '/' + "EvaluateProcessorVersion",
+ requestType = com.google.cloud.documentai.v1.EvaluateProcessorVersionRequest.class,
+ responseType = com.google.longrunning.Operation.class,
+ methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
+ public static io.grpc.MethodDescriptor<
+ com.google.cloud.documentai.v1.EvaluateProcessorVersionRequest,
+ com.google.longrunning.Operation>
+ getEvaluateProcessorVersionMethod() {
+ io.grpc.MethodDescriptor<
+ com.google.cloud.documentai.v1.EvaluateProcessorVersionRequest,
+ com.google.longrunning.Operation>
+ getEvaluateProcessorVersionMethod;
+ if ((getEvaluateProcessorVersionMethod =
+ DocumentProcessorServiceGrpc.getEvaluateProcessorVersionMethod)
+ == null) {
+ synchronized (DocumentProcessorServiceGrpc.class) {
+ if ((getEvaluateProcessorVersionMethod =
+ DocumentProcessorServiceGrpc.getEvaluateProcessorVersionMethod)
+ == null) {
+ DocumentProcessorServiceGrpc.getEvaluateProcessorVersionMethod =
+ getEvaluateProcessorVersionMethod =
+ io.grpc.MethodDescriptor
+ .
+ newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(
+ generateFullMethodName(SERVICE_NAME, "EvaluateProcessorVersion"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.documentai.v1.EvaluateProcessorVersionRequest
+ .getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.longrunning.Operation.getDefaultInstance()))
+ .setSchemaDescriptor(
+ new DocumentProcessorServiceMethodDescriptorSupplier(
+ "EvaluateProcessorVersion"))
+ .build();
+ }
+ }
+ }
+ return getEvaluateProcessorVersionMethod;
+ }
+
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.cloud.documentai.v1.GetEvaluationRequest,
+ com.google.cloud.documentai.v1.Evaluation>
+ getGetEvaluationMethod;
+
+ @io.grpc.stub.annotations.RpcMethod(
+ fullMethodName = SERVICE_NAME + '/' + "GetEvaluation",
+ requestType = com.google.cloud.documentai.v1.GetEvaluationRequest.class,
+ responseType = com.google.cloud.documentai.v1.Evaluation.class,
+ methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
+ public static io.grpc.MethodDescriptor<
+ com.google.cloud.documentai.v1.GetEvaluationRequest,
+ com.google.cloud.documentai.v1.Evaluation>
+ getGetEvaluationMethod() {
+ io.grpc.MethodDescriptor<
+ com.google.cloud.documentai.v1.GetEvaluationRequest,
+ com.google.cloud.documentai.v1.Evaluation>
+ getGetEvaluationMethod;
+ if ((getGetEvaluationMethod = DocumentProcessorServiceGrpc.getGetEvaluationMethod) == null) {
+ synchronized (DocumentProcessorServiceGrpc.class) {
+ if ((getGetEvaluationMethod = DocumentProcessorServiceGrpc.getGetEvaluationMethod)
+ == null) {
+ DocumentProcessorServiceGrpc.getGetEvaluationMethod =
+ getGetEvaluationMethod =
+ io.grpc.MethodDescriptor
+ .
+ newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetEvaluation"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.documentai.v1.GetEvaluationRequest
+ .getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.documentai.v1.Evaluation.getDefaultInstance()))
+ .setSchemaDescriptor(
+ new DocumentProcessorServiceMethodDescriptorSupplier("GetEvaluation"))
+ .build();
+ }
+ }
+ }
+ return getGetEvaluationMethod;
+ }
+
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.cloud.documentai.v1.ListEvaluationsRequest,
+ com.google.cloud.documentai.v1.ListEvaluationsResponse>
+ getListEvaluationsMethod;
+
+ @io.grpc.stub.annotations.RpcMethod(
+ fullMethodName = SERVICE_NAME + '/' + "ListEvaluations",
+ requestType = com.google.cloud.documentai.v1.ListEvaluationsRequest.class,
+ responseType = com.google.cloud.documentai.v1.ListEvaluationsResponse.class,
+ methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
+ public static io.grpc.MethodDescriptor<
+ com.google.cloud.documentai.v1.ListEvaluationsRequest,
+ com.google.cloud.documentai.v1.ListEvaluationsResponse>
+ getListEvaluationsMethod() {
+ io.grpc.MethodDescriptor<
+ com.google.cloud.documentai.v1.ListEvaluationsRequest,
+ com.google.cloud.documentai.v1.ListEvaluationsResponse>
+ getListEvaluationsMethod;
+ if ((getListEvaluationsMethod = DocumentProcessorServiceGrpc.getListEvaluationsMethod)
+ == null) {
+ synchronized (DocumentProcessorServiceGrpc.class) {
+ if ((getListEvaluationsMethod = DocumentProcessorServiceGrpc.getListEvaluationsMethod)
+ == null) {
+ DocumentProcessorServiceGrpc.getListEvaluationsMethod =
+ getListEvaluationsMethod =
+ io.grpc.MethodDescriptor
+ .
+ newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListEvaluations"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.documentai.v1.ListEvaluationsRequest
+ .getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.documentai.v1.ListEvaluationsResponse
+ .getDefaultInstance()))
+ .setSchemaDescriptor(
+ new DocumentProcessorServiceMethodDescriptorSupplier("ListEvaluations"))
+ .build();
+ }
+ }
+ }
+ return getListEvaluationsMethod;
+ }
+
/** Creates a new async stub that supports all call types for the service */
public static DocumentProcessorServiceStub newStub(io.grpc.Channel channel) {
io.grpc.stub.AbstractStub.StubFactory factory =
@@ -1076,6 +1276,22 @@ public void getProcessor(
getGetProcessorMethod(), responseObserver);
}
+ /**
+ *
+ *
+ *
+ * Trains a new processor version.
+ * Operation metadata is returned as
+ * cloud_documentai_core.TrainProcessorVersionMetadata.
+ *
+ */
+ public void trainProcessorVersion(
+ com.google.cloud.documentai.v1.TrainProcessorVersionRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
+ getTrainProcessorVersionMethod(), responseObserver);
+ }
+
/**
*
*
@@ -1240,6 +1456,50 @@ public void reviewDocument(
getReviewDocumentMethod(), responseObserver);
}
+ /**
+ *
+ *
+ *
+ * Evaluates a ProcessorVersion against annotated documents, producing an
+ * Evaluation.
+ *
+ */
+ public void evaluateProcessorVersion(
+ com.google.cloud.documentai.v1.EvaluateProcessorVersionRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
+ getEvaluateProcessorVersionMethod(), responseObserver);
+ }
+
+ /**
+ *
+ *
+ *
+ * Retrieves a specific evaluation.
+ *
+ */
+ public void getEvaluation(
+ com.google.cloud.documentai.v1.GetEvaluationRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
+ getGetEvaluationMethod(), responseObserver);
+ }
+
+ /**
+ *
+ *
+ *
+ * Retrieves a set of evaluations for a given processor version.
+ *
+ */
+ public void listEvaluations(
+ com.google.cloud.documentai.v1.ListEvaluationsRequest request,
+ io.grpc.stub.StreamObserver
+ responseObserver) {
+ io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
+ getListEvaluationsMethod(), responseObserver);
+ }
+
@java.lang.Override
public final io.grpc.ServerServiceDefinition bindService() {
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
@@ -1290,6 +1550,12 @@ public final io.grpc.ServerServiceDefinition bindService() {
new MethodHandlers<
com.google.cloud.documentai.v1.GetProcessorRequest,
com.google.cloud.documentai.v1.Processor>(this, METHODID_GET_PROCESSOR)))
+ .addMethod(
+ getTrainProcessorVersionMethod(),
+ io.grpc.stub.ServerCalls.asyncUnaryCall(
+ new MethodHandlers<
+ com.google.cloud.documentai.v1.TrainProcessorVersionRequest,
+ com.google.longrunning.Operation>(this, METHODID_TRAIN_PROCESSOR_VERSION)))
.addMethod(
getGetProcessorVersionMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
@@ -1359,6 +1625,25 @@ public final io.grpc.ServerServiceDefinition bindService() {
new MethodHandlers<
com.google.cloud.documentai.v1.ReviewDocumentRequest,
com.google.longrunning.Operation>(this, METHODID_REVIEW_DOCUMENT)))
+ .addMethod(
+ getEvaluateProcessorVersionMethod(),
+ io.grpc.stub.ServerCalls.asyncUnaryCall(
+ new MethodHandlers<
+ com.google.cloud.documentai.v1.EvaluateProcessorVersionRequest,
+ com.google.longrunning.Operation>(this, METHODID_EVALUATE_PROCESSOR_VERSION)))
+ .addMethod(
+ getGetEvaluationMethod(),
+ io.grpc.stub.ServerCalls.asyncUnaryCall(
+ new MethodHandlers<
+ com.google.cloud.documentai.v1.GetEvaluationRequest,
+ com.google.cloud.documentai.v1.Evaluation>(this, METHODID_GET_EVALUATION)))
+ .addMethod(
+ getListEvaluationsMethod(),
+ io.grpc.stub.ServerCalls.asyncUnaryCall(
+ new MethodHandlers<
+ com.google.cloud.documentai.v1.ListEvaluationsRequest,
+ com.google.cloud.documentai.v1.ListEvaluationsResponse>(
+ this, METHODID_LIST_EVALUATIONS)))
.build();
}
}
@@ -1504,6 +1789,24 @@ public void getProcessor(
responseObserver);
}
+ /**
+ *
+ *
+ *
+ * Trains a new processor version.
+ * Operation metadata is returned as
+ * cloud_documentai_core.TrainProcessorVersionMetadata.
+ *
+ */
+ public void trainProcessorVersion(
+ com.google.cloud.documentai.v1.TrainProcessorVersionRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ io.grpc.stub.ClientCalls.asyncUnaryCall(
+ getChannel().newCall(getTrainProcessorVersionMethod(), getCallOptions()),
+ request,
+ responseObserver);
+ }
+
/**
*
*
@@ -1689,6 +1992,56 @@ public void reviewDocument(
request,
responseObserver);
}
+
+ /**
+ *
+ *
+ *
+ * Evaluates a ProcessorVersion against annotated documents, producing an
+ * Evaluation.
+ *
+ */
+ public void evaluateProcessorVersion(
+ com.google.cloud.documentai.v1.EvaluateProcessorVersionRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ io.grpc.stub.ClientCalls.asyncUnaryCall(
+ getChannel().newCall(getEvaluateProcessorVersionMethod(), getCallOptions()),
+ request,
+ responseObserver);
+ }
+
+ /**
+ *
+ *
+ *
+ * Retrieves a specific evaluation.
+ *
+ */
+ public void getEvaluation(
+ com.google.cloud.documentai.v1.GetEvaluationRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ io.grpc.stub.ClientCalls.asyncUnaryCall(
+ getChannel().newCall(getGetEvaluationMethod(), getCallOptions()),
+ request,
+ responseObserver);
+ }
+
+ /**
+ *
+ *
+ *
+ * Retrieves a set of evaluations for a given processor version.
+ *
+ */
+ public void listEvaluations(
+ com.google.cloud.documentai.v1.ListEvaluationsRequest request,
+ io.grpc.stub.StreamObserver
+ responseObserver) {
+ io.grpc.stub.ClientCalls.asyncUnaryCall(
+ getChannel().newCall(getListEvaluationsMethod(), getCallOptions()),
+ request,
+ responseObserver);
+ }
}
/**
@@ -1807,6 +2160,21 @@ public com.google.cloud.documentai.v1.Processor getProcessor(
getChannel(), getGetProcessorMethod(), getCallOptions(), request);
}
+ /**
+ *
+ *
+ *
+ * Trains a new processor version.
+ * Operation metadata is returned as
+ * cloud_documentai_core.TrainProcessorVersionMetadata.
+ *
+ */
+ public com.google.longrunning.Operation trainProcessorVersion(
+ com.google.cloud.documentai.v1.TrainProcessorVersionRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getTrainProcessorVersionMethod(), getCallOptions(), request);
+ }
+
/**
*
*
@@ -1957,6 +2325,46 @@ public com.google.longrunning.Operation reviewDocument(
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getReviewDocumentMethod(), getCallOptions(), request);
}
+
+ /**
+ *
+ *
+ *
+ * Evaluates a ProcessorVersion against annotated documents, producing an
+ * Evaluation.
+ *
+ */
+ public com.google.longrunning.Operation evaluateProcessorVersion(
+ com.google.cloud.documentai.v1.EvaluateProcessorVersionRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getEvaluateProcessorVersionMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Retrieves a specific evaluation.
+ *
+ */
+ public com.google.cloud.documentai.v1.Evaluation getEvaluation(
+ com.google.cloud.documentai.v1.GetEvaluationRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getGetEvaluationMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Retrieves a set of evaluations for a given processor version.
+ *
+ */
+ public com.google.cloud.documentai.v1.ListEvaluationsResponse listEvaluations(
+ com.google.cloud.documentai.v1.ListEvaluationsRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getListEvaluationsMethod(), getCallOptions(), request);
+ }
}
/**
@@ -2081,6 +2489,21 @@ protected DocumentProcessorServiceFutureStub build(
getChannel().newCall(getGetProcessorMethod(), getCallOptions()), request);
}
+ /**
+ *
+ *
+ *
+ * Trains a new processor version.
+ * Operation metadata is returned as
+ * cloud_documentai_core.TrainProcessorVersionMetadata.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture
+ trainProcessorVersion(com.google.cloud.documentai.v1.TrainProcessorVersionRequest request) {
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
+ getChannel().newCall(getTrainProcessorVersionMethod(), getCallOptions()), request);
+ }
+
/**
*
*
@@ -2238,6 +2661,49 @@ protected DocumentProcessorServiceFutureStub build(
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getReviewDocumentMethod(), getCallOptions()), request);
}
+
+ /**
+ *
+ *
+ *
+ * Evaluates a ProcessorVersion against annotated documents, producing an
+ * Evaluation.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture
+ evaluateProcessorVersion(
+ com.google.cloud.documentai.v1.EvaluateProcessorVersionRequest request) {
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
+ getChannel().newCall(getEvaluateProcessorVersionMethod(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Retrieves a specific evaluation.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture<
+ com.google.cloud.documentai.v1.Evaluation>
+ getEvaluation(com.google.cloud.documentai.v1.GetEvaluationRequest request) {
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
+ getChannel().newCall(getGetEvaluationMethod(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Retrieves a set of evaluations for a given processor version.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture<
+ com.google.cloud.documentai.v1.ListEvaluationsResponse>
+ listEvaluations(com.google.cloud.documentai.v1.ListEvaluationsRequest request) {
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
+ getChannel().newCall(getListEvaluationsMethod(), getCallOptions()), request);
+ }
}
private static final int METHODID_PROCESS_DOCUMENT = 0;
@@ -2247,17 +2713,21 @@ protected DocumentProcessorServiceFutureStub build(
private static final int METHODID_GET_PROCESSOR_TYPE = 4;
private static final int METHODID_LIST_PROCESSORS = 5;
private static final int METHODID_GET_PROCESSOR = 6;
- private static final int METHODID_GET_PROCESSOR_VERSION = 7;
- private static final int METHODID_LIST_PROCESSOR_VERSIONS = 8;
- private static final int METHODID_DELETE_PROCESSOR_VERSION = 9;
- private static final int METHODID_DEPLOY_PROCESSOR_VERSION = 10;
- private static final int METHODID_UNDEPLOY_PROCESSOR_VERSION = 11;
- private static final int METHODID_CREATE_PROCESSOR = 12;
- private static final int METHODID_DELETE_PROCESSOR = 13;
- private static final int METHODID_ENABLE_PROCESSOR = 14;
- private static final int METHODID_DISABLE_PROCESSOR = 15;
- private static final int METHODID_SET_DEFAULT_PROCESSOR_VERSION = 16;
- private static final int METHODID_REVIEW_DOCUMENT = 17;
+ private static final int METHODID_TRAIN_PROCESSOR_VERSION = 7;
+ private static final int METHODID_GET_PROCESSOR_VERSION = 8;
+ private static final int METHODID_LIST_PROCESSOR_VERSIONS = 9;
+ private static final int METHODID_DELETE_PROCESSOR_VERSION = 10;
+ private static final int METHODID_DEPLOY_PROCESSOR_VERSION = 11;
+ private static final int METHODID_UNDEPLOY_PROCESSOR_VERSION = 12;
+ private static final int METHODID_CREATE_PROCESSOR = 13;
+ private static final int METHODID_DELETE_PROCESSOR = 14;
+ private static final int METHODID_ENABLE_PROCESSOR = 15;
+ private static final int METHODID_DISABLE_PROCESSOR = 16;
+ private static final int METHODID_SET_DEFAULT_PROCESSOR_VERSION = 17;
+ private static final int METHODID_REVIEW_DOCUMENT = 18;
+ private static final int METHODID_EVALUATE_PROCESSOR_VERSION = 19;
+ private static final int METHODID_GET_EVALUATION = 20;
+ private static final int METHODID_LIST_EVALUATIONS = 21;
private static final class MethodHandlers
implements io.grpc.stub.ServerCalls.UnaryMethod,
@@ -2319,6 +2789,11 @@ public void invoke(Req request, io.grpc.stub.StreamObserver responseObserv
(io.grpc.stub.StreamObserver)
responseObserver);
break;
+ case METHODID_TRAIN_PROCESSOR_VERSION:
+ serviceImpl.trainProcessorVersion(
+ (com.google.cloud.documentai.v1.TrainProcessorVersionRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
case METHODID_GET_PROCESSOR_VERSION:
serviceImpl.getProcessorVersion(
(com.google.cloud.documentai.v1.GetProcessorVersionRequest) request,
@@ -2378,6 +2853,23 @@ public void invoke(Req request, io.grpc.stub.StreamObserver responseObserv
(com.google.cloud.documentai.v1.ReviewDocumentRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
+ case METHODID_EVALUATE_PROCESSOR_VERSION:
+ serviceImpl.evaluateProcessorVersion(
+ (com.google.cloud.documentai.v1.EvaluateProcessorVersionRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_GET_EVALUATION:
+ serviceImpl.getEvaluation(
+ (com.google.cloud.documentai.v1.GetEvaluationRequest) request,
+ (io.grpc.stub.StreamObserver