This is an automated email from the ASF dual-hosted git repository. jihao pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git
The following commit(s) were added to refs/heads/master by this push: new 881de3f [TE] add anomaly classification to detection anomalies endpoint (#3789) 881de3f is described below commit 881de3f6299512943b8b42900754f4b0a871eec8 Author: Jihao Zhang <jihzh...@linkedin.com> AuthorDate: Mon Feb 4 10:58:10 2019 -0800 [TE] add anomaly classification to detection anomalies endpoint (#3789) Add anomaly classification info to detection anomalies endpoint. For precision/recall calculation. --- .../org/apache/pinot/thirdeye/detection/DetectionResource.java | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/detection/DetectionResource.java b/thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/detection/DetectionResource.java index f151d8d..e76e7eb 100644 --- a/thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/detection/DetectionResource.java +++ b/thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/detection/DetectionResource.java @@ -34,6 +34,7 @@ import java.util.List; import java.util.Map; import java.util.Set; import java.util.concurrent.TimeUnit; +import java.util.stream.Collectors; import javax.ws.rs.DefaultValue; import javax.ws.rs.GET; import javax.ws.rs.POST; @@ -47,6 +48,8 @@ import org.apache.commons.collections.MapUtils; import org.apache.pinot.thirdeye.api.Constants; import org.apache.pinot.thirdeye.constant.AnomalyFeedbackType; import org.apache.pinot.thirdeye.constant.AnomalyResultSource; +import org.apache.pinot.thirdeye.dashboard.resources.v2.ResourceUtils; +import org.apache.pinot.thirdeye.dashboard.resources.v2.rootcause.AnomalyEventFormatter; import org.apache.pinot.thirdeye.datalayer.bao.DatasetConfigManager; import org.apache.pinot.thirdeye.datalayer.bao.DetectionAlertConfigManager; import org.apache.pinot.thirdeye.datalayer.bao.DetectionConfigManager; @@ -162,7 +165,12 @@ public class DetectionResource { Predicate.EQ("detectionConfigId", detectionConfigId), Predicate.LT("startTime", endTime), Predicate.GT("endTime", startTime))); - return Response.ok(anomalies).build(); + List result = anomalies.stream().map(anomaly -> { + Map<String, Object> anomalyResult = OBJECT_MAPPER.convertValue(anomaly, Map.class); + anomalyResult.put(AnomalyEventFormatter.ATTR_STATUS_CLASSIFICATION, ResourceUtils.getStatusClassification(anomaly).toString()); + return anomalyResult; + }).collect(Collectors.toList()); + return Response.ok(result).build(); } @POST --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org For additional commands, e-mail: commits-h...@pinot.apache.org