You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by ma...@apache.org on 2013/11/27 05:50:14 UTC
[8/8] git commit: Modified AverageHeathRequest execution plan to find
unreachable ports
Modified AverageHeathRequest execution plan to find unreachable ports
Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/d2365339
Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/d2365339
Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/d2365339
Branch: refs/heads/master
Commit: d2365339d734b66737460f84eaf437e930973273
Parents: 2fbefde
Author: Manula Thantriwatte <ma...@apache.org>
Authored: Wed Nov 27 10:17:14 2013 +0530
Committer: Manula Thantriwatte <ma...@apache.org>
Committed: Wed Nov 27 10:17:14 2013 +0530
----------------------------------------------------------------------
extensions/cep/artifacts/executionplans/AverageHeathRequest.xml | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/d2365339/extensions/cep/artifacts/executionplans/AverageHeathRequest.xml
----------------------------------------------------------------------
diff --git a/extensions/cep/artifacts/executionplans/AverageHeathRequest.xml b/extensions/cep/artifacts/executionplans/AverageHeathRequest.xml
index cfb9166..b40f3bb 100644
--- a/extensions/cep/artifacts/executionplans/AverageHeathRequest.xml
+++ b/extensions/cep/artifacts/executionplans/AverageHeathRequest.xml
@@ -10,6 +10,7 @@
<stream as="healthStats1" name="stratos.agent.health.stats" version="1.0.0"/>
</importedStreams>
<queryExpressions><![CDATA[define partition healthStats1Partition by member_id;
+ from healthStats1 [health_description == 'port_not_open'] select member_id insert into fault_message partition by healthStats1Partition;
from healthStats1 [health_description == 'load_average'] #window.timeBatch(1 min) select member_id, avg(value) as average_load_average insert into average_load_average_stats partition by healthStats1Partition;
from healthStats1 [health_description == 'memory_consumption'] #window.timeBatch(1 min) select member_id, avg(value) as average_memory_consumption insert into average_memory_consumption_stats partition by healthStats1Partition;]]></queryExpressions>
<exportedStreams>
@@ -17,5 +18,7 @@
valueOf="average_load_average_stats" version="1.0.0"/>
<stream name="average_memory_consumption_stats" passthroughFlow="disable"
valueOf="average_memory_consumption_stats" version="1.0.0"/>
+ <stream name="fault_message" passthroughFlow="disable"
+ valueOf="fault_message" version="1.0.0"/>
</exportedStreams>
</executionPlan>