Skip to content
This repository was archived by the owner on Sep 9, 2023. It is now read-only.

Commit 139a839

Browse files
feat: add monitoring_config to EntityType in aiplatform v1 entity_type.proto (#830)
* feat: add monitoring_config to EntityType in aiplatform v1 entity_type.proto feat: add disable_monitoring to Feature in aiplatform v1 feature.proto feat: add monitoring_stats_anomalies to Feature in aiplatform v1 feature.proto feat: add staleness_days to SnapshotAnalysis in aiplatform v1 featurestore_monitoring.proto feat: add import_features_analysis to FeaturestoreMonitoringConfig in aiplatform v1 featurestore_monitoring.proto feat: add numerical_threshold_config to FeaturestoreMonitoringConfig in aiplatform v1 featurestore_monitoring.proto feat: add categorical_threshold_config to FeaturestoreMonitoringConfig in aiplatform v1 featurestore_monitoring.proto feat: add objective to MonitoringStatsSpec in aiplatform v1 featurestore_service.proto feat: add disable_monitoring to Feature in aiplatform v1beta1 feature.proto feat: add monitoring_stats_anomalies to Feature in aiplatform v1beta1 feature.proto feat: add staleness_days to SnapshotAnalysis in aiplatform v1beta1 featurestore_monitoring.proto feat: add import_features_analysis to FeaturestoreMonitoringConfig in aiplatform v1beta1 featurestore_monitoring.proto feat: add numerical_threshold_config to FeaturestoreMonitoringConfig in aiplatform v1beta1 featurestore_monitoring.proto feat: add categorical_threshold_config to FeaturestoreMonitoringConfig in aiplatform v1beta1 featurestore_monitoring.proto feat: add objective to MonitoringStatsSpec in aiplatform v1beta1 featurestore_service.proto PiperOrigin-RevId: 434018027 Source-Link: googleapis/googleapis@90f38d1 Source-Link: https://github.com/googleapis/googleapis-gen/commit/f6adb410330bd52d7b539d4322e66cc4603ba34a Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiZjZhZGI0MTAzMzBiZDUyZDdiNTM5ZDQzMjJlNjZjYzQ2MDNiYTM0YSJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
1 parent f31367a commit 139a839

File tree

40 files changed

+16188
-2218
lines changed

40 files changed

+16188
-2218
lines changed

google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/FeaturestoreServiceClient.java

Lines changed: 10 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1413,7 +1413,12 @@ public final ListEntityTypesPagedResponse listEntityTypes(ListEntityTypesRequest
14131413
* overwritten. Set the update_mask to `&#42;` to override all fields.
14141414
* <p>Updatable fields:
14151415
* <p>&#42; `description` &#42; `labels` &#42; `monitoring_config.snapshot_analysis.disabled`
1416-
* &#42; `monitoring_config.snapshot_analysis.monitoring_interval`
1416+
* &#42; `monitoring_config.snapshot_analysis.monitoring_interval_days` &#42;
1417+
* `monitoring_config.snapshot_analysis.staleness_days` &#42;
1418+
* `monitoring_config.import_features_analysis.state` &#42;
1419+
* `monitoring_config.import_features_analysis.anomaly_detection_baseline` &#42;
1420+
* `monitoring_config.numerical_threshold_config.value` &#42;
1421+
* `monitoring_config.categorical_threshold_config.value`
14171422
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
14181423
*/
14191424
public final EntityType updateEntityType(EntityType entityType, FieldMask updateMask) {
@@ -2323,8 +2328,7 @@ public final UnaryCallable<ListFeaturesRequest, ListFeaturesResponse> listFeatur
23232328
* user does not provide a mask then only the non-empty fields present in the request will be
23242329
* overwritten. Set the update_mask to `&#42;` to override all fields.
23252330
* <p>Updatable fields:
2326-
* <p>&#42; `description` &#42; `labels` &#42; `monitoring_config.snapshot_analysis.disabled`
2327-
* &#42; `monitoring_config.snapshot_analysis.monitoring_interval`
2331+
* <p>&#42; `description` &#42; `labels` &#42; `disable_monitoring`
23282332
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
23292333
*/
23302334
public final Feature updateFeature(Feature feature, FieldMask updateMask) {
@@ -2632,6 +2636,7 @@ public final UnaryCallable<DeleteFeatureRequest, Operation> deleteFeatureCallabl
26322636
* .addAllFeatureSpecs(new ArrayList<ImportFeatureValuesRequest.FeatureSpec>())
26332637
* .setDisableOnlineServing(true)
26342638
* .setWorkerCount(372044046)
2639+
* .setDisableIngestionAnalysis(true)
26352640
* .build();
26362641
* ImportFeatureValuesResponse response =
26372642
* featurestoreServiceClient.importFeatureValuesAsync(request).get();
@@ -2679,6 +2684,7 @@ public final UnaryCallable<DeleteFeatureRequest, Operation> deleteFeatureCallabl
26792684
* .addAllFeatureSpecs(new ArrayList<ImportFeatureValuesRequest.FeatureSpec>())
26802685
* .setDisableOnlineServing(true)
26812686
* .setWorkerCount(372044046)
2687+
* .setDisableIngestionAnalysis(true)
26822688
* .build();
26832689
* OperationFuture<ImportFeatureValuesResponse, ImportFeatureValuesOperationMetadata> future =
26842690
* featurestoreServiceClient.importFeatureValuesOperationCallable().futureCall(request);
@@ -2728,6 +2734,7 @@ public final UnaryCallable<DeleteFeatureRequest, Operation> deleteFeatureCallabl
27282734
* .addAllFeatureSpecs(new ArrayList<ImportFeatureValuesRequest.FeatureSpec>())
27292735
* .setDisableOnlineServing(true)
27302736
* .setWorkerCount(372044046)
2737+
* .setDisableIngestionAnalysis(true)
27312738
* .build();
27322739
* ApiFuture<Operation> future =
27332740
* featurestoreServiceClient.importFeatureValuesCallable().futureCall(request);

google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1beta1/FeaturestoreServiceClient.java

Lines changed: 10 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1414,7 +1414,12 @@ public final ListEntityTypesPagedResponse listEntityTypes(ListEntityTypesRequest
14141414
* overwritten. Set the update_mask to `&#42;` to override all fields.
14151415
* <p>Updatable fields:
14161416
* <p>&#42; `description` &#42; `labels` &#42; `monitoring_config.snapshot_analysis.disabled`
1417-
* &#42; `monitoring_config.snapshot_analysis.monitoring_interval`
1417+
* &#42; `monitoring_config.snapshot_analysis.monitoring_interval_days` &#42;
1418+
* `monitoring_config.snapshot_analysis.staleness_days` &#42;
1419+
* `monitoring_config.import_features_analysis.state` &#42;
1420+
* `monitoring_config.import_features_analysis.anomaly_detection_baseline` &#42;
1421+
* `monitoring_config.numerical_threshold_config.value` &#42;
1422+
* `monitoring_config.categorical_threshold_config.value`
14181423
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
14191424
*/
14201425
public final EntityType updateEntityType(EntityType entityType, FieldMask updateMask) {
@@ -2324,8 +2329,7 @@ public final UnaryCallable<ListFeaturesRequest, ListFeaturesResponse> listFeatur
23242329
* user does not provide a mask then only the non-empty fields present in the request will be
23252330
* overwritten. Set the update_mask to `&#42;` to override all fields.
23262331
* <p>Updatable fields:
2327-
* <p>&#42; `description` &#42; `labels` &#42; `monitoring_config.snapshot_analysis.disabled`
2328-
* &#42; `monitoring_config.snapshot_analysis.monitoring_interval`
2332+
* <p>&#42; `description` &#42; `labels` &#42; `disable_monitoring`
23292333
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
23302334
*/
23312335
public final Feature updateFeature(Feature feature, FieldMask updateMask) {
@@ -2633,6 +2637,7 @@ public final UnaryCallable<DeleteFeatureRequest, Operation> deleteFeatureCallabl
26332637
* .addAllFeatureSpecs(new ArrayList<ImportFeatureValuesRequest.FeatureSpec>())
26342638
* .setDisableOnlineServing(true)
26352639
* .setWorkerCount(372044046)
2640+
* .setDisableIngestionAnalysis(true)
26362641
* .build();
26372642
* ImportFeatureValuesResponse response =
26382643
* featurestoreServiceClient.importFeatureValuesAsync(request).get();
@@ -2680,6 +2685,7 @@ public final UnaryCallable<DeleteFeatureRequest, Operation> deleteFeatureCallabl
26802685
* .addAllFeatureSpecs(new ArrayList<ImportFeatureValuesRequest.FeatureSpec>())
26812686
* .setDisableOnlineServing(true)
26822687
* .setWorkerCount(372044046)
2688+
* .setDisableIngestionAnalysis(true)
26832689
* .build();
26842690
* OperationFuture<ImportFeatureValuesResponse, ImportFeatureValuesOperationMetadata> future =
26852691
* featurestoreServiceClient.importFeatureValuesOperationCallable().futureCall(request);
@@ -2729,6 +2735,7 @@ public final UnaryCallable<DeleteFeatureRequest, Operation> deleteFeatureCallabl
27292735
* .addAllFeatureSpecs(new ArrayList<ImportFeatureValuesRequest.FeatureSpec>())
27302736
* .setDisableOnlineServing(true)
27312737
* .setWorkerCount(372044046)
2738+
* .setDisableIngestionAnalysis(true)
27322739
* .build();
27332740
* ApiFuture<Operation> future =
27342741
* featurestoreServiceClient.importFeatureValuesCallable().futureCall(request);

google-cloud-aiplatform/src/test/java/com/google/cloud/aiplatform/v1/FeaturestoreServiceClientTest.java

Lines changed: 21 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -735,6 +735,7 @@ public void createEntityTypeTest() throws Exception {
735735
.setUpdateTime(Timestamp.newBuilder().build())
736736
.putAllLabels(new HashMap<String, String>())
737737
.setEtag("etag3123477")
738+
.setMonitoringConfig(FeaturestoreMonitoringConfig.newBuilder().build())
738739
.build();
739740
Operation resultOperation =
740741
Operation.newBuilder()
@@ -791,6 +792,7 @@ public void createEntityTypeTest2() throws Exception {
791792
.setUpdateTime(Timestamp.newBuilder().build())
792793
.putAllLabels(new HashMap<String, String>())
793794
.setEtag("etag3123477")
795+
.setMonitoringConfig(FeaturestoreMonitoringConfig.newBuilder().build())
794796
.build();
795797
Operation resultOperation =
796798
Operation.newBuilder()
@@ -847,6 +849,7 @@ public void createEntityTypeTest3() throws Exception {
847849
.setUpdateTime(Timestamp.newBuilder().build())
848850
.putAllLabels(new HashMap<String, String>())
849851
.setEtag("etag3123477")
852+
.setMonitoringConfig(FeaturestoreMonitoringConfig.newBuilder().build())
850853
.build();
851854
Operation resultOperation =
852855
Operation.newBuilder()
@@ -907,6 +910,7 @@ public void createEntityTypeTest4() throws Exception {
907910
.setUpdateTime(Timestamp.newBuilder().build())
908911
.putAllLabels(new HashMap<String, String>())
909912
.setEtag("etag3123477")
913+
.setMonitoringConfig(FeaturestoreMonitoringConfig.newBuilder().build())
910914
.build();
911915
Operation resultOperation =
912916
Operation.newBuilder()
@@ -967,6 +971,7 @@ public void getEntityTypeTest() throws Exception {
967971
.setUpdateTime(Timestamp.newBuilder().build())
968972
.putAllLabels(new HashMap<String, String>())
969973
.setEtag("etag3123477")
974+
.setMonitoringConfig(FeaturestoreMonitoringConfig.newBuilder().build())
970975
.build();
971976
mockFeaturestoreService.addResponse(expectedResponse);
972977

@@ -1014,6 +1019,7 @@ public void getEntityTypeTest2() throws Exception {
10141019
.setUpdateTime(Timestamp.newBuilder().build())
10151020
.putAllLabels(new HashMap<String, String>())
10161021
.setEtag("etag3123477")
1022+
.setMonitoringConfig(FeaturestoreMonitoringConfig.newBuilder().build())
10171023
.build();
10181024
mockFeaturestoreService.addResponse(expectedResponse);
10191025

@@ -1147,6 +1153,7 @@ public void updateEntityTypeTest() throws Exception {
11471153
.setUpdateTime(Timestamp.newBuilder().build())
11481154
.putAllLabels(new HashMap<String, String>())
11491155
.setEtag("etag3123477")
1156+
.setMonitoringConfig(FeaturestoreMonitoringConfig.newBuilder().build())
11501157
.build();
11511158
mockFeaturestoreService.addResponse(expectedResponse);
11521159

@@ -1374,6 +1381,8 @@ public void createFeatureTest() throws Exception {
13741381
.setUpdateTime(Timestamp.newBuilder().build())
13751382
.putAllLabels(new HashMap<String, String>())
13761383
.setEtag("etag3123477")
1384+
.setDisableMonitoring(true)
1385+
.addAllMonitoringStatsAnomalies(new ArrayList<Feature.MonitoringStatsAnomaly>())
13771386
.build();
13781387
Operation resultOperation =
13791388
Operation.newBuilder()
@@ -1433,6 +1442,8 @@ public void createFeatureTest2() throws Exception {
14331442
.setUpdateTime(Timestamp.newBuilder().build())
14341443
.putAllLabels(new HashMap<String, String>())
14351444
.setEtag("etag3123477")
1445+
.setDisableMonitoring(true)
1446+
.addAllMonitoringStatsAnomalies(new ArrayList<Feature.MonitoringStatsAnomaly>())
14361447
.build();
14371448
Operation resultOperation =
14381449
Operation.newBuilder()
@@ -1490,6 +1501,8 @@ public void createFeatureTest3() throws Exception {
14901501
.setUpdateTime(Timestamp.newBuilder().build())
14911502
.putAllLabels(new HashMap<String, String>())
14921503
.setEtag("etag3123477")
1504+
.setDisableMonitoring(true)
1505+
.addAllMonitoringStatsAnomalies(new ArrayList<Feature.MonitoringStatsAnomaly>())
14931506
.build();
14941507
Operation resultOperation =
14951508
Operation.newBuilder()
@@ -1552,6 +1565,8 @@ public void createFeatureTest4() throws Exception {
15521565
.setUpdateTime(Timestamp.newBuilder().build())
15531566
.putAllLabels(new HashMap<String, String>())
15541567
.setEtag("etag3123477")
1568+
.setDisableMonitoring(true)
1569+
.addAllMonitoringStatsAnomalies(new ArrayList<Feature.MonitoringStatsAnomaly>())
15551570
.build();
15561571
Operation resultOperation =
15571572
Operation.newBuilder()
@@ -1710,6 +1725,8 @@ public void getFeatureTest() throws Exception {
17101725
.setUpdateTime(Timestamp.newBuilder().build())
17111726
.putAllLabels(new HashMap<String, String>())
17121727
.setEtag("etag3123477")
1728+
.setDisableMonitoring(true)
1729+
.addAllMonitoringStatsAnomalies(new ArrayList<Feature.MonitoringStatsAnomaly>())
17131730
.build();
17141731
mockFeaturestoreService.addResponse(expectedResponse);
17151732

@@ -1758,6 +1775,8 @@ public void getFeatureTest2() throws Exception {
17581775
.setUpdateTime(Timestamp.newBuilder().build())
17591776
.putAllLabels(new HashMap<String, String>())
17601777
.setEtag("etag3123477")
1778+
.setDisableMonitoring(true)
1779+
.addAllMonitoringStatsAnomalies(new ArrayList<Feature.MonitoringStatsAnomaly>())
17611780
.build();
17621781
mockFeaturestoreService.addResponse(expectedResponse);
17631782

@@ -1894,6 +1913,8 @@ public void updateFeatureTest() throws Exception {
18941913
.setUpdateTime(Timestamp.newBuilder().build())
18951914
.putAllLabels(new HashMap<String, String>())
18961915
.setEtag("etag3123477")
1916+
.setDisableMonitoring(true)
1917+
.addAllMonitoringStatsAnomalies(new ArrayList<Feature.MonitoringStatsAnomaly>())
18971918
.build();
18981919
mockFeaturestoreService.addResponse(expectedResponse);
18991920

google-cloud-aiplatform/src/test/java/com/google/cloud/aiplatform/v1beta1/FeaturestoreServiceClientTest.java

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1382,7 +1382,9 @@ public void createFeatureTest() throws Exception {
13821382
.putAllLabels(new HashMap<String, String>())
13831383
.setEtag("etag3123477")
13841384
.setMonitoringConfig(FeaturestoreMonitoringConfig.newBuilder().build())
1385+
.setDisableMonitoring(true)
13851386
.addAllMonitoringStats(new ArrayList<FeatureStatsAnomaly>())
1387+
.addAllMonitoringStatsAnomalies(new ArrayList<Feature.MonitoringStatsAnomaly>())
13861388
.build();
13871389
Operation resultOperation =
13881390
Operation.newBuilder()
@@ -1443,7 +1445,9 @@ public void createFeatureTest2() throws Exception {
14431445
.putAllLabels(new HashMap<String, String>())
14441446
.setEtag("etag3123477")
14451447
.setMonitoringConfig(FeaturestoreMonitoringConfig.newBuilder().build())
1448+
.setDisableMonitoring(true)
14461449
.addAllMonitoringStats(new ArrayList<FeatureStatsAnomaly>())
1450+
.addAllMonitoringStatsAnomalies(new ArrayList<Feature.MonitoringStatsAnomaly>())
14471451
.build();
14481452
Operation resultOperation =
14491453
Operation.newBuilder()
@@ -1502,7 +1506,9 @@ public void createFeatureTest3() throws Exception {
15021506
.putAllLabels(new HashMap<String, String>())
15031507
.setEtag("etag3123477")
15041508
.setMonitoringConfig(FeaturestoreMonitoringConfig.newBuilder().build())
1509+
.setDisableMonitoring(true)
15051510
.addAllMonitoringStats(new ArrayList<FeatureStatsAnomaly>())
1511+
.addAllMonitoringStatsAnomalies(new ArrayList<Feature.MonitoringStatsAnomaly>())
15061512
.build();
15071513
Operation resultOperation =
15081514
Operation.newBuilder()
@@ -1566,7 +1572,9 @@ public void createFeatureTest4() throws Exception {
15661572
.putAllLabels(new HashMap<String, String>())
15671573
.setEtag("etag3123477")
15681574
.setMonitoringConfig(FeaturestoreMonitoringConfig.newBuilder().build())
1575+
.setDisableMonitoring(true)
15691576
.addAllMonitoringStats(new ArrayList<FeatureStatsAnomaly>())
1577+
.addAllMonitoringStatsAnomalies(new ArrayList<Feature.MonitoringStatsAnomaly>())
15701578
.build();
15711579
Operation resultOperation =
15721580
Operation.newBuilder()
@@ -1726,7 +1734,9 @@ public void getFeatureTest() throws Exception {
17261734
.putAllLabels(new HashMap<String, String>())
17271735
.setEtag("etag3123477")
17281736
.setMonitoringConfig(FeaturestoreMonitoringConfig.newBuilder().build())
1737+
.setDisableMonitoring(true)
17291738
.addAllMonitoringStats(new ArrayList<FeatureStatsAnomaly>())
1739+
.addAllMonitoringStatsAnomalies(new ArrayList<Feature.MonitoringStatsAnomaly>())
17301740
.build();
17311741
mockFeaturestoreService.addResponse(expectedResponse);
17321742

@@ -1776,7 +1786,9 @@ public void getFeatureTest2() throws Exception {
17761786
.putAllLabels(new HashMap<String, String>())
17771787
.setEtag("etag3123477")
17781788
.setMonitoringConfig(FeaturestoreMonitoringConfig.newBuilder().build())
1789+
.setDisableMonitoring(true)
17791790
.addAllMonitoringStats(new ArrayList<FeatureStatsAnomaly>())
1791+
.addAllMonitoringStatsAnomalies(new ArrayList<Feature.MonitoringStatsAnomaly>())
17801792
.build();
17811793
mockFeaturestoreService.addResponse(expectedResponse);
17821794

@@ -1914,7 +1926,9 @@ public void updateFeatureTest() throws Exception {
19141926
.putAllLabels(new HashMap<String, String>())
19151927
.setEtag("etag3123477")
19161928
.setMonitoringConfig(FeaturestoreMonitoringConfig.newBuilder().build())
1929+
.setDisableMonitoring(true)
19171930
.addAllMonitoringStats(new ArrayList<FeatureStatsAnomaly>())
1931+
.addAllMonitoringStatsAnomalies(new ArrayList<Feature.MonitoringStatsAnomaly>())
19181932
.build();
19191933
mockFeaturestoreService.addResponse(expectedResponse);
19201934

0 commit comments

Comments
 (0)