You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by im...@apache.org on 2015/05/17 18:52:25 UTC
stratos git commit: Updating AverageRequestsInflightEventFormatter
according to RIF parameters
Repository: stratos
Updated Branches:
refs/heads/master f602f3ef3 -> 1f712366f
Updating AverageRequestsInflightEventFormatter according to RIF parameters
Project: http://git-wip-us.apache.org/repos/asf/stratos/repo
Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/1f712366
Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/1f712366
Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/1f712366
Branch: refs/heads/master
Commit: 1f712366fc24fbad6918a98602ca10a70fb0310d
Parents: f602f3e
Author: Imesh Gunaratne <im...@apache.org>
Authored: Sun May 17 22:22:11 2015 +0530
Committer: Imesh Gunaratne <im...@apache.org>
Committed: Sun May 17 22:22:11 2015 +0530
----------------------------------------------------------------------
.../eventformatters/AverageInFlightRequestsEventFormatter.xml | 2 +-
.../cep/artifacts/executionplans/AverageInFlightRequestsFinder.xml | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/stratos/blob/1f712366/extensions/cep/artifacts/eventformatters/AverageInFlightRequestsEventFormatter.xml
----------------------------------------------------------------------
diff --git a/extensions/cep/artifacts/eventformatters/AverageInFlightRequestsEventFormatter.xml b/extensions/cep/artifacts/eventformatters/AverageInFlightRequestsEventFormatter.xml
index 26c8f66..5955866 100644
--- a/extensions/cep/artifacts/eventformatters/AverageInFlightRequestsEventFormatter.xml
+++ b/extensions/cep/artifacts/eventformatters/AverageInFlightRequestsEventFormatter.xml
@@ -24,7 +24,7 @@
statistics="disable" trace="enable" xmlns="http://wso2.org/carbon/eventformatter">
<from streamName="average_in_flight_requests" version="1.0.0"/>
<mapping customMapping="enable" type="json">
- <inline>{"org.apache.stratos.messaging.event.health.stat.AverageRequestsInFlightEvent":{"message":{"clusterId":"{{cluster_id}}","clusterInstanceId":"{{cluster_instance_id}}","networkPartitionId":"{{network_partition_id}}","activeInstances":"{{instances_count}}","value":"{{count}}" ,"servedCount":"{{served_count}}"}}}</inline>
+ <inline>{"org.apache.stratos.messaging.event.health.stat.AverageRequestsInFlightEvent":{"message":{"clusterId":"{{cluster_id}}","clusterInstanceId":"{{cluster_instance_id}}","networkPartitionId":"{{network_partition_id}}","value":"{{count}}"}}}</inline>
</mapping>
<to eventAdaptorName="JMSOutputAdaptor" eventAdaptorType="jms">
<property name="transport.jms.Destination">summarized-health-stats</property>
http://git-wip-us.apache.org/repos/asf/stratos/blob/1f712366/extensions/cep/artifacts/executionplans/AverageInFlightRequestsFinder.xml
----------------------------------------------------------------------
diff --git a/extensions/cep/artifacts/executionplans/AverageInFlightRequestsFinder.xml b/extensions/cep/artifacts/executionplans/AverageInFlightRequestsFinder.xml
index 3ff8287..20b94da 100644
--- a/extensions/cep/artifacts/executionplans/AverageInFlightRequestsFinder.xml
+++ b/extensions/cep/artifacts/executionplans/AverageInFlightRequestsFinder.xml
@@ -35,7 +35,7 @@
select cluster_id, cluster_instance_id, network_partition_id, in_flight_request_count,
stratos:concat(cluster_id, '-' ,cluster_instance_id) as avg_rif_cluster_network
insert into avg_rif_concat;
- define partition avg_rif_cluster_partition by avg_rif_concat.avg_rif_cluster_network;
+ define partition avg_rif_cluster_partition by avg_rif_concat.avg_rif_cluster_network;
from avg_rif_concat#window.timeBatch(1 min)
select cluster_id, cluster_instance_id, network_partition_id, avg(in_flight_request_count) as count
insert into average_in_flight_requests