This is an automated email from the ASF dual-hosted git repository.
akshayrai09 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 33578ac [TE] recover deleted api enpoints (#5556)
33578ac is described below
commit 33578ac4edbafbfca484c0555adca235231cb489
Author: Vincent Chen <jianc...@linkedin.com>
AuthorDate: Fri Jun 12 18:08:35 2020 -0700
[TE] recover deleted api enpoints (#5556)
---
.../dashboard/resources/v2/AnomaliesResource.java | 31 ++++++++++++++++++++++
1 file changed, 31 insertions(+)
diff --git
a/thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/dashboard/resources/v2/AnomaliesResource.java
b/thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/dashboard/resources/v2/AnomaliesResource.java
index f3f1c95..51e1b43 100644
---
a/thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/dashboard/resources/v2/AnomaliesResource.java
+++
b/thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/dashboard/resources/v2/AnomaliesResource.java
@@ -196,6 +196,37 @@ public class AnomaliesResource {
return anomaliesWrapper;
}
+ /**
+ * Find anomalies by anomaly ids
+ * @param startTime
+ * @param endTime
+ * @param anomalyIdsString
+ * @return
+ * @throws Exception
+ */
+ @GET
+ @Path("search/anomalyIds/{startTime}/{endTime}/{pageNumber}")
+ public AnomaliesWrapper getAnomaliesByAnomalyIds(
+ @PathParam("startTime") Long startTime,
+ @PathParam("endTime") Long endTime,
+ @PathParam("pageNumber") int pageNumber,
+ @QueryParam("anomalyIds") String anomalyIdsString,
+ @QueryParam("searchFilters") String searchFiltersJSON,
+ @QueryParam("filterOnly") @DefaultValue("false") boolean filterOnly)
throws Exception {
+
+ String[] anomalyIds = anomalyIdsString.split(",");
+ List<MergedAnomalyResultDTO> mergedAnomalies = new ArrayList<>();
+ for (String id : anomalyIds) {
+ Long anomalyId = Long.valueOf(id);
+ MergedAnomalyResultDTO anomaly =
mergedAnomalyResultDAO.findById(anomalyId);
+ if (anomaly != null) {
+ mergedAnomalies.add(anomaly);
+ }
+ }
+ AnomaliesWrapper
+ anomaliesWrapper =
constructAnomaliesWrapperFromMergedAnomalies(mergedAnomalies,
searchFiltersJSON, pageNumber, filterOnly);
+ return anomaliesWrapper;
+ }
// ----------- HELPER FUNCTIONS
/**
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org
