From caf12950939a46a9450bdd04fc4bf363e567e1f7 Mon Sep 17 00:00:00 2001
From: Hao Chen <hao@apache.org>
Date: Mon, 20 Feb 2017 17:33:38 +0800
Subject: [PATCH] Support /streams?siteId={SITE_ID} API

---
 .../service/metadata/resource/MetadataResource.java   | 11 +++++++++--
 1 file changed, 9 insertions(+), 2 deletions(-)

diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-metadata-parent/alert-metadata-service/src/main/java/org/apache/eagle/service/metadata/resource/MetadataResource.java b/eagle-core/eagle-alert-parent/eagle-alert/alert-metadata-parent/alert-metadata-service/src/main/java/org/apache/eagle/service/metadata/resource/MetadataResource.java
index 2d30e8524e..36a3044b75 100644
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-metadata-parent/alert-metadata-service/src/main/java/org/apache/eagle/service/metadata/resource/MetadataResource.java
+++ b/eagle-core/eagle-alert-parent/eagle-alert/alert-metadata-parent/alert-metadata-service/src/main/java/org/apache/eagle/service/metadata/resource/MetadataResource.java
@@ -42,6 +42,7 @@
 import java.util.LinkedList;
 import java.util.List;
 import java.util.Map;
+import java.util.stream.Collectors;
 
 /**
  * @since Apr 11, 2016.
@@ -129,8 +130,14 @@ public List<OpResult> removeClusters(List<String> clusterIds) {
 
     @Path("/streams")
     @GET
-    public List<StreamDefinition> listStreams() {
-        return dao.listStreams();
+    public List<StreamDefinition> listStreams(@QueryParam("siteId") String siteId) {
+        if (siteId == null) {
+            return dao.listStreams();
+        } else {
+            return dao.listStreams().stream()
+                .filter((streamDefinition -> streamDefinition.getSiteId().equals(siteId)))
+                .collect(Collectors.toList());
+        }
     }
 
     @Path("/streams")