This is an automated email from the ASF dual-hosted git repository.
apucher 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 f079714 [TE] subscription groups endpoint (#3616)
f079714 is described below
commit f079714c3ffa1246f38dc6b83e15e29e15a28bb8
Author: Jihao Zhang <[email protected]>
AuthorDate: Thu Dec 13 16:33:21 2018 -0800
[TE] subscription groups endpoint (#3616)
---
.../linkedin/thirdeye/detection/DetectionResource.java | 16 ++++++++++++++++
1 file changed, 16 insertions(+)
diff --git
a/thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/DetectionResource.java
b/thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/DetectionResource.java
index 2647e9f..9a6376a 100644
---
a/thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/DetectionResource.java
+++
b/thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/DetectionResource.java
@@ -46,9 +46,11 @@ import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
import java.util.Date;
+import java.util.HashSet;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
+import java.util.Set;
import java.util.concurrent.TimeUnit;
import javax.ws.rs.DefaultValue;
import javax.ws.rs.GET;
@@ -122,6 +124,20 @@ public class DetectionResource {
return Response.ok(config).build();
}
+ @Path("/subscription-groups/{id}")
+ @GET
+ @ApiOperation("get a list of detection alert configs for a given detection
config id")
+ public Response getSubscriptionGroups(@ApiParam("the detection config id")
@PathParam("id") long id){
+ List<DetectionAlertConfigDTO> detectionAlertConfigDTOs =
this.detectionAlertConfigDAO.findAll();
+ Set<DetectionAlertConfigDTO> subscriptionGroupAlertDTOs = new HashSet<>();
+ for (DetectionAlertConfigDTO alertConfigDTO : detectionAlertConfigDTOs){
+ if (alertConfigDTO.getVectorClocks().containsKey(id)){
+ subscriptionGroupAlertDTOs.add(alertConfigDTO);
+ }
+ }
+ return Response.ok(new ArrayList<>(subscriptionGroupAlertDTOs)).build();
+ }
+
@POST
@Path("/preview")
public Response detectionPreview(
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
