{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* DatasetName name = DatasetName.of("[PROJECT]", "[LOCATION]", "[DATASET]");
* Dataset response = datasetServiceClient.getDataset(name);
@@ -83,6 +93,8 @@
* To customize credentials:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* DatasetServiceSettings datasetServiceSettings =
* DatasetServiceSettings.newBuilder()
* .setCredentialsProvider(FixedCredentialsProvider.create(myCredentials))
@@ -93,6 +105,8 @@
* To customize the endpoint:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* DatasetServiceSettings datasetServiceSettings =
* DatasetServiceSettings.newBuilder().setEndpoint(myEndpoint).build();
* DatasetServiceClient datasetServiceClient = DatasetServiceClient.create(datasetServiceSettings);
@@ -124,7 +138,6 @@ public static final DatasetServiceClient create(DatasetServiceSettings settings)
* Constructs an instance of DatasetServiceClient, using the given stub for making calls. This is
* for advanced usage - prefer using create(DatasetServiceSettings).
*/
- @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public static final DatasetServiceClient create(DatasetServiceStub stub) {
return new DatasetServiceClient(stub);
}
@@ -140,7 +153,6 @@ protected DatasetServiceClient(DatasetServiceSettings settings) throws IOExcepti
this.operationsClient = OperationsClient.create(this.stub.getOperationsStub());
}
- @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
protected DatasetServiceClient(DatasetServiceStub stub) {
this.settings = null;
this.stub = stub;
@@ -151,7 +163,6 @@ public final DatasetServiceSettings getSettings() {
return settings;
}
- @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public DatasetServiceStub getStub() {
return stub;
}
@@ -171,6 +182,8 @@ public final OperationsClient getOperationsClient() {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
* Dataset dataset = Dataset.newBuilder().build();
@@ -200,6 +213,8 @@ public final OperationFuture createData
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
* Dataset dataset = Dataset.newBuilder().build();
@@ -226,6 +241,8 @@ public final OperationFuture createData
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* CreateDatasetRequest request =
* CreateDatasetRequest.newBuilder()
@@ -251,6 +268,8 @@ public final OperationFuture createData
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* CreateDatasetRequest request =
* CreateDatasetRequest.newBuilder()
@@ -276,6 +295,8 @@ public final OperationFuture createData
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* CreateDatasetRequest request =
* CreateDatasetRequest.newBuilder()
@@ -300,6 +321,8 @@ public final UnaryCallable createDatasetCallabl
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* DatasetName name = DatasetName.of("[PROJECT]", "[LOCATION]", "[DATASET]");
* Dataset response = datasetServiceClient.getDataset(name);
@@ -322,6 +345,8 @@ public final Dataset getDataset(DatasetName name) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* String name = DatasetName.of("[PROJECT]", "[LOCATION]", "[DATASET]").toString();
* Dataset response = datasetServiceClient.getDataset(name);
@@ -343,6 +368,8 @@ public final Dataset getDataset(String name) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* GetDatasetRequest request =
* GetDatasetRequest.newBuilder()
@@ -367,6 +394,8 @@ public final Dataset getDataset(GetDatasetRequest request) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* GetDatasetRequest request =
* GetDatasetRequest.newBuilder()
@@ -390,6 +419,8 @@ public final UnaryCallable getDatasetCallable() {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* Dataset dataset = Dataset.newBuilder().build();
* FieldMask updateMask = FieldMask.newBuilder().build();
@@ -416,6 +447,8 @@ public final Dataset updateDataset(Dataset dataset, FieldMask updateMask) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* UpdateDatasetRequest request =
* UpdateDatasetRequest.newBuilder()
@@ -440,6 +473,8 @@ public final Dataset updateDataset(UpdateDatasetRequest request) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* UpdateDatasetRequest request =
* UpdateDatasetRequest.newBuilder()
@@ -463,6 +498,8 @@ public final UnaryCallable updateDatasetCallable(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
* for (Dataset element : datasetServiceClient.listDatasets(parent).iterateAll()) {
@@ -490,6 +527,8 @@ public final ListDatasetsPagedResponse listDatasets(LocationName parent) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
* for (Dataset element : datasetServiceClient.listDatasets(parent).iterateAll()) {
@@ -514,6 +553,8 @@ public final ListDatasetsPagedResponse listDatasets(String parent) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* ListDatasetsRequest request =
* ListDatasetsRequest.newBuilder()
@@ -544,6 +585,8 @@ public final ListDatasetsPagedResponse listDatasets(ListDatasetsRequest request)
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* ListDatasetsRequest request =
* ListDatasetsRequest.newBuilder()
@@ -575,6 +618,8 @@ public final ListDatasetsPagedResponse listDatasets(ListDatasetsRequest request)
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* ListDatasetsRequest request =
* ListDatasetsRequest.newBuilder()
@@ -587,7 +632,7 @@ public final ListDatasetsPagedResponse listDatasets(ListDatasetsRequest request)
* .build();
* while (true) {
* ListDatasetsResponse response = datasetServiceClient.listDatasetsCallable().call(request);
- * for (Dataset element : response.getResponsesList()) {
+ * for (Dataset element : response.getDatasetsList()) {
* // doThingsWith(element);
* }
* String nextPageToken = response.getNextPageToken();
@@ -611,6 +656,8 @@ public final UnaryCallable listDatase
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* DatasetName name = DatasetName.of("[PROJECT]", "[LOCATION]", "[DATASET]");
* datasetServiceClient.deleteDatasetAsync(name).get();
@@ -635,6 +682,8 @@ public final OperationFuture deleteDatasetAsync(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* String name = DatasetName.of("[PROJECT]", "[LOCATION]", "[DATASET]").toString();
* datasetServiceClient.deleteDatasetAsync(name).get();
@@ -657,6 +706,8 @@ public final OperationFuture deleteDatasetAsync(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* DeleteDatasetRequest request =
* DeleteDatasetRequest.newBuilder()
@@ -681,6 +732,8 @@ public final OperationFuture deleteDatasetAsync(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* DeleteDatasetRequest request =
* DeleteDatasetRequest.newBuilder()
@@ -705,6 +758,8 @@ public final OperationFuture deleteDatasetAsync(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* DeleteDatasetRequest request =
* DeleteDatasetRequest.newBuilder()
@@ -728,6 +783,8 @@ public final UnaryCallable deleteDatasetCallabl
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* DatasetName name = DatasetName.of("[PROJECT]", "[LOCATION]", "[DATASET]");
* List importConfigs = new ArrayList<>();
@@ -758,6 +815,8 @@ public final OperationFuture im
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* String name = DatasetName.of("[PROJECT]", "[LOCATION]", "[DATASET]").toString();
* List importConfigs = new ArrayList<>();
@@ -785,6 +844,8 @@ public final OperationFuture im
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* ImportDataRequest request =
* ImportDataRequest.newBuilder()
@@ -810,6 +871,8 @@ public final OperationFuture im
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* ImportDataRequest request =
* ImportDataRequest.newBuilder()
@@ -835,6 +898,8 @@ public final OperationFuture im
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* ImportDataRequest request =
* ImportDataRequest.newBuilder()
@@ -858,6 +923,8 @@ public final UnaryCallable importDataCallable() {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* DatasetName name = DatasetName.of("[PROJECT]", "[LOCATION]", "[DATASET]");
* ExportDataConfig exportConfig = ExportDataConfig.newBuilder().build();
@@ -887,6 +954,8 @@ public final OperationFuture ex
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* String name = DatasetName.of("[PROJECT]", "[LOCATION]", "[DATASET]").toString();
* ExportDataConfig exportConfig = ExportDataConfig.newBuilder().build();
@@ -913,6 +982,8 @@ public final OperationFuture ex
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* ExportDataRequest request =
* ExportDataRequest.newBuilder()
@@ -938,6 +1009,8 @@ public final OperationFuture ex
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* ExportDataRequest request =
* ExportDataRequest.newBuilder()
@@ -963,6 +1036,8 @@ public final OperationFuture ex
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* ExportDataRequest request =
* ExportDataRequest.newBuilder()
@@ -986,6 +1061,8 @@ public final UnaryCallable exportDataCallable() {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* DatasetName parent = DatasetName.of("[PROJECT]", "[LOCATION]", "[DATASET]");
* for (DataItem element : datasetServiceClient.listDataItems(parent).iterateAll()) {
@@ -1013,6 +1090,8 @@ public final ListDataItemsPagedResponse listDataItems(DatasetName parent) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* String parent = DatasetName.of("[PROJECT]", "[LOCATION]", "[DATASET]").toString();
* for (DataItem element : datasetServiceClient.listDataItems(parent).iterateAll()) {
@@ -1037,6 +1116,8 @@ public final ListDataItemsPagedResponse listDataItems(String parent) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* ListDataItemsRequest request =
* ListDataItemsRequest.newBuilder()
@@ -1067,6 +1148,8 @@ public final ListDataItemsPagedResponse listDataItems(ListDataItemsRequest reque
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* ListDataItemsRequest request =
* ListDataItemsRequest.newBuilder()
@@ -1098,6 +1181,8 @@ public final ListDataItemsPagedResponse listDataItems(ListDataItemsRequest reque
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* ListDataItemsRequest request =
* ListDataItemsRequest.newBuilder()
@@ -1110,7 +1195,7 @@ public final ListDataItemsPagedResponse listDataItems(ListDataItemsRequest reque
* .build();
* while (true) {
* ListDataItemsResponse response = datasetServiceClient.listDataItemsCallable().call(request);
- * for (DataItem element : response.getResponsesList()) {
+ * for (DataItem element : response.getDataItemsList()) {
* // doThingsWith(element);
* }
* String nextPageToken = response.getNextPageToken();
@@ -1134,6 +1219,8 @@ public final UnaryCallable listData
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* AnnotationSpecName name =
* AnnotationSpecName.of("[PROJECT]", "[LOCATION]", "[DATASET]", "[ANNOTATION_SPEC]");
@@ -1160,6 +1247,8 @@ public final AnnotationSpec getAnnotationSpec(AnnotationSpecName name) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* String name =
* AnnotationSpecName.of("[PROJECT]", "[LOCATION]", "[DATASET]", "[ANNOTATION_SPEC]")
@@ -1184,6 +1273,8 @@ public final AnnotationSpec getAnnotationSpec(String name) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* GetAnnotationSpecRequest request =
* GetAnnotationSpecRequest.newBuilder()
@@ -1210,6 +1301,8 @@ public final AnnotationSpec getAnnotationSpec(GetAnnotationSpecRequest request)
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* GetAnnotationSpecRequest request =
* GetAnnotationSpecRequest.newBuilder()
@@ -1236,6 +1329,8 @@ public final UnaryCallable getAnnotati
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* DataItemName parent = DataItemName.of("[PROJECT]", "[LOCATION]", "[DATASET]", "[DATA_ITEM]");
* for (Annotation element : datasetServiceClient.listAnnotations(parent).iterateAll()) {
@@ -1263,6 +1358,8 @@ public final ListAnnotationsPagedResponse listAnnotations(DataItemName parent) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* String parent =
* DataItemName.of("[PROJECT]", "[LOCATION]", "[DATASET]", "[DATA_ITEM]").toString();
@@ -1288,6 +1385,8 @@ public final ListAnnotationsPagedResponse listAnnotations(String parent) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* ListAnnotationsRequest request =
* ListAnnotationsRequest.newBuilder()
@@ -1319,6 +1418,8 @@ public final ListAnnotationsPagedResponse listAnnotations(ListAnnotationsRequest
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* ListAnnotationsRequest request =
* ListAnnotationsRequest.newBuilder()
@@ -1351,6 +1452,8 @@ public final ListAnnotationsPagedResponse listAnnotations(ListAnnotationsRequest
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
* ListAnnotationsRequest request =
* ListAnnotationsRequest.newBuilder()
@@ -1365,7 +1468,7 @@ public final ListAnnotationsPagedResponse listAnnotations(ListAnnotationsRequest
* while (true) {
* ListAnnotationsResponse response =
* datasetServiceClient.listAnnotationsCallable().call(request);
- * for (Annotation element : response.getResponsesList()) {
+ * for (Annotation element : response.getAnnotationsList()) {
* // doThingsWith(element);
* }
* String nextPageToken = response.getNextPageToken();
@@ -1383,6 +1486,331 @@ public final ListAnnotationsPagedResponse listAnnotations(ListAnnotationsRequest
return stub.listAnnotationsCallable();
}
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists information about the supported locations for this service.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
+ * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
+ * ListLocationsRequest request =
+ * ListLocationsRequest.newBuilder()
+ * .setName("name3373707")
+ * .setFilter("filter-1274492040")
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .build();
+ * for (Location element : datasetServiceClient.listLocations(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 ListLocationsPagedResponse listLocations(ListLocationsRequest request) {
+ return listLocationsPagedCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists information about the supported locations for this service.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
+ * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
+ * ListLocationsRequest request =
+ * ListLocationsRequest.newBuilder()
+ * .setName("name3373707")
+ * .setFilter("filter-1274492040")
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .build();
+ * ApiFuture future =
+ * datasetServiceClient.listLocationsPagedCallable().futureCall(request);
+ * // Do something.
+ * for (Location element : future.get().iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ * }
+ */
+ public final UnaryCallable
+ listLocationsPagedCallable() {
+ return stub.listLocationsPagedCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists information about the supported locations for this service.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
+ * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
+ * ListLocationsRequest request =
+ * ListLocationsRequest.newBuilder()
+ * .setName("name3373707")
+ * .setFilter("filter-1274492040")
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .build();
+ * while (true) {
+ * ListLocationsResponse response = datasetServiceClient.listLocationsCallable().call(request);
+ * for (Location element : response.getLocationsList()) {
+ * // doThingsWith(element);
+ * }
+ * String nextPageToken = response.getNextPageToken();
+ * if (!Strings.isNullOrEmpty(nextPageToken)) {
+ * request = request.toBuilder().setPageToken(nextPageToken).build();
+ * } else {
+ * break;
+ * }
+ * }
+ * }
+ * }
+ */
+ public final UnaryCallable listLocationsCallable() {
+ return stub.listLocationsCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Gets information about a location.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
+ * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
+ * GetLocationRequest request = GetLocationRequest.newBuilder().setName("name3373707").build();
+ * Location response = datasetServiceClient.getLocation(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 Location getLocation(GetLocationRequest request) {
+ return getLocationCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Gets information about a location.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
+ * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
+ * GetLocationRequest request = GetLocationRequest.newBuilder().setName("name3373707").build();
+ * ApiFuture future = datasetServiceClient.getLocationCallable().futureCall(request);
+ * // Do something.
+ * Location response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable getLocationCallable() {
+ return stub.getLocationCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Sets the access control policy on the specified resource. Replacesany existing policy.
+ *
+ * Can return `NOT_FOUND`, `INVALID_ARGUMENT`, and `PERMISSION_DENIED`errors.
+ *
+ *
Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
+ * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
+ * SetIamPolicyRequest request =
+ * SetIamPolicyRequest.newBuilder()
+ * .setResource(
+ * EntityTypeName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]", "[ENTITY_TYPE]")
+ * .toString())
+ * .setPolicy(Policy.newBuilder().build())
+ * .setUpdateMask(FieldMask.newBuilder().build())
+ * .build();
+ * Policy response = datasetServiceClient.setIamPolicy(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 Policy setIamPolicy(SetIamPolicyRequest request) {
+ return setIamPolicyCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Sets the access control policy on the specified resource. Replacesany existing policy.
+ *
+ * Can return `NOT_FOUND`, `INVALID_ARGUMENT`, and `PERMISSION_DENIED`errors.
+ *
+ *
Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
+ * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
+ * SetIamPolicyRequest request =
+ * SetIamPolicyRequest.newBuilder()
+ * .setResource(
+ * EntityTypeName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]", "[ENTITY_TYPE]")
+ * .toString())
+ * .setPolicy(Policy.newBuilder().build())
+ * .setUpdateMask(FieldMask.newBuilder().build())
+ * .build();
+ * ApiFuture future = datasetServiceClient.setIamPolicyCallable().futureCall(request);
+ * // Do something.
+ * Policy response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable setIamPolicyCallable() {
+ return stub.setIamPolicyCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Gets the access control policy for a resource. Returns an empty policyif the resource exists
+ * and does not have a policy set.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
+ * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
+ * GetIamPolicyRequest request =
+ * GetIamPolicyRequest.newBuilder()
+ * .setResource(
+ * EntityTypeName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]", "[ENTITY_TYPE]")
+ * .toString())
+ * .setOptions(GetPolicyOptions.newBuilder().build())
+ * .build();
+ * Policy response = datasetServiceClient.getIamPolicy(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 Policy getIamPolicy(GetIamPolicyRequest request) {
+ return getIamPolicyCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Gets the access control policy for a resource. Returns an empty policyif the resource exists
+ * and does not have a policy set.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
+ * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
+ * GetIamPolicyRequest request =
+ * GetIamPolicyRequest.newBuilder()
+ * .setResource(
+ * EntityTypeName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]", "[ENTITY_TYPE]")
+ * .toString())
+ * .setOptions(GetPolicyOptions.newBuilder().build())
+ * .build();
+ * ApiFuture future = datasetServiceClient.getIamPolicyCallable().futureCall(request);
+ * // Do something.
+ * Policy response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable getIamPolicyCallable() {
+ return stub.getIamPolicyCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Returns permissions that a caller has on the specified resource. If theresource does not exist,
+ * this will return an empty set ofpermissions, not a `NOT_FOUND` error.
+ *
+ * Note: This operation is designed to be used for buildingpermission-aware UIs and
+ * command-line tools, not for authorizationchecking. This operation may "fail open" without
+ * warning.
+ *
+ *
Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
+ * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
+ * TestIamPermissionsRequest request =
+ * TestIamPermissionsRequest.newBuilder()
+ * .setResource(
+ * EntityTypeName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]", "[ENTITY_TYPE]")
+ * .toString())
+ * .addAllPermissions(new ArrayList())
+ * .build();
+ * TestIamPermissionsResponse response = datasetServiceClient.testIamPermissions(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 TestIamPermissionsResponse testIamPermissions(TestIamPermissionsRequest request) {
+ return testIamPermissionsCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Returns permissions that a caller has on the specified resource. If theresource does not exist,
+ * this will return an empty set ofpermissions, not a `NOT_FOUND` error.
+ *
+ * Note: This operation is designed to be used for buildingpermission-aware UIs and
+ * command-line tools, not for authorizationchecking. This operation may "fail open" without
+ * warning.
+ *
+ *
Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
+ * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) {
+ * TestIamPermissionsRequest request =
+ * TestIamPermissionsRequest.newBuilder()
+ * .setResource(
+ * EntityTypeName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]", "[ENTITY_TYPE]")
+ * .toString())
+ * .addAllPermissions(new ArrayList())
+ * .build();
+ * ApiFuture future =
+ * datasetServiceClient.testIamPermissionsCallable().futureCall(request);
+ * // Do something.
+ * TestIamPermissionsResponse response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable
+ testIamPermissionsCallable() {
+ return stub.testIamPermissionsCallable();
+ }
+
@Override
public final void close() {
stub.close();
@@ -1640,4 +2068,80 @@ protected ListAnnotationsFixedSizeCollection createCollection(
return new ListAnnotationsFixedSizeCollection(pages, collectionSize);
}
}
+
+ public static class ListLocationsPagedResponse
+ extends AbstractPagedListResponse<
+ ListLocationsRequest,
+ ListLocationsResponse,
+ Location,
+ ListLocationsPage,
+ ListLocationsFixedSizeCollection> {
+
+ public static ApiFuture createAsync(
+ PageContext context,
+ ApiFuture futureResponse) {
+ ApiFuture futurePage =
+ ListLocationsPage.createEmptyPage().createPageAsync(context, futureResponse);
+ return ApiFutures.transform(
+ futurePage,
+ input -> new ListLocationsPagedResponse(input),
+ MoreExecutors.directExecutor());
+ }
+
+ private ListLocationsPagedResponse(ListLocationsPage page) {
+ super(page, ListLocationsFixedSizeCollection.createEmptyCollection());
+ }
+ }
+
+ public static class ListLocationsPage
+ extends AbstractPage<
+ ListLocationsRequest, ListLocationsResponse, Location, ListLocationsPage> {
+
+ private ListLocationsPage(
+ PageContext context,
+ ListLocationsResponse response) {
+ super(context, response);
+ }
+
+ private static ListLocationsPage createEmptyPage() {
+ return new ListLocationsPage(null, null);
+ }
+
+ @Override
+ protected ListLocationsPage createPage(
+ PageContext context,
+ ListLocationsResponse response) {
+ return new ListLocationsPage(context, response);
+ }
+
+ @Override
+ public ApiFuture createPageAsync(
+ PageContext context,
+ ApiFuture futureResponse) {
+ return super.createPageAsync(context, futureResponse);
+ }
+ }
+
+ public static class ListLocationsFixedSizeCollection
+ extends AbstractFixedSizeCollection<
+ ListLocationsRequest,
+ ListLocationsResponse,
+ Location,
+ ListLocationsPage,
+ ListLocationsFixedSizeCollection> {
+
+ private ListLocationsFixedSizeCollection(List pages, int collectionSize) {
+ super(pages, collectionSize);
+ }
+
+ private static ListLocationsFixedSizeCollection createEmptyCollection() {
+ return new ListLocationsFixedSizeCollection(null, 0);
+ }
+
+ @Override
+ protected ListLocationsFixedSizeCollection createCollection(
+ List pages, int collectionSize) {
+ return new ListLocationsFixedSizeCollection(pages, collectionSize);
+ }
+ }
}
diff --git a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/DatasetServiceSettings.java b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/DatasetServiceSettings.java
index 3956f654b..6c5eb24b8 100644
--- a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/DatasetServiceSettings.java
+++ b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/DatasetServiceSettings.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2021 Google LLC
+ * Copyright 2022 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -19,6 +19,7 @@
import static com.google.cloud.aiplatform.v1.DatasetServiceClient.ListAnnotationsPagedResponse;
import static com.google.cloud.aiplatform.v1.DatasetServiceClient.ListDataItemsPagedResponse;
import static com.google.cloud.aiplatform.v1.DatasetServiceClient.ListDatasetsPagedResponse;
+import static com.google.cloud.aiplatform.v1.DatasetServiceClient.ListLocationsPagedResponse;
import com.google.api.core.ApiFunction;
import com.google.api.core.BetaApi;
@@ -33,6 +34,15 @@
import com.google.api.gax.rpc.TransportChannelProvider;
import com.google.api.gax.rpc.UnaryCallSettings;
import com.google.cloud.aiplatform.v1.stub.DatasetServiceStubSettings;
+import com.google.cloud.location.GetLocationRequest;
+import com.google.cloud.location.ListLocationsRequest;
+import com.google.cloud.location.ListLocationsResponse;
+import com.google.cloud.location.Location;
+import com.google.iam.v1.GetIamPolicyRequest;
+import com.google.iam.v1.Policy;
+import com.google.iam.v1.SetIamPolicyRequest;
+import com.google.iam.v1.TestIamPermissionsRequest;
+import com.google.iam.v1.TestIamPermissionsResponse;
import com.google.longrunning.Operation;
import com.google.protobuf.Empty;
import java.io.IOException;
@@ -57,6 +67,8 @@
* For example, to set the total timeout of getDataset to 30 seconds:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* DatasetServiceSettings.Builder datasetServiceSettingsBuilder =
* DatasetServiceSettings.newBuilder();
* datasetServiceSettingsBuilder
@@ -152,6 +164,33 @@ public UnaryCallSettings getAnnotation
return ((DatasetServiceStubSettings) getStubSettings()).listAnnotationsSettings();
}
+ /** Returns the object with the settings used for calls to listLocations. */
+ public PagedCallSettings
+ listLocationsSettings() {
+ return ((DatasetServiceStubSettings) getStubSettings()).listLocationsSettings();
+ }
+
+ /** Returns the object with the settings used for calls to getLocation. */
+ public UnaryCallSettings getLocationSettings() {
+ return ((DatasetServiceStubSettings) getStubSettings()).getLocationSettings();
+ }
+
+ /** Returns the object with the settings used for calls to setIamPolicy. */
+ public UnaryCallSettings setIamPolicySettings() {
+ return ((DatasetServiceStubSettings) getStubSettings()).setIamPolicySettings();
+ }
+
+ /** Returns the object with the settings used for calls to getIamPolicy. */
+ public UnaryCallSettings getIamPolicySettings() {
+ return ((DatasetServiceStubSettings) getStubSettings()).getIamPolicySettings();
+ }
+
+ /** Returns the object with the settings used for calls to testIamPermissions. */
+ public UnaryCallSettings
+ testIamPermissionsSettings() {
+ return ((DatasetServiceStubSettings) getStubSettings()).testIamPermissionsSettings();
+ }
+
public static final DatasetServiceSettings create(DatasetServiceStubSettings stub)
throws IOException {
return new DatasetServiceSettings.Builder(stub.toBuilder()).build();
@@ -333,6 +372,34 @@ public UnaryCallSettings.Builder exportDataSetting
return getStubSettingsBuilder().listAnnotationsSettings();
}
+ /** Returns the builder for the settings used for calls to listLocations. */
+ public PagedCallSettings.Builder<
+ ListLocationsRequest, ListLocationsResponse, ListLocationsPagedResponse>
+ listLocationsSettings() {
+ return getStubSettingsBuilder().listLocationsSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to getLocation. */
+ public UnaryCallSettings.Builder getLocationSettings() {
+ return getStubSettingsBuilder().getLocationSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to setIamPolicy. */
+ public UnaryCallSettings.Builder setIamPolicySettings() {
+ return getStubSettingsBuilder().setIamPolicySettings();
+ }
+
+ /** Returns the builder for the settings used for calls to getIamPolicy. */
+ public UnaryCallSettings.Builder getIamPolicySettings() {
+ return getStubSettingsBuilder().getIamPolicySettings();
+ }
+
+ /** Returns the builder for the settings used for calls to testIamPermissions. */
+ public UnaryCallSettings.Builder
+ testIamPermissionsSettings() {
+ return getStubSettingsBuilder().testIamPermissionsSettings();
+ }
+
@Override
public DatasetServiceSettings build() throws IOException {
return new DatasetServiceSettings(this);
diff --git a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/EndpointServiceClient.java b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/EndpointServiceClient.java
index e04b99c99..28ba86eed 100644
--- a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/EndpointServiceClient.java
+++ b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/EndpointServiceClient.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2021 Google LLC
+ * Copyright 2022 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -18,7 +18,6 @@
import com.google.api.core.ApiFuture;
import com.google.api.core.ApiFutures;
-import com.google.api.core.BetaApi;
import com.google.api.gax.core.BackgroundResource;
import com.google.api.gax.longrunning.OperationFuture;
import com.google.api.gax.paging.AbstractFixedSizeCollection;
@@ -29,7 +28,16 @@
import com.google.api.gax.rpc.UnaryCallable;
import com.google.cloud.aiplatform.v1.stub.EndpointServiceStub;
import com.google.cloud.aiplatform.v1.stub.EndpointServiceStubSettings;
+import com.google.cloud.location.GetLocationRequest;
+import com.google.cloud.location.ListLocationsRequest;
+import com.google.cloud.location.ListLocationsResponse;
+import com.google.cloud.location.Location;
import com.google.common.util.concurrent.MoreExecutors;
+import com.google.iam.v1.GetIamPolicyRequest;
+import com.google.iam.v1.Policy;
+import com.google.iam.v1.SetIamPolicyRequest;
+import com.google.iam.v1.TestIamPermissionsRequest;
+import com.google.iam.v1.TestIamPermissionsResponse;
import com.google.longrunning.Operation;
import com.google.longrunning.OperationsClient;
import com.google.protobuf.Empty;
@@ -48,6 +56,8 @@
* calls that map to API methods. Sample code to get started:
*
* {@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
* EndpointName name = EndpointName.of("[PROJECT]", "[LOCATION]", "[ENDPOINT]");
* Endpoint response = endpointServiceClient.getEndpoint(name);
@@ -84,6 +94,8 @@
* To customize credentials:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* EndpointServiceSettings endpointServiceSettings =
* EndpointServiceSettings.newBuilder()
* .setCredentialsProvider(FixedCredentialsProvider.create(myCredentials))
@@ -95,6 +107,8 @@
* To customize the endpoint:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* EndpointServiceSettings endpointServiceSettings =
* EndpointServiceSettings.newBuilder().setEndpoint(myEndpoint).build();
* EndpointServiceClient endpointServiceClient =
@@ -127,7 +141,6 @@ public static final EndpointServiceClient create(EndpointServiceSettings setting
* Constructs an instance of EndpointServiceClient, using the given stub for making calls. This is
* for advanced usage - prefer using create(EndpointServiceSettings).
*/
- @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public static final EndpointServiceClient create(EndpointServiceStub stub) {
return new EndpointServiceClient(stub);
}
@@ -143,7 +156,6 @@ protected EndpointServiceClient(EndpointServiceSettings settings) throws IOExcep
this.operationsClient = OperationsClient.create(this.stub.getOperationsStub());
}
- @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
protected EndpointServiceClient(EndpointServiceStub stub) {
this.settings = null;
this.stub = stub;
@@ -154,7 +166,6 @@ public final EndpointServiceSettings getSettings() {
return settings;
}
- @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public EndpointServiceStub getStub() {
return stub;
}
@@ -174,6 +185,8 @@ public final OperationsClient getOperationsClient() {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
* LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
* Endpoint endpoint = Endpoint.newBuilder().build();
@@ -203,6 +216,8 @@ public final OperationFuture createEn
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
* String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
* Endpoint endpoint = Endpoint.newBuilder().build();
@@ -229,6 +244,8 @@ public final OperationFuture createEn
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
* LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
* Endpoint endpoint = Endpoint.newBuilder().build();
@@ -268,6 +285,8 @@ public final OperationFuture createEn
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
* String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
* Endpoint endpoint = Endpoint.newBuilder().build();
@@ -307,6 +326,8 @@ public final OperationFuture createEn
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
* CreateEndpointRequest request =
* CreateEndpointRequest.newBuilder()
@@ -333,6 +354,8 @@ public final OperationFuture createEn
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
* CreateEndpointRequest request =
* CreateEndpointRequest.newBuilder()
@@ -359,6 +382,8 @@ public final OperationFuture createEn
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
* CreateEndpointRequest request =
* CreateEndpointRequest.newBuilder()
@@ -384,6 +409,8 @@ public final UnaryCallable createEndpointCalla
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
* EndpointName name = EndpointName.of("[PROJECT]", "[LOCATION]", "[ENDPOINT]");
* Endpoint response = endpointServiceClient.getEndpoint(name);
@@ -407,6 +434,8 @@ public final Endpoint getEndpoint(EndpointName name) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
* String name = EndpointName.of("[PROJECT]", "[LOCATION]", "[ENDPOINT]").toString();
* Endpoint response = endpointServiceClient.getEndpoint(name);
@@ -429,6 +458,8 @@ public final Endpoint getEndpoint(String name) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
* GetEndpointRequest request =
* GetEndpointRequest.newBuilder()
@@ -452,6 +483,8 @@ public final Endpoint getEndpoint(GetEndpointRequest request) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
* GetEndpointRequest request =
* GetEndpointRequest.newBuilder()
@@ -474,6 +507,8 @@ public final UnaryCallable getEndpointCallable() {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
* LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
* for (Endpoint element : endpointServiceClient.listEndpoints(parent).iterateAll()) {
@@ -501,6 +536,8 @@ public final ListEndpointsPagedResponse listEndpoints(LocationName parent) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
* String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
* for (Endpoint element : endpointServiceClient.listEndpoints(parent).iterateAll()) {
@@ -525,6 +562,8 @@ public final ListEndpointsPagedResponse listEndpoints(String parent) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
* ListEndpointsRequest request =
* ListEndpointsRequest.newBuilder()
@@ -555,6 +594,8 @@ public final ListEndpointsPagedResponse listEndpoints(ListEndpointsRequest reque
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
* ListEndpointsRequest request =
* ListEndpointsRequest.newBuilder()
@@ -586,6 +627,8 @@ public final ListEndpointsPagedResponse listEndpoints(ListEndpointsRequest reque
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
* ListEndpointsRequest request =
* ListEndpointsRequest.newBuilder()
@@ -599,7 +642,7 @@ public final ListEndpointsPagedResponse listEndpoints(ListEndpointsRequest reque
* while (true) {
* ListEndpointsResponse response =
* endpointServiceClient.listEndpointsCallable().call(request);
- * for (Endpoint element : response.getResponsesList()) {
+ * for (Endpoint element : response.getEndpointsList()) {
* // doThingsWith(element);
* }
* String nextPageToken = response.getNextPageToken();
@@ -623,6 +666,8 @@ public final UnaryCallable listEndp
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
* Endpoint endpoint = Endpoint.newBuilder().build();
* FieldMask updateMask = FieldMask.newBuilder().build();
@@ -648,6 +693,8 @@ public final Endpoint updateEndpoint(Endpoint endpoint, FieldMask updateMask) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
* UpdateEndpointRequest request =
* UpdateEndpointRequest.newBuilder()
@@ -672,6 +719,8 @@ public final Endpoint updateEndpoint(UpdateEndpointRequest request) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
* UpdateEndpointRequest request =
* UpdateEndpointRequest.newBuilder()
@@ -696,6 +745,8 @@ public final UnaryCallable updateEndpointCallab
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
* EndpointName name = EndpointName.of("[PROJECT]", "[LOCATION]", "[ENDPOINT]");
* endpointServiceClient.deleteEndpointAsync(name).get();
@@ -720,6 +771,8 @@ public final OperationFuture deleteEndpointAsync
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
* String name = EndpointName.of("[PROJECT]", "[LOCATION]", "[ENDPOINT]").toString();
* endpointServiceClient.deleteEndpointAsync(name).get();
@@ -742,6 +795,8 @@ public final OperationFuture deleteEndpointAsync
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
* DeleteEndpointRequest request =
* DeleteEndpointRequest.newBuilder()
@@ -766,6 +821,8 @@ public final OperationFuture deleteEndpointAsync
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
* DeleteEndpointRequest request =
* DeleteEndpointRequest.newBuilder()
@@ -790,6 +847,8 @@ public final OperationFuture deleteEndpointAsync
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
* DeleteEndpointRequest request =
* DeleteEndpointRequest.newBuilder()
@@ -813,6 +872,8 @@ public final UnaryCallable deleteEndpointCalla
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
* EndpointName endpoint = EndpointName.of("[PROJECT]", "[LOCATION]", "[ENDPOINT]");
* DeployedModel deployedModel = DeployedModel.newBuilder().build();
@@ -857,6 +918,8 @@ public final OperationFuture
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
* String endpoint = EndpointName.of("[PROJECT]", "[LOCATION]", "[ENDPOINT]").toString();
* DeployedModel deployedModel = DeployedModel.newBuilder().build();
@@ -901,6 +964,8 @@ public final OperationFuture
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
* DeployModelRequest request =
* DeployModelRequest.newBuilder()
@@ -927,6 +992,8 @@ public final OperationFuture
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
* DeployModelRequest request =
* DeployModelRequest.newBuilder()
@@ -954,6 +1021,8 @@ public final OperationFuture
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
* DeployModelRequest request =
* DeployModelRequest.newBuilder()
@@ -979,6 +1048,8 @@ public final UnaryCallable deployModelCallable()
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
* EndpointName endpoint = EndpointName.of("[PROJECT]", "[LOCATION]", "[ENDPOINT]");
* String deployedModelId = "deployedModelId-1817547906";
@@ -1020,6 +1091,8 @@ public final UnaryCallable deployModelCallable()
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
* String endpoint = EndpointName.of("[PROJECT]", "[LOCATION]", "[ENDPOINT]").toString();
* String deployedModelId = "deployedModelId-1817547906";
@@ -1061,6 +1134,8 @@ public final UnaryCallable deployModelCallable()
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
* UndeployModelRequest request =
* UndeployModelRequest.newBuilder()
@@ -1088,6 +1163,8 @@ public final UnaryCallable deployModelCallable()
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
* UndeployModelRequest request =
* UndeployModelRequest.newBuilder()
@@ -1116,6 +1193,8 @@ public final UnaryCallable deployModelCallable()
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
* UndeployModelRequest request =
* UndeployModelRequest.newBuilder()
@@ -1134,6 +1213,332 @@ public final UnaryCallable undeployModelCallabl
return stub.undeployModelCallable();
}
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists information about the supported locations for this service.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
+ * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
+ * ListLocationsRequest request =
+ * ListLocationsRequest.newBuilder()
+ * .setName("name3373707")
+ * .setFilter("filter-1274492040")
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .build();
+ * for (Location element : endpointServiceClient.listLocations(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 ListLocationsPagedResponse listLocations(ListLocationsRequest request) {
+ return listLocationsPagedCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists information about the supported locations for this service.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
+ * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
+ * ListLocationsRequest request =
+ * ListLocationsRequest.newBuilder()
+ * .setName("name3373707")
+ * .setFilter("filter-1274492040")
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .build();
+ * ApiFuture future =
+ * endpointServiceClient.listLocationsPagedCallable().futureCall(request);
+ * // Do something.
+ * for (Location element : future.get().iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ * }
+ */
+ public final UnaryCallable
+ listLocationsPagedCallable() {
+ return stub.listLocationsPagedCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists information about the supported locations for this service.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
+ * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
+ * ListLocationsRequest request =
+ * ListLocationsRequest.newBuilder()
+ * .setName("name3373707")
+ * .setFilter("filter-1274492040")
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .build();
+ * while (true) {
+ * ListLocationsResponse response =
+ * endpointServiceClient.listLocationsCallable().call(request);
+ * for (Location element : response.getLocationsList()) {
+ * // doThingsWith(element);
+ * }
+ * String nextPageToken = response.getNextPageToken();
+ * if (!Strings.isNullOrEmpty(nextPageToken)) {
+ * request = request.toBuilder().setPageToken(nextPageToken).build();
+ * } else {
+ * break;
+ * }
+ * }
+ * }
+ * }
+ */
+ public final UnaryCallable listLocationsCallable() {
+ return stub.listLocationsCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Gets information about a location.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
+ * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
+ * GetLocationRequest request = GetLocationRequest.newBuilder().setName("name3373707").build();
+ * Location response = endpointServiceClient.getLocation(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 Location getLocation(GetLocationRequest request) {
+ return getLocationCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Gets information about a location.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
+ * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
+ * GetLocationRequest request = GetLocationRequest.newBuilder().setName("name3373707").build();
+ * ApiFuture future = endpointServiceClient.getLocationCallable().futureCall(request);
+ * // Do something.
+ * Location response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable getLocationCallable() {
+ return stub.getLocationCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Sets the access control policy on the specified resource. Replacesany existing policy.
+ *
+ * Can return `NOT_FOUND`, `INVALID_ARGUMENT`, and `PERMISSION_DENIED`errors.
+ *
+ *
Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
+ * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
+ * SetIamPolicyRequest request =
+ * SetIamPolicyRequest.newBuilder()
+ * .setResource(
+ * EntityTypeName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]", "[ENTITY_TYPE]")
+ * .toString())
+ * .setPolicy(Policy.newBuilder().build())
+ * .setUpdateMask(FieldMask.newBuilder().build())
+ * .build();
+ * Policy response = endpointServiceClient.setIamPolicy(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 Policy setIamPolicy(SetIamPolicyRequest request) {
+ return setIamPolicyCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Sets the access control policy on the specified resource. Replacesany existing policy.
+ *
+ * Can return `NOT_FOUND`, `INVALID_ARGUMENT`, and `PERMISSION_DENIED`errors.
+ *
+ *
Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
+ * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
+ * SetIamPolicyRequest request =
+ * SetIamPolicyRequest.newBuilder()
+ * .setResource(
+ * EntityTypeName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]", "[ENTITY_TYPE]")
+ * .toString())
+ * .setPolicy(Policy.newBuilder().build())
+ * .setUpdateMask(FieldMask.newBuilder().build())
+ * .build();
+ * ApiFuture future = endpointServiceClient.setIamPolicyCallable().futureCall(request);
+ * // Do something.
+ * Policy response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable setIamPolicyCallable() {
+ return stub.setIamPolicyCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Gets the access control policy for a resource. Returns an empty policyif the resource exists
+ * and does not have a policy set.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
+ * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
+ * GetIamPolicyRequest request =
+ * GetIamPolicyRequest.newBuilder()
+ * .setResource(
+ * EntityTypeName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]", "[ENTITY_TYPE]")
+ * .toString())
+ * .setOptions(GetPolicyOptions.newBuilder().build())
+ * .build();
+ * Policy response = endpointServiceClient.getIamPolicy(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 Policy getIamPolicy(GetIamPolicyRequest request) {
+ return getIamPolicyCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Gets the access control policy for a resource. Returns an empty policyif the resource exists
+ * and does not have a policy set.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
+ * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
+ * GetIamPolicyRequest request =
+ * GetIamPolicyRequest.newBuilder()
+ * .setResource(
+ * EntityTypeName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]", "[ENTITY_TYPE]")
+ * .toString())
+ * .setOptions(GetPolicyOptions.newBuilder().build())
+ * .build();
+ * ApiFuture future = endpointServiceClient.getIamPolicyCallable().futureCall(request);
+ * // Do something.
+ * Policy response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable getIamPolicyCallable() {
+ return stub.getIamPolicyCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Returns permissions that a caller has on the specified resource. If theresource does not exist,
+ * this will return an empty set ofpermissions, not a `NOT_FOUND` error.
+ *
+ * Note: This operation is designed to be used for buildingpermission-aware UIs and
+ * command-line tools, not for authorizationchecking. This operation may "fail open" without
+ * warning.
+ *
+ *
Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
+ * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
+ * TestIamPermissionsRequest request =
+ * TestIamPermissionsRequest.newBuilder()
+ * .setResource(
+ * EntityTypeName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]", "[ENTITY_TYPE]")
+ * .toString())
+ * .addAllPermissions(new ArrayList())
+ * .build();
+ * TestIamPermissionsResponse response = endpointServiceClient.testIamPermissions(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 TestIamPermissionsResponse testIamPermissions(TestIamPermissionsRequest request) {
+ return testIamPermissionsCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Returns permissions that a caller has on the specified resource. If theresource does not exist,
+ * this will return an empty set ofpermissions, not a `NOT_FOUND` error.
+ *
+ * Note: This operation is designed to be used for buildingpermission-aware UIs and
+ * command-line tools, not for authorizationchecking. This operation may "fail open" without
+ * warning.
+ *
+ *
Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
+ * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) {
+ * TestIamPermissionsRequest request =
+ * TestIamPermissionsRequest.newBuilder()
+ * .setResource(
+ * EntityTypeName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]", "[ENTITY_TYPE]")
+ * .toString())
+ * .addAllPermissions(new ArrayList())
+ * .build();
+ * ApiFuture future =
+ * endpointServiceClient.testIamPermissionsCallable().futureCall(request);
+ * // Do something.
+ * TestIamPermissionsResponse response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable
+ testIamPermissionsCallable() {
+ return stub.testIamPermissionsCallable();
+ }
+
@Override
public final void close() {
stub.close();
@@ -1239,4 +1644,80 @@ protected ListEndpointsFixedSizeCollection createCollection(
return new ListEndpointsFixedSizeCollection(pages, collectionSize);
}
}
+
+ public static class ListLocationsPagedResponse
+ extends AbstractPagedListResponse<
+ ListLocationsRequest,
+ ListLocationsResponse,
+ Location,
+ ListLocationsPage,
+ ListLocationsFixedSizeCollection> {
+
+ public static ApiFuture createAsync(
+ PageContext context,
+ ApiFuture futureResponse) {
+ ApiFuture futurePage =
+ ListLocationsPage.createEmptyPage().createPageAsync(context, futureResponse);
+ return ApiFutures.transform(
+ futurePage,
+ input -> new ListLocationsPagedResponse(input),
+ MoreExecutors.directExecutor());
+ }
+
+ private ListLocationsPagedResponse(ListLocationsPage page) {
+ super(page, ListLocationsFixedSizeCollection.createEmptyCollection());
+ }
+ }
+
+ public static class ListLocationsPage
+ extends AbstractPage<
+ ListLocationsRequest, ListLocationsResponse, Location, ListLocationsPage> {
+
+ private ListLocationsPage(
+ PageContext context,
+ ListLocationsResponse response) {
+ super(context, response);
+ }
+
+ private static ListLocationsPage createEmptyPage() {
+ return new ListLocationsPage(null, null);
+ }
+
+ @Override
+ protected ListLocationsPage createPage(
+ PageContext context,
+ ListLocationsResponse response) {
+ return new ListLocationsPage(context, response);
+ }
+
+ @Override
+ public ApiFuture createPageAsync(
+ PageContext context,
+ ApiFuture futureResponse) {
+ return super.createPageAsync(context, futureResponse);
+ }
+ }
+
+ public static class ListLocationsFixedSizeCollection
+ extends AbstractFixedSizeCollection<
+ ListLocationsRequest,
+ ListLocationsResponse,
+ Location,
+ ListLocationsPage,
+ ListLocationsFixedSizeCollection> {
+
+ private ListLocationsFixedSizeCollection(List pages, int collectionSize) {
+ super(pages, collectionSize);
+ }
+
+ private static ListLocationsFixedSizeCollection createEmptyCollection() {
+ return new ListLocationsFixedSizeCollection(null, 0);
+ }
+
+ @Override
+ protected ListLocationsFixedSizeCollection createCollection(
+ List pages, int collectionSize) {
+ return new ListLocationsFixedSizeCollection(pages, collectionSize);
+ }
+ }
}
diff --git a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/EndpointServiceSettings.java b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/EndpointServiceSettings.java
index eca80dba7..3862dc143 100644
--- a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/EndpointServiceSettings.java
+++ b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/EndpointServiceSettings.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2021 Google LLC
+ * Copyright 2022 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -17,6 +17,7 @@
package com.google.cloud.aiplatform.v1;
import static com.google.cloud.aiplatform.v1.EndpointServiceClient.ListEndpointsPagedResponse;
+import static com.google.cloud.aiplatform.v1.EndpointServiceClient.ListLocationsPagedResponse;
import com.google.api.core.ApiFunction;
import com.google.api.core.BetaApi;
@@ -31,6 +32,15 @@
import com.google.api.gax.rpc.TransportChannelProvider;
import com.google.api.gax.rpc.UnaryCallSettings;
import com.google.cloud.aiplatform.v1.stub.EndpointServiceStubSettings;
+import com.google.cloud.location.GetLocationRequest;
+import com.google.cloud.location.ListLocationsRequest;
+import com.google.cloud.location.ListLocationsResponse;
+import com.google.cloud.location.Location;
+import com.google.iam.v1.GetIamPolicyRequest;
+import com.google.iam.v1.Policy;
+import com.google.iam.v1.SetIamPolicyRequest;
+import com.google.iam.v1.TestIamPermissionsRequest;
+import com.google.iam.v1.TestIamPermissionsResponse;
import com.google.longrunning.Operation;
import com.google.protobuf.Empty;
import java.io.IOException;
@@ -55,6 +65,8 @@
* For example, to set the total timeout of getEndpoint to 30 seconds:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* EndpointServiceSettings.Builder endpointServiceSettingsBuilder =
* EndpointServiceSettings.newBuilder();
* endpointServiceSettingsBuilder
@@ -134,6 +146,33 @@ public UnaryCallSettings undeployModelSettings(
return ((EndpointServiceStubSettings) getStubSettings()).undeployModelOperationSettings();
}
+ /** Returns the object with the settings used for calls to listLocations. */
+ public PagedCallSettings
+ listLocationsSettings() {
+ return ((EndpointServiceStubSettings) getStubSettings()).listLocationsSettings();
+ }
+
+ /** Returns the object with the settings used for calls to getLocation. */
+ public UnaryCallSettings getLocationSettings() {
+ return ((EndpointServiceStubSettings) getStubSettings()).getLocationSettings();
+ }
+
+ /** Returns the object with the settings used for calls to setIamPolicy. */
+ public UnaryCallSettings setIamPolicySettings() {
+ return ((EndpointServiceStubSettings) getStubSettings()).setIamPolicySettings();
+ }
+
+ /** Returns the object with the settings used for calls to getIamPolicy. */
+ public UnaryCallSettings getIamPolicySettings() {
+ return ((EndpointServiceStubSettings) getStubSettings()).getIamPolicySettings();
+ }
+
+ /** Returns the object with the settings used for calls to testIamPermissions. */
+ public UnaryCallSettings
+ testIamPermissionsSettings() {
+ return ((EndpointServiceStubSettings) getStubSettings()).testIamPermissionsSettings();
+ }
+
public static final EndpointServiceSettings create(EndpointServiceStubSettings stub)
throws IOException {
return new EndpointServiceSettings.Builder(stub.toBuilder()).build();
@@ -295,6 +334,34 @@ public UnaryCallSettings.Builder undeployModelS
return getStubSettingsBuilder().undeployModelOperationSettings();
}
+ /** Returns the builder for the settings used for calls to listLocations. */
+ public PagedCallSettings.Builder<
+ ListLocationsRequest, ListLocationsResponse, ListLocationsPagedResponse>
+ listLocationsSettings() {
+ return getStubSettingsBuilder().listLocationsSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to getLocation. */
+ public UnaryCallSettings.Builder getLocationSettings() {
+ return getStubSettingsBuilder().getLocationSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to setIamPolicy. */
+ public UnaryCallSettings.Builder setIamPolicySettings() {
+ return getStubSettingsBuilder().setIamPolicySettings();
+ }
+
+ /** Returns the builder for the settings used for calls to getIamPolicy. */
+ public UnaryCallSettings.Builder getIamPolicySettings() {
+ return getStubSettingsBuilder().getIamPolicySettings();
+ }
+
+ /** Returns the builder for the settings used for calls to testIamPermissions. */
+ public UnaryCallSettings.Builder
+ testIamPermissionsSettings() {
+ return getStubSettingsBuilder().testIamPermissionsSettings();
+ }
+
@Override
public EndpointServiceSettings build() throws IOException {
return new EndpointServiceSettings(this);
diff --git a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/FeaturestoreOnlineServingServiceClient.java b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/FeaturestoreOnlineServingServiceClient.java
index 010101145..2084dcd03 100644
--- a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/FeaturestoreOnlineServingServiceClient.java
+++ b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/FeaturestoreOnlineServingServiceClient.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2021 Google LLC
+ * Copyright 2022 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -16,13 +16,29 @@
package com.google.cloud.aiplatform.v1;
-import com.google.api.core.BetaApi;
+import com.google.api.core.ApiFuture;
+import com.google.api.core.ApiFutures;
import com.google.api.gax.core.BackgroundResource;
+import com.google.api.gax.paging.AbstractFixedSizeCollection;
+import com.google.api.gax.paging.AbstractPage;
+import com.google.api.gax.paging.AbstractPagedListResponse;
+import com.google.api.gax.rpc.PageContext;
import com.google.api.gax.rpc.ServerStreamingCallable;
import com.google.api.gax.rpc.UnaryCallable;
import com.google.cloud.aiplatform.v1.stub.FeaturestoreOnlineServingServiceStub;
import com.google.cloud.aiplatform.v1.stub.FeaturestoreOnlineServingServiceStubSettings;
+import com.google.cloud.location.GetLocationRequest;
+import com.google.cloud.location.ListLocationsRequest;
+import com.google.cloud.location.ListLocationsResponse;
+import com.google.cloud.location.Location;
+import com.google.common.util.concurrent.MoreExecutors;
+import com.google.iam.v1.GetIamPolicyRequest;
+import com.google.iam.v1.Policy;
+import com.google.iam.v1.SetIamPolicyRequest;
+import com.google.iam.v1.TestIamPermissionsRequest;
+import com.google.iam.v1.TestIamPermissionsResponse;
import java.io.IOException;
+import java.util.List;
import java.util.concurrent.TimeUnit;
import javax.annotation.Generated;
@@ -34,6 +50,8 @@
* calls that map to API methods. Sample code to get started:
*
* {@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (FeaturestoreOnlineServingServiceClient featurestoreOnlineServingServiceClient =
* FeaturestoreOnlineServingServiceClient.create()) {
* EntityTypeName entityType =
@@ -73,6 +91,8 @@
* To customize credentials:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* FeaturestoreOnlineServingServiceSettings featurestoreOnlineServingServiceSettings =
* FeaturestoreOnlineServingServiceSettings.newBuilder()
* .setCredentialsProvider(FixedCredentialsProvider.create(myCredentials))
@@ -84,6 +104,8 @@
* To customize the endpoint:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* FeaturestoreOnlineServingServiceSettings featurestoreOnlineServingServiceSettings =
* FeaturestoreOnlineServingServiceSettings.newBuilder().setEndpoint(myEndpoint).build();
* FeaturestoreOnlineServingServiceClient featurestoreOnlineServingServiceClient =
@@ -117,7 +139,6 @@ public static final FeaturestoreOnlineServingServiceClient create(
* making calls. This is for advanced usage - prefer using
* create(FeaturestoreOnlineServingServiceSettings).
*/
- @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public static final FeaturestoreOnlineServingServiceClient create(
FeaturestoreOnlineServingServiceStub stub) {
return new FeaturestoreOnlineServingServiceClient(stub);
@@ -135,7 +156,6 @@ protected FeaturestoreOnlineServingServiceClient(
((FeaturestoreOnlineServingServiceStubSettings) settings.getStubSettings()).createStub();
}
- @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
protected FeaturestoreOnlineServingServiceClient(FeaturestoreOnlineServingServiceStub stub) {
this.settings = null;
this.stub = stub;
@@ -145,7 +165,6 @@ public final FeaturestoreOnlineServingServiceSettings getSettings() {
return settings;
}
- @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public FeaturestoreOnlineServingServiceStub getStub() {
return stub;
}
@@ -158,6 +177,8 @@ public FeaturestoreOnlineServingServiceStub getStub() {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (FeaturestoreOnlineServingServiceClient featurestoreOnlineServingServiceClient =
* FeaturestoreOnlineServingServiceClient.create()) {
* EntityTypeName entityType =
@@ -190,6 +211,8 @@ public final ReadFeatureValuesResponse readFeatureValues(EntityTypeName entityTy
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (FeaturestoreOnlineServingServiceClient featurestoreOnlineServingServiceClient =
* FeaturestoreOnlineServingServiceClient.create()) {
* String entityType =
@@ -221,6 +244,8 @@ public final ReadFeatureValuesResponse readFeatureValues(String entityType) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (FeaturestoreOnlineServingServiceClient featurestoreOnlineServingServiceClient =
* FeaturestoreOnlineServingServiceClient.create()) {
* ReadFeatureValuesRequest request =
@@ -251,6 +276,8 @@ public final ReadFeatureValuesResponse readFeatureValues(ReadFeatureValuesReques
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (FeaturestoreOnlineServingServiceClient featurestoreOnlineServingServiceClient =
* FeaturestoreOnlineServingServiceClient.create()) {
* ReadFeatureValuesRequest request =
@@ -281,6 +308,8 @@ public final ReadFeatureValuesResponse readFeatureValues(ReadFeatureValuesReques
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (FeaturestoreOnlineServingServiceClient featurestoreOnlineServingServiceClient =
* FeaturestoreOnlineServingServiceClient.create()) {
* StreamingReadFeatureValuesRequest request =
@@ -304,6 +333,348 @@ public final ReadFeatureValuesResponse readFeatureValues(ReadFeatureValuesReques
return stub.streamingReadFeatureValuesCallable();
}
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists information about the supported locations for this service.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
+ * try (FeaturestoreOnlineServingServiceClient featurestoreOnlineServingServiceClient =
+ * FeaturestoreOnlineServingServiceClient.create()) {
+ * ListLocationsRequest request =
+ * ListLocationsRequest.newBuilder()
+ * .setName("name3373707")
+ * .setFilter("filter-1274492040")
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .build();
+ * for (Location element :
+ * featurestoreOnlineServingServiceClient.listLocations(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 ListLocationsPagedResponse listLocations(ListLocationsRequest request) {
+ return listLocationsPagedCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists information about the supported locations for this service.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
+ * try (FeaturestoreOnlineServingServiceClient featurestoreOnlineServingServiceClient =
+ * FeaturestoreOnlineServingServiceClient.create()) {
+ * ListLocationsRequest request =
+ * ListLocationsRequest.newBuilder()
+ * .setName("name3373707")
+ * .setFilter("filter-1274492040")
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .build();
+ * ApiFuture future =
+ * featurestoreOnlineServingServiceClient.listLocationsPagedCallable().futureCall(request);
+ * // Do something.
+ * for (Location element : future.get().iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ * }
+ */
+ public final UnaryCallable
+ listLocationsPagedCallable() {
+ return stub.listLocationsPagedCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists information about the supported locations for this service.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
+ * try (FeaturestoreOnlineServingServiceClient featurestoreOnlineServingServiceClient =
+ * FeaturestoreOnlineServingServiceClient.create()) {
+ * ListLocationsRequest request =
+ * ListLocationsRequest.newBuilder()
+ * .setName("name3373707")
+ * .setFilter("filter-1274492040")
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .build();
+ * while (true) {
+ * ListLocationsResponse response =
+ * featurestoreOnlineServingServiceClient.listLocationsCallable().call(request);
+ * for (Location element : response.getLocationsList()) {
+ * // doThingsWith(element);
+ * }
+ * String nextPageToken = response.getNextPageToken();
+ * if (!Strings.isNullOrEmpty(nextPageToken)) {
+ * request = request.toBuilder().setPageToken(nextPageToken).build();
+ * } else {
+ * break;
+ * }
+ * }
+ * }
+ * }
+ */
+ public final UnaryCallable listLocationsCallable() {
+ return stub.listLocationsCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Gets information about a location.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
+ * try (FeaturestoreOnlineServingServiceClient featurestoreOnlineServingServiceClient =
+ * FeaturestoreOnlineServingServiceClient.create()) {
+ * GetLocationRequest request = GetLocationRequest.newBuilder().setName("name3373707").build();
+ * Location response = featurestoreOnlineServingServiceClient.getLocation(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 Location getLocation(GetLocationRequest request) {
+ return getLocationCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Gets information about a location.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
+ * try (FeaturestoreOnlineServingServiceClient featurestoreOnlineServingServiceClient =
+ * FeaturestoreOnlineServingServiceClient.create()) {
+ * GetLocationRequest request = GetLocationRequest.newBuilder().setName("name3373707").build();
+ * ApiFuture future =
+ * featurestoreOnlineServingServiceClient.getLocationCallable().futureCall(request);
+ * // Do something.
+ * Location response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable getLocationCallable() {
+ return stub.getLocationCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Sets the access control policy on the specified resource. Replacesany existing policy.
+ *
+ * Can return `NOT_FOUND`, `INVALID_ARGUMENT`, and `PERMISSION_DENIED`errors.
+ *
+ *
Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
+ * try (FeaturestoreOnlineServingServiceClient featurestoreOnlineServingServiceClient =
+ * FeaturestoreOnlineServingServiceClient.create()) {
+ * SetIamPolicyRequest request =
+ * SetIamPolicyRequest.newBuilder()
+ * .setResource(
+ * EntityTypeName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]", "[ENTITY_TYPE]")
+ * .toString())
+ * .setPolicy(Policy.newBuilder().build())
+ * .setUpdateMask(FieldMask.newBuilder().build())
+ * .build();
+ * Policy response = featurestoreOnlineServingServiceClient.setIamPolicy(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 Policy setIamPolicy(SetIamPolicyRequest request) {
+ return setIamPolicyCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Sets the access control policy on the specified resource. Replacesany existing policy.
+ *
+ * Can return `NOT_FOUND`, `INVALID_ARGUMENT`, and `PERMISSION_DENIED`errors.
+ *
+ *
Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
+ * try (FeaturestoreOnlineServingServiceClient featurestoreOnlineServingServiceClient =
+ * FeaturestoreOnlineServingServiceClient.create()) {
+ * SetIamPolicyRequest request =
+ * SetIamPolicyRequest.newBuilder()
+ * .setResource(
+ * EntityTypeName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]", "[ENTITY_TYPE]")
+ * .toString())
+ * .setPolicy(Policy.newBuilder().build())
+ * .setUpdateMask(FieldMask.newBuilder().build())
+ * .build();
+ * ApiFuture future =
+ * featurestoreOnlineServingServiceClient.setIamPolicyCallable().futureCall(request);
+ * // Do something.
+ * Policy response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable setIamPolicyCallable() {
+ return stub.setIamPolicyCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Gets the access control policy for a resource. Returns an empty policyif the resource exists
+ * and does not have a policy set.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
+ * try (FeaturestoreOnlineServingServiceClient featurestoreOnlineServingServiceClient =
+ * FeaturestoreOnlineServingServiceClient.create()) {
+ * GetIamPolicyRequest request =
+ * GetIamPolicyRequest.newBuilder()
+ * .setResource(
+ * EntityTypeName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]", "[ENTITY_TYPE]")
+ * .toString())
+ * .setOptions(GetPolicyOptions.newBuilder().build())
+ * .build();
+ * Policy response = featurestoreOnlineServingServiceClient.getIamPolicy(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 Policy getIamPolicy(GetIamPolicyRequest request) {
+ return getIamPolicyCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Gets the access control policy for a resource. Returns an empty policyif the resource exists
+ * and does not have a policy set.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
+ * try (FeaturestoreOnlineServingServiceClient featurestoreOnlineServingServiceClient =
+ * FeaturestoreOnlineServingServiceClient.create()) {
+ * GetIamPolicyRequest request =
+ * GetIamPolicyRequest.newBuilder()
+ * .setResource(
+ * EntityTypeName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]", "[ENTITY_TYPE]")
+ * .toString())
+ * .setOptions(GetPolicyOptions.newBuilder().build())
+ * .build();
+ * ApiFuture future =
+ * featurestoreOnlineServingServiceClient.getIamPolicyCallable().futureCall(request);
+ * // Do something.
+ * Policy response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable getIamPolicyCallable() {
+ return stub.getIamPolicyCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Returns permissions that a caller has on the specified resource. If theresource does not exist,
+ * this will return an empty set ofpermissions, not a `NOT_FOUND` error.
+ *
+ * Note: This operation is designed to be used for buildingpermission-aware UIs and
+ * command-line tools, not for authorizationchecking. This operation may "fail open" without
+ * warning.
+ *
+ *
Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
+ * try (FeaturestoreOnlineServingServiceClient featurestoreOnlineServingServiceClient =
+ * FeaturestoreOnlineServingServiceClient.create()) {
+ * TestIamPermissionsRequest request =
+ * TestIamPermissionsRequest.newBuilder()
+ * .setResource(
+ * EntityTypeName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]", "[ENTITY_TYPE]")
+ * .toString())
+ * .addAllPermissions(new ArrayList())
+ * .build();
+ * TestIamPermissionsResponse response =
+ * featurestoreOnlineServingServiceClient.testIamPermissions(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 TestIamPermissionsResponse testIamPermissions(TestIamPermissionsRequest request) {
+ return testIamPermissionsCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Returns permissions that a caller has on the specified resource. If theresource does not exist,
+ * this will return an empty set ofpermissions, not a `NOT_FOUND` error.
+ *
+ * Note: This operation is designed to be used for buildingpermission-aware UIs and
+ * command-line tools, not for authorizationchecking. This operation may "fail open" without
+ * warning.
+ *
+ *
Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
+ * try (FeaturestoreOnlineServingServiceClient featurestoreOnlineServingServiceClient =
+ * FeaturestoreOnlineServingServiceClient.create()) {
+ * TestIamPermissionsRequest request =
+ * TestIamPermissionsRequest.newBuilder()
+ * .setResource(
+ * EntityTypeName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]", "[ENTITY_TYPE]")
+ * .toString())
+ * .addAllPermissions(new ArrayList())
+ * .build();
+ * ApiFuture future =
+ * featurestoreOnlineServingServiceClient.testIamPermissionsCallable().futureCall(request);
+ * // Do something.
+ * TestIamPermissionsResponse response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable
+ testIamPermissionsCallable() {
+ return stub.testIamPermissionsCallable();
+ }
+
@Override
public final void close() {
stub.close();
@@ -333,4 +704,80 @@ public void shutdownNow() {
public boolean awaitTermination(long duration, TimeUnit unit) throws InterruptedException {
return stub.awaitTermination(duration, unit);
}
+
+ public static class ListLocationsPagedResponse
+ extends AbstractPagedListResponse<
+ ListLocationsRequest,
+ ListLocationsResponse,
+ Location,
+ ListLocationsPage,
+ ListLocationsFixedSizeCollection> {
+
+ public static ApiFuture createAsync(
+ PageContext context,
+ ApiFuture futureResponse) {
+ ApiFuture futurePage =
+ ListLocationsPage.createEmptyPage().createPageAsync(context, futureResponse);
+ return ApiFutures.transform(
+ futurePage,
+ input -> new ListLocationsPagedResponse(input),
+ MoreExecutors.directExecutor());
+ }
+
+ private ListLocationsPagedResponse(ListLocationsPage page) {
+ super(page, ListLocationsFixedSizeCollection.createEmptyCollection());
+ }
+ }
+
+ public static class ListLocationsPage
+ extends AbstractPage<
+ ListLocationsRequest, ListLocationsResponse, Location, ListLocationsPage> {
+
+ private ListLocationsPage(
+ PageContext context,
+ ListLocationsResponse response) {
+ super(context, response);
+ }
+
+ private static ListLocationsPage createEmptyPage() {
+ return new ListLocationsPage(null, null);
+ }
+
+ @Override
+ protected ListLocationsPage createPage(
+ PageContext context,
+ ListLocationsResponse response) {
+ return new ListLocationsPage(context, response);
+ }
+
+ @Override
+ public ApiFuture createPageAsync(
+ PageContext context,
+ ApiFuture futureResponse) {
+ return super.createPageAsync(context, futureResponse);
+ }
+ }
+
+ public static class ListLocationsFixedSizeCollection
+ extends AbstractFixedSizeCollection<
+ ListLocationsRequest,
+ ListLocationsResponse,
+ Location,
+ ListLocationsPage,
+ ListLocationsFixedSizeCollection> {
+
+ private ListLocationsFixedSizeCollection(List pages, int collectionSize) {
+ super(pages, collectionSize);
+ }
+
+ private static ListLocationsFixedSizeCollection createEmptyCollection() {
+ return new ListLocationsFixedSizeCollection(null, 0);
+ }
+
+ @Override
+ protected ListLocationsFixedSizeCollection createCollection(
+ List pages, int collectionSize) {
+ return new ListLocationsFixedSizeCollection(pages, collectionSize);
+ }
+ }
}
diff --git a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/FeaturestoreOnlineServingServiceSettings.java b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/FeaturestoreOnlineServingServiceSettings.java
index ea99fa565..5b481fb4d 100644
--- a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/FeaturestoreOnlineServingServiceSettings.java
+++ b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/FeaturestoreOnlineServingServiceSettings.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2021 Google LLC
+ * Copyright 2022 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -16,6 +16,8 @@
package com.google.cloud.aiplatform.v1;
+import static com.google.cloud.aiplatform.v1.FeaturestoreOnlineServingServiceClient.ListLocationsPagedResponse;
+
import com.google.api.core.ApiFunction;
import com.google.api.core.BetaApi;
import com.google.api.gax.core.GoogleCredentialsProvider;
@@ -24,10 +26,20 @@
import com.google.api.gax.rpc.ApiClientHeaderProvider;
import com.google.api.gax.rpc.ClientContext;
import com.google.api.gax.rpc.ClientSettings;
+import com.google.api.gax.rpc.PagedCallSettings;
import com.google.api.gax.rpc.ServerStreamingCallSettings;
import com.google.api.gax.rpc.TransportChannelProvider;
import com.google.api.gax.rpc.UnaryCallSettings;
import com.google.cloud.aiplatform.v1.stub.FeaturestoreOnlineServingServiceStubSettings;
+import com.google.cloud.location.GetLocationRequest;
+import com.google.cloud.location.ListLocationsRequest;
+import com.google.cloud.location.ListLocationsResponse;
+import com.google.cloud.location.Location;
+import com.google.iam.v1.GetIamPolicyRequest;
+import com.google.iam.v1.Policy;
+import com.google.iam.v1.SetIamPolicyRequest;
+import com.google.iam.v1.TestIamPermissionsRequest;
+import com.google.iam.v1.TestIamPermissionsResponse;
import java.io.IOException;
import java.util.List;
import javax.annotation.Generated;
@@ -50,6 +62,8 @@
* For example, to set the total timeout of readFeatureValues to 30 seconds:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* FeaturestoreOnlineServingServiceSettings.Builder
* featurestoreOnlineServingServiceSettingsBuilder =
* FeaturestoreOnlineServingServiceSettings.newBuilder();
@@ -84,6 +98,37 @@ public class FeaturestoreOnlineServingServiceSettings
.streamingReadFeatureValuesSettings();
}
+ /** Returns the object with the settings used for calls to listLocations. */
+ public PagedCallSettings
+ listLocationsSettings() {
+ return ((FeaturestoreOnlineServingServiceStubSettings) getStubSettings())
+ .listLocationsSettings();
+ }
+
+ /** Returns the object with the settings used for calls to getLocation. */
+ public UnaryCallSettings getLocationSettings() {
+ return ((FeaturestoreOnlineServingServiceStubSettings) getStubSettings()).getLocationSettings();
+ }
+
+ /** Returns the object with the settings used for calls to setIamPolicy. */
+ public UnaryCallSettings setIamPolicySettings() {
+ return ((FeaturestoreOnlineServingServiceStubSettings) getStubSettings())
+ .setIamPolicySettings();
+ }
+
+ /** Returns the object with the settings used for calls to getIamPolicy. */
+ public UnaryCallSettings getIamPolicySettings() {
+ return ((FeaturestoreOnlineServingServiceStubSettings) getStubSettings())
+ .getIamPolicySettings();
+ }
+
+ /** Returns the object with the settings used for calls to testIamPermissions. */
+ public UnaryCallSettings
+ testIamPermissionsSettings() {
+ return ((FeaturestoreOnlineServingServiceStubSettings) getStubSettings())
+ .testIamPermissionsSettings();
+ }
+
public static final FeaturestoreOnlineServingServiceSettings create(
FeaturestoreOnlineServingServiceStubSettings stub) throws IOException {
return new FeaturestoreOnlineServingServiceSettings.Builder(stub.toBuilder()).build();
@@ -195,6 +240,34 @@ public Builder applyToAllUnaryMethods(
return getStubSettingsBuilder().streamingReadFeatureValuesSettings();
}
+ /** Returns the builder for the settings used for calls to listLocations. */
+ public PagedCallSettings.Builder<
+ ListLocationsRequest, ListLocationsResponse, ListLocationsPagedResponse>
+ listLocationsSettings() {
+ return getStubSettingsBuilder().listLocationsSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to getLocation. */
+ public UnaryCallSettings.Builder getLocationSettings() {
+ return getStubSettingsBuilder().getLocationSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to setIamPolicy. */
+ public UnaryCallSettings.Builder setIamPolicySettings() {
+ return getStubSettingsBuilder().setIamPolicySettings();
+ }
+
+ /** Returns the builder for the settings used for calls to getIamPolicy. */
+ public UnaryCallSettings.Builder getIamPolicySettings() {
+ return getStubSettingsBuilder().getIamPolicySettings();
+ }
+
+ /** Returns the builder for the settings used for calls to testIamPermissions. */
+ public UnaryCallSettings.Builder
+ testIamPermissionsSettings() {
+ return getStubSettingsBuilder().testIamPermissionsSettings();
+ }
+
@Override
public FeaturestoreOnlineServingServiceSettings build() throws IOException {
return new FeaturestoreOnlineServingServiceSettings(this);
diff --git a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/FeaturestoreServiceClient.java b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/FeaturestoreServiceClient.java
index dbbc953db..d542ddc6c 100644
--- a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/FeaturestoreServiceClient.java
+++ b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/FeaturestoreServiceClient.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2021 Google LLC
+ * Copyright 2022 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -18,7 +18,6 @@
import com.google.api.core.ApiFuture;
import com.google.api.core.ApiFutures;
-import com.google.api.core.BetaApi;
import com.google.api.gax.core.BackgroundResource;
import com.google.api.gax.longrunning.OperationFuture;
import com.google.api.gax.paging.AbstractFixedSizeCollection;
@@ -29,7 +28,16 @@
import com.google.api.gax.rpc.UnaryCallable;
import com.google.cloud.aiplatform.v1.stub.FeaturestoreServiceStub;
import com.google.cloud.aiplatform.v1.stub.FeaturestoreServiceStubSettings;
+import com.google.cloud.location.GetLocationRequest;
+import com.google.cloud.location.ListLocationsRequest;
+import com.google.cloud.location.ListLocationsResponse;
+import com.google.cloud.location.Location;
import com.google.common.util.concurrent.MoreExecutors;
+import com.google.iam.v1.GetIamPolicyRequest;
+import com.google.iam.v1.Policy;
+import com.google.iam.v1.SetIamPolicyRequest;
+import com.google.iam.v1.TestIamPermissionsRequest;
+import com.google.iam.v1.TestIamPermissionsResponse;
import com.google.longrunning.Operation;
import com.google.longrunning.OperationsClient;
import com.google.protobuf.Empty;
@@ -47,6 +55,8 @@
* calls that map to API methods. Sample code to get started:
*
* {@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (FeaturestoreServiceClient featurestoreServiceClient = FeaturestoreServiceClient.create()) {
* FeaturestoreName name = FeaturestoreName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]");
* Featurestore response = featurestoreServiceClient.getFeaturestore(name);
@@ -83,6 +93,8 @@
* To customize credentials:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* FeaturestoreServiceSettings featurestoreServiceSettings =
* FeaturestoreServiceSettings.newBuilder()
* .setCredentialsProvider(FixedCredentialsProvider.create(myCredentials))
@@ -94,6 +106,8 @@
* To customize the endpoint:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* FeaturestoreServiceSettings featurestoreServiceSettings =
* FeaturestoreServiceSettings.newBuilder().setEndpoint(myEndpoint).build();
* FeaturestoreServiceClient featurestoreServiceClient =
@@ -126,7 +140,6 @@ public static final FeaturestoreServiceClient create(FeaturestoreServiceSettings
* Constructs an instance of FeaturestoreServiceClient, using the given stub for making calls.
* This is for advanced usage - prefer using create(FeaturestoreServiceSettings).
*/
- @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public static final FeaturestoreServiceClient create(FeaturestoreServiceStub stub) {
return new FeaturestoreServiceClient(stub);
}
@@ -142,7 +155,6 @@ protected FeaturestoreServiceClient(FeaturestoreServiceSettings settings) throws
this.operationsClient = OperationsClient.create(this.stub.getOperationsStub());
}
- @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
protected FeaturestoreServiceClient(FeaturestoreServiceStub stub) {
this.settings = null;
this.stub = stub;
@@ -153,7 +165,6 @@ public final FeaturestoreServiceSettings getSettings() {
return settings;
}
- @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public FeaturestoreServiceStub getStub() {
return stub;
}
@@ -173,6 +184,8 @@ public final OperationsClient getOperationsClient() {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (FeaturestoreServiceClient featurestoreServiceClient = FeaturestoreServiceClient.create()) {
* LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
* Featurestore featurestore = Featurestore.newBuilder().build();
@@ -203,6 +216,8 @@ public final OperationsClient getOperationsClient() {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (FeaturestoreServiceClient featurestoreServiceClient = FeaturestoreServiceClient.create()) {
* String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
* Featurestore featurestore = Featurestore.newBuilder().build();
@@ -233,6 +248,8 @@ public final OperationsClient getOperationsClient() {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (FeaturestoreServiceClient featurestoreServiceClient = FeaturestoreServiceClient.create()) {
* LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
* Featurestore featurestore = Featurestore.newBuilder().build();
@@ -273,6 +290,8 @@ public final OperationsClient getOperationsClient() {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (FeaturestoreServiceClient featurestoreServiceClient = FeaturestoreServiceClient.create()) {
* String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
* Featurestore featurestore = Featurestore.newBuilder().build();
@@ -312,6 +331,8 @@ public final OperationsClient getOperationsClient() {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (FeaturestoreServiceClient featurestoreServiceClient = FeaturestoreServiceClient.create()) {
* CreateFeaturestoreRequest request =
* CreateFeaturestoreRequest.newBuilder()
@@ -338,6 +359,8 @@ public final OperationsClient getOperationsClient() {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (FeaturestoreServiceClient featurestoreServiceClient = FeaturestoreServiceClient.create()) {
* CreateFeaturestoreRequest request =
* CreateFeaturestoreRequest.newBuilder()
@@ -365,6 +388,8 @@ public final OperationsClient getOperationsClient() {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (FeaturestoreServiceClient featurestoreServiceClient = FeaturestoreServiceClient.create()) {
* CreateFeaturestoreRequest request =
* CreateFeaturestoreRequest.newBuilder()
@@ -390,6 +415,8 @@ public final UnaryCallable