You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by ra...@apache.org on 2015/11/03 12:44:53 UTC
[49/58] stratos git commit: Adding SystemTimeWindowProcessor
extension and introducing timestamp attribute in cep avg stats artifacts
Adding SystemTimeWindowProcessor extension and introducing timestamp attribute in cep avg stats artifacts
Project: http://git-wip-us.apache.org/repos/asf/stratos/repo
Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/01699c92
Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/01699c92
Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/01699c92
Branch: refs/heads/master
Commit: 01699c923c5cfb4a5d10128825a6f5f8e7011780
Parents: 91b9919
Author: Thanuja <th...@wso2.com>
Authored: Thu Oct 22 11:41:23 2015 +0530
Committer: Akila Perera <ra...@gmail.com>
Committed: Tue Nov 3 17:13:19 2015 +0530
----------------------------------------------------------------------
.../AverageInFlightRequestsEventFormatter.xml | 2 +-
.../AverageLoadAverageEventFormatter.xml | 2 +-
.../AverageMemoryConsumptionEventFormatter.xml | 2 +-
.../MemberAverageLoadAverageEventFormatter.xml | 2 +-
...erAverageMemoryConsumptionEventFormatter.xml | 2 +-
.../executionplans/AverageHeathRequest.xml | 10 +-
.../AverageInFlightRequestsFinder.xml | 4 +-
.../streamdefinitions/stream-manager-config.xml | 491 ++++++++++---------
.../AverageInFlightRequestsEventFormatter.xml | 2 +-
.../AverageLoadAverageEventFormatter.xml | 2 +-
.../AverageMemoryConsumptionEventFormatter.xml | 2 +-
.../MemberAverageLoadAverageEventFormatter.xml | 2 +-
...erAverageMemoryConsumptionEventFormatter.xml | 2 +-
.../executionplans/AverageHeathRequest.xml | 52 +-
.../AverageInFlightRequestsFinder.xml | 34 +-
.../streamdefinitions/stream-manager-config.xml | 489 +++++++++---------
.../extension/SystemTimeWindowProcessor.java | 48 ++
.../extension/SystemTimeWindowProcessor.java | 50 ++
.../src/main/conf/siddhi/siddhi.extension | 1 +
19 files changed, 662 insertions(+), 537 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/stratos/blob/01699c92/extensions/cep/modules/artifacts/wso2cep-3.0.0/eventformatters/AverageInFlightRequestsEventFormatter.xml
----------------------------------------------------------------------
diff --git a/extensions/cep/modules/artifacts/wso2cep-3.0.0/eventformatters/AverageInFlightRequestsEventFormatter.xml b/extensions/cep/modules/artifacts/wso2cep-3.0.0/eventformatters/AverageInFlightRequestsEventFormatter.xml
index 5955866..f812d89 100644
--- a/extensions/cep/modules/artifacts/wso2cep-3.0.0/eventformatters/AverageInFlightRequestsEventFormatter.xml
+++ b/extensions/cep/modules/artifacts/wso2cep-3.0.0/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}}","value":"{{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}}","timestamp":"{{timestamp}}"}}}</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/01699c92/extensions/cep/modules/artifacts/wso2cep-3.0.0/eventformatters/AverageLoadAverageEventFormatter.xml
----------------------------------------------------------------------
diff --git a/extensions/cep/modules/artifacts/wso2cep-3.0.0/eventformatters/AverageLoadAverageEventFormatter.xml b/extensions/cep/modules/artifacts/wso2cep-3.0.0/eventformatters/AverageLoadAverageEventFormatter.xml
index a0e2052..5ef7f07 100644
--- a/extensions/cep/modules/artifacts/wso2cep-3.0.0/eventformatters/AverageLoadAverageEventFormatter.xml
+++ b/extensions/cep/modules/artifacts/wso2cep-3.0.0/eventformatters/AverageLoadAverageEventFormatter.xml
@@ -24,7 +24,7 @@
statistics="disable" trace="enable" xmlns="http://wso2.org/carbon/eventformatter">
<from streamName="average_load_average_stats" version="1.0.0"/>
<mapping customMapping="enable" type="json">
- <inline>{"org.apache.stratos.messaging.event.health.stat.AverageLoadAverageEvent":{"message":{"clusterId":"{{cluster_id}}","clusterInstanceId":"{{cluster_instance_id}}","networkPartitionId":"{{network_partition_id}}","value":"{{average_load_average}}"}}}</inline>
+ <inline>{"org.apache.stratos.messaging.event.health.stat.AverageLoadAverageEvent":{"message":{"clusterId":"{{cluster_id}}","clusterInstanceId":"{{cluster_instance_id}}","networkPartitionId":"{{network_partition_id}}","value":"{{average_load_average}}","timestamp":"{{timestamp}}"}}}</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/01699c92/extensions/cep/modules/artifacts/wso2cep-3.0.0/eventformatters/AverageMemoryConsumptionEventFormatter.xml
----------------------------------------------------------------------
diff --git a/extensions/cep/modules/artifacts/wso2cep-3.0.0/eventformatters/AverageMemoryConsumptionEventFormatter.xml b/extensions/cep/modules/artifacts/wso2cep-3.0.0/eventformatters/AverageMemoryConsumptionEventFormatter.xml
index cbcab0a..21cba89 100644
--- a/extensions/cep/modules/artifacts/wso2cep-3.0.0/eventformatters/AverageMemoryConsumptionEventFormatter.xml
+++ b/extensions/cep/modules/artifacts/wso2cep-3.0.0/eventformatters/AverageMemoryConsumptionEventFormatter.xml
@@ -24,7 +24,7 @@
statistics="disable" trace="enable" xmlns="http://wso2.org/carbon/eventformatter">
<from streamName="average_memory_consumption_stats" version="1.0.0"/>
<mapping customMapping="enable" type="json">
- <inline>{"org.apache.stratos.messaging.event.health.stat.AverageMemoryConsumptionEvent":{"message":{"clusterId":"{{cluster_id}}","clusterInstanceId":"{{cluster_instance_id}}","networkPartitionId":"{{network_partition_id}}","value":"{{average_memory_consumption}}"}}}</inline>
+ <inline>{"org.apache.stratos.messaging.event.health.stat.AverageMemoryConsumptionEvent":{"message":{"clusterId":"{{cluster_id}}","clusterInstanceId":"{{cluster_instance_id}}","networkPartitionId":"{{network_partition_id}}","value":"{{average_memory_consumption}}","timestamp":"{{timestamp}}"}}}</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/01699c92/extensions/cep/modules/artifacts/wso2cep-3.0.0/eventformatters/MemberAverageLoadAverageEventFormatter.xml
----------------------------------------------------------------------
diff --git a/extensions/cep/modules/artifacts/wso2cep-3.0.0/eventformatters/MemberAverageLoadAverageEventFormatter.xml b/extensions/cep/modules/artifacts/wso2cep-3.0.0/eventformatters/MemberAverageLoadAverageEventFormatter.xml
index cab6df6..1d3c110 100644
--- a/extensions/cep/modules/artifacts/wso2cep-3.0.0/eventformatters/MemberAverageLoadAverageEventFormatter.xml
+++ b/extensions/cep/modules/artifacts/wso2cep-3.0.0/eventformatters/MemberAverageLoadAverageEventFormatter.xml
@@ -24,7 +24,7 @@
statistics="disable" trace="enable" xmlns="http://wso2.org/carbon/eventformatter">
<from streamName="member_average_load_average_stats" version="1.0.0"/>
<mapping customMapping="enable" type="json">
- <inline>{"org.apache.stratos.messaging.event.health.stat.MemberAverageLoadAverageEvent":{"message":{"memberId":"{{member_id}}","clusterId":"{{cluster_id}}","clusterInstanceId":"{{cluster_instance_id}}","networkPartitionId":"{{network_partition_id}}","value":"{{member_average_load_average}}"}}}</inline>
+ <inline>{"org.apache.stratos.messaging.event.health.stat.MemberAverageLoadAverageEvent":{"message":{"memberId":"{{member_id}}","clusterId":"{{cluster_id}}","clusterInstanceId":"{{cluster_instance_id}}","networkPartitionId":"{{network_partition_id}}","value":"{{member_average_load_average}}","timestamp":"{{timestamp}}"}}}</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/01699c92/extensions/cep/modules/artifacts/wso2cep-3.0.0/eventformatters/MemberAverageMemoryConsumptionEventFormatter.xml
----------------------------------------------------------------------
diff --git a/extensions/cep/modules/artifacts/wso2cep-3.0.0/eventformatters/MemberAverageMemoryConsumptionEventFormatter.xml b/extensions/cep/modules/artifacts/wso2cep-3.0.0/eventformatters/MemberAverageMemoryConsumptionEventFormatter.xml
index 7f6e1f8..d6dba28 100644
--- a/extensions/cep/modules/artifacts/wso2cep-3.0.0/eventformatters/MemberAverageMemoryConsumptionEventFormatter.xml
+++ b/extensions/cep/modules/artifacts/wso2cep-3.0.0/eventformatters/MemberAverageMemoryConsumptionEventFormatter.xml
@@ -24,7 +24,7 @@
statistics="disable" trace="enable" xmlns="http://wso2.org/carbon/eventformatter">
<from streamName="member_average_memory_consumption_stats" version="1.0.0"/>
<mapping customMapping="enable" type="json">
- <inline>{"org.apache.stratos.messaging.event.health.stat.MemberAverageMemoryConsumptionEvent":{"message":{"memberId":"{{member_id}}","clusterId":"{{cluster_id}}","clusterInstanceId":"{{cluster_instance_id}}","networkPartitionId":"{{network_partition_id}}","value":"{{member_average_memory_consumption}}"}}}</inline>
+ <inline>{"org.apache.stratos.messaging.event.health.stat.MemberAverageMemoryConsumptionEvent":{"message":{"memberId":"{{member_id}}","clusterId":"{{cluster_id}}","clusterInstanceId":"{{cluster_instance_id}}","networkPartitionId":"{{network_partition_id}}","value":"{{member_average_memory_consumption}}","timestamp":"{{timestamp}}"}}}</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/01699c92/extensions/cep/modules/artifacts/wso2cep-3.0.0/executionplans/AverageHeathRequest.xml
----------------------------------------------------------------------
diff --git a/extensions/cep/modules/artifacts/wso2cep-3.0.0/executionplans/AverageHeathRequest.xml b/extensions/cep/modules/artifacts/wso2cep-3.0.0/executionplans/AverageHeathRequest.xml
index b60a0bf..8be0b3a 100644
--- a/extensions/cep/modules/artifacts/wso2cep-3.0.0/executionplans/AverageHeathRequest.xml
+++ b/extensions/cep/modules/artifacts/wso2cep-3.0.0/executionplans/AverageHeathRequest.xml
@@ -40,20 +40,20 @@
define partition health_avg_cluster_partition by health_avg_concatinator.health_grad_cluster_network;
define partition member_health_avg_cluster_partition by health_avg_processsor.member_id;
from health_avg_concatinator [health_description == 'load_average']
- #window.timeBatch(1 min) select cluster_id, cluster_instance_id, network_partition_id, avg(value) as average_load_average
+ #window.timeBatch(1 min) select cluster_id, cluster_instance_id, network_partition_id, avg(value) as average_load_average, stratos:now() as timestamp
insert into average_load_average_stats
partition by health_avg_cluster_partition;
from health_avg_processsor [health_description == 'load_average']
- #window.timeBatch(1 min) select member_id, cluster_id, cluster_instance_id, network_partition_id, avg(value) as member_average_load_average
+ #window.timeBatch(1 min) select member_id, cluster_id, cluster_instance_id, network_partition_id, avg(value) as member_average_load_average, stratos:now() as timestamp
insert into member_average_load_average_stats
partition by member_health_avg_cluster_partition;
from health_avg_processsor [health_description == 'memory_consumption']
- #window.timeBatch(1 min) select member_id, cluster_id, cluster_instance_id, network_partition_id, avg(value) as member_average_memory_consumption
+ #window.timeBatch(1 min) select member_id, cluster_id, cluster_instance_id, network_partition_id, avg(value) as member_average_memory_consumption, stratos:now() as timestamp
insert into member_average_memory_consumption_stats
partition by member_health_avg_cluster_partition;
from health_avg_concatinator [health_description == 'memory_consumption']
- #window.timeBatch(1 min) select cluster_id, cluster_instance_id, network_partition_id, avg(value) as average_memory_consumption
- insert into average_memory_consumption_stats
+ #window.timeBatch(1 min) select cluster_id, cluster_instance_id, network_partition_id, avg(value) as average_memory_consumption, stratos:now() as timestamp
+ insert into average_memory_consumption_stats
partition by health_avg_cluster_partition;
]]></queryExpressions>
<exportedStreams>
http://git-wip-us.apache.org/repos/asf/stratos/blob/01699c92/extensions/cep/modules/artifacts/wso2cep-3.0.0/executionplans/AverageInFlightRequestsFinder.xml
----------------------------------------------------------------------
diff --git a/extensions/cep/modules/artifacts/wso2cep-3.0.0/executionplans/AverageInFlightRequestsFinder.xml b/extensions/cep/modules/artifacts/wso2cep-3.0.0/executionplans/AverageInFlightRequestsFinder.xml
index 20b94da..41fc179 100644
--- a/extensions/cep/modules/artifacts/wso2cep-3.0.0/executionplans/AverageInFlightRequestsFinder.xml
+++ b/extensions/cep/modules/artifacts/wso2cep-3.0.0/executionplans/AverageInFlightRequestsFinder.xml
@@ -37,8 +37,8 @@
insert into avg_rif_concat;
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
+ select cluster_id, cluster_instance_id, network_partition_id, avg(in_flight_request_count) as count, stratos:now() as timestamp
+ insert into average_in_flight_requests
partition by avg_rif_cluster_partition;
]]></queryExpressions>
<exportedStreams>
http://git-wip-us.apache.org/repos/asf/stratos/blob/01699c92/extensions/cep/modules/artifacts/wso2cep-3.0.0/streamdefinitions/stream-manager-config.xml
----------------------------------------------------------------------
diff --git a/extensions/cep/modules/artifacts/wso2cep-3.0.0/streamdefinitions/stream-manager-config.xml b/extensions/cep/modules/artifacts/wso2cep-3.0.0/streamdefinitions/stream-manager-config.xml
index 4c4c7e0..ca2cd9a 100644
--- a/extensions/cep/modules/artifacts/wso2cep-3.0.0/streamdefinitions/stream-manager-config.xml
+++ b/extensions/cep/modules/artifacts/wso2cep-3.0.0/streamdefinitions/stream-manager-config.xml
@@ -23,287 +23,292 @@
<streamManagerConfiguration xmlns="http://wso2.org/carbon/streammanager">
<!-- in-flight requests stream definitions start -->
<streamDefinition name="in_flight_requests" version="1.0.0">
- <description>in-flight request count</description>
- <nickName>in-flight requests</nickName>
- <metaData>
- </metaData>
- <correlationData>
- </correlationData>
- <payloadData>
- <property name="cluster_id" type="String"/>
- <property name="cluster_instance_id" type="String"/>
- <property name="network_partition_id" type="String"/>
- <property name="in_flight_request_count" type="double"/>
- </payloadData>
- </streamDefinition>
+ <description>in-flight request count</description>
+ <nickName>in-flight requests</nickName>
+ <metaData>
+ </metaData>
+ <correlationData>
+ </correlationData>
+ <payloadData>
+ <property name="cluster_id" type="String"/>
+ <property name="cluster_instance_id" type="String"/>
+ <property name="network_partition_id" type="String"/>
+ <property name="in_flight_request_count" type="double"/>
+ </payloadData>
+ </streamDefinition>
<streamDefinition name="gradient_in_flight_requests" version="1.0.0">
- <description>gradient of in flight request count</description>
- <nickName>gradient in flight requests</nickName>
- <metaData>
- </metaData>
- <correlationData>
- </correlationData>
- <payloadData>
- <property name="cluster_id" type="String"/>
- <property name="cluster_instance_id" type="String"/>
- <property name="network_partition_id" type="String"/>
- <property name="count" type="double"/>
- </payloadData>
- </streamDefinition>
+ <description>gradient of in flight request count</description>
+ <nickName>gradient in flight requests</nickName>
+ <metaData>
+ </metaData>
+ <correlationData>
+ </correlationData>
+ <payloadData>
+ <property name="cluster_id" type="String"/>
+ <property name="cluster_instance_id" type="String"/>
+ <property name="network_partition_id" type="String"/>
+ <property name="count" type="double"/>
+ </payloadData>
+ </streamDefinition>
<streamDefinition name="average_in_flight_requests" version="1.0.0">
- <description>average of in-flight request count</description>
- <nickName>average in-flight requests</nickName>
- <metaData>
- </metaData>
- <correlationData>
- </correlationData>
- <payloadData>
- <property name="cluster_id" type="String"/>
- <property name="cluster_instance_id" type="String"/>
- <property name="network_partition_id" type="String"/>
- <property name="count" type="double"/>
- </payloadData>
- </streamDefinition>
+ <description>average of in-flight request count</description>
+ <nickName>average in-flight requests</nickName>
+ <metaData>
+ </metaData>
+ <correlationData>
+ </correlationData>
+ <payloadData>
+ <property name="cluster_id" type="String"/>
+ <property name="cluster_instance_id" type="String"/>
+ <property name="network_partition_id" type="String"/>
+ <property name="count" type="double"/>
+ <property name="timestamp" type="Long"/>
+ </payloadData>
+ </streamDefinition>
<streamDefinition name="second_derivative_in_flight_requests" version="1.0.0">
- <description>second derivative of in-flight request count</description>
- <nickName>second derivative in-flight requests</nickName>
- <metaData>
- </metaData>
- <correlationData>
- </correlationData>
- <payloadData>
- <property name="cluster_id" type="String"/>
- <property name="cluster_instance_id" type="String"/>
- <property name="network_partition_id" type="String"/>
- <property name="count" type="double"/>
- </payloadData>
+ <description>second derivative of in-flight request count</description>
+ <nickName>second derivative in-flight requests</nickName>
+ <metaData>
+ </metaData>
+ <correlationData>
+ </correlationData>
+ <payloadData>
+ <property name="cluster_id" type="String"/>
+ <property name="cluster_instance_id" type="String"/>
+ <property name="network_partition_id" type="String"/>
+ <property name="count" type="double"/>
+ </payloadData>
</streamDefinition>
<!-- in-flight requests stream definitions end -->
<!-- cartridge agent health stats stream definitions start -->
<streamDefinition name="cartridge_agent_health_stats" version="1.0.0">
- <description>agent health stats</description>
- <nickName>agent health stats</nickName>
- <metaData>
- </metaData>
- <correlationData>
- </correlationData>
- <payloadData>
- <property name="cluster_id" type="String" />
- <property name="cluster_instance_id" type="String"/>
- <property name="network_partition_id" type="String"/>
- <property name="member_id" type="String" />
- <property name="partition_id" type="String" />
- <property name="health_description" type="String"/>
- <property name="value" type="double"/>
- </payloadData>
- </streamDefinition>
+ <description>agent health stats</description>
+ <nickName>agent health stats</nickName>
+ <metaData>
+ </metaData>
+ <correlationData>
+ </correlationData>
+ <payloadData>
+ <property name="cluster_id" type="String"/>
+ <property name="cluster_instance_id" type="String"/>
+ <property name="network_partition_id" type="String"/>
+ <property name="member_id" type="String"/>
+ <property name="partition_id" type="String"/>
+ <property name="health_description" type="String"/>
+ <property name="value" type="double"/>
+ </payloadData>
+ </streamDefinition>
<streamDefinition name="average_load_average_stats" version="1.0.0">
- <description>average load average stats</description>
- <nickName>average load average stats</nickName>
- <metaData>
- </metaData>
- <correlationData>
- </correlationData>
- <payloadData>
- <property name="cluster_id" type="String" />
- <property name="cluster_instance_id" type="String"/>
- <property name="network_partition_id" type="String"/>
- <property name="average_load_average" type="double"/>
- </payloadData>
- </streamDefinition>
+ <description>average load average stats</description>
+ <nickName>average load average stats</nickName>
+ <metaData>
+ </metaData>
+ <correlationData>
+ </correlationData>
+ <payloadData>
+ <property name="cluster_id" type="String"/>
+ <property name="cluster_instance_id" type="String"/>
+ <property name="network_partition_id" type="String"/>
+ <property name="average_load_average" type="double"/>
+ <property name="timestamp" type="Long"/>
+ </payloadData>
+ </streamDefinition>
<streamDefinition name="average_memory_consumption_stats" version="1.0.0">
- <description>average memory consumption stats</description>
- <nickName>average memory consumption stats</nickName>
- <metaData>
- </metaData>
- <correlationData>
- </correlationData>
- <payloadData>
- <property name="cluster_id" type="String"/>
- <property name="cluster_instance_id" type="String"/>
- <property name="network_partition_id" type="String"/>
- <property name="average_memory_consumption" type="double"/>
- </payloadData>
- </streamDefinition>
+ <description>average memory consumption stats</description>
+ <nickName>average memory consumption stats</nickName>
+ <metaData>
+ </metaData>
+ <correlationData>
+ </correlationData>
+ <payloadData>
+ <property name="cluster_id" type="String"/>
+ <property name="cluster_instance_id" type="String"/>
+ <property name="network_partition_id" type="String"/>
+ <property name="average_memory_consumption" type="double"/>
+ <property name="timestamp" type="Long"/>
+ </payloadData>
+ </streamDefinition>
<streamDefinition name="gradient_load_average_stats" version="1.0.0">
- <description>gradient load average stats</description>
- <nickName>gradient load average stats</nickName>
- <metaData>
- </metaData>
- <correlationData>
- </correlationData>
- <payloadData>
- <property name="cluster_id" type="String" />
- <property name="cluster_instance_id" type="String"/>
- <property name="network_partition_id" type="String"/>
- <property name="gradient_load_average" type="double"/>
- </payloadData>
- </streamDefinition>
+ <description>gradient load average stats</description>
+ <nickName>gradient load average stats</nickName>
+ <metaData>
+ </metaData>
+ <correlationData>
+ </correlationData>
+ <payloadData>
+ <property name="cluster_id" type="String"/>
+ <property name="cluster_instance_id" type="String"/>
+ <property name="network_partition_id" type="String"/>
+ <property name="gradient_load_average" type="double"/>
+ </payloadData>
+ </streamDefinition>
<streamDefinition name="gradient_memory_consumption_stats" version="1.0.0">
- <description>gradient memoryconsumption stats</description>
- <nickName>gradient memoryconsumption stats</nickName>
- <metaData>
- </metaData>
- <correlationData>
- </correlationData>
- <payloadData>
- <property name="cluster_id" type="String" />
- <property name="cluster_instance_id" type="String"/>
- <property name="network_partition_id" type="String"/>
- <property name="gradient_memory_consumption" type="double"/>
- </payloadData>
- </streamDefinition>
+ <description>gradient memoryconsumption stats</description>
+ <nickName>gradient memoryconsumption stats</nickName>
+ <metaData>
+ </metaData>
+ <correlationData>
+ </correlationData>
+ <payloadData>
+ <property name="cluster_id" type="String"/>
+ <property name="cluster_instance_id" type="String"/>
+ <property name="network_partition_id" type="String"/>
+ <property name="gradient_memory_consumption" type="double"/>
+ </payloadData>
+ </streamDefinition>
<streamDefinition name="second_derivative_memory_consumption_stats" version="1.0.0">
- <description>second derivative memory consumption stats</description>
- <nickName>second derivative memory consumption stats</nickName>
- <metaData>
- </metaData>
- <correlationData>
- </correlationData>
- <payloadData>
- <property name="cluster_id" type="String" />
- <property name="cluster_instance_id" type="String"/>
- <property name="network_partition_id" type="String"/>
- <property name="second_derivative_memory_consumption" type="double"/>
- </payloadData>
- </streamDefinition>
+ <description>second derivative memory consumption stats</description>
+ <nickName>second derivative memory consumption stats</nickName>
+ <metaData>
+ </metaData>
+ <correlationData>
+ </correlationData>
+ <payloadData>
+ <property name="cluster_id" type="String"/>
+ <property name="cluster_instance_id" type="String"/>
+ <property name="network_partition_id" type="String"/>
+ <property name="second_derivative_memory_consumption" type="double"/>
+ </payloadData>
+ </streamDefinition>
<streamDefinition name="second_derivative_load_average_stats" version="1.0.0">
- <description>second derivative load average stats</description>
- <nickName>second derivative load average stats</nickName>
- <metaData>
- </metaData>
- <correlationData>
- </correlationData>
- <payloadData>
- <property name="cluster_id" type="String" />
- <property name="cluster_instance_id" type="String"/>
- <property name="network_partition_id" type="String"/>
- <property name="second_derivative_load_average" type="double"/>
- </payloadData>
- </streamDefinition>
+ <description>second derivative load average stats</description>
+ <nickName>second derivative load average stats</nickName>
+ <metaData>
+ </metaData>
+ <correlationData>
+ </correlationData>
+ <payloadData>
+ <property name="cluster_id" type="String"/>
+ <property name="cluster_instance_id" type="String"/>
+ <property name="network_partition_id" type="String"/>
+ <property name="second_derivative_load_average" type="double"/>
+ </payloadData>
+ </streamDefinition>
<streamDefinition name="fault_message" version="1.0.0">
- <description>fault message</description>
- <nickName>fault message</nickName>
- <metaData>
- </metaData>
- <correlationData>
- </correlationData>
- <payloadData>
- <property name="cluster_id" type="String"/>
- <property name="cluster_instance_id" type="String"/>
- <property name="network_partition_id" type="String"/>
- <property name="member_id" type="String"/>
- <property name="partition_id" type="String"/>
- </payloadData>
+ <description>fault message</description>
+ <nickName>fault message</nickName>
+ <metaData>
+ </metaData>
+ <correlationData>
+ </correlationData>
+ <payloadData>
+ <property name="cluster_id" type="String"/>
+ <property name="cluster_instance_id" type="String"/>
+ <property name="network_partition_id" type="String"/>
+ <property name="member_id" type="String"/>
+ <property name="partition_id" type="String"/>
+ </payloadData>
</streamDefinition>
<!-- cartridge agent health stats stream definitions end -->
<!-- This is for member_id wise grouping-->
<streamDefinition name="member_average_load_average_stats" version="1.0.0">
- <description>average load average stats</description>
- <nickName>average load average stats</nickName>
- <metaData>
- </metaData>
- <correlationData>
- </correlationData>
- <payloadData>
- <property name="member_id" type="String" />
- <property name="cluster_id" type="String" />
- <property name="cluster_instance_id" type="String"/>
- <property name="network_partition_id" type="String"/>
- <property name="member_average_load_average" type="double"/>
- </payloadData>
- </streamDefinition>
+ <description>average load average stats</description>
+ <nickName>average load average stats</nickName>
+ <metaData>
+ </metaData>
+ <correlationData>
+ </correlationData>
+ <payloadData>
+ <property name="member_id" type="String"/>
+ <property name="cluster_id" type="String"/>
+ <property name="cluster_instance_id" type="String"/>
+ <property name="network_partition_id" type="String"/>
+ <property name="member_average_load_average" type="double"/>
+ <property name="timestamp" type="Long"/>
+ </payloadData>
+ </streamDefinition>
<streamDefinition name="member_average_memory_consumption_stats" version="1.0.0">
- <description>average memory consumption stats</description>
- <nickName>average memory consumption stats</nickName>
- <metaData>
- </metaData>
- <correlationData>
- </correlationData>
- <payloadData>
- <property name="member_id" type="String"/>
- <property name="cluster_id" type="String"/>
- <property name="cluster_instance_id" type="String"/>
- <property name="network_partition_id" type="String"/>
- <property name="member_average_memory_consumption" type="double"/>
- </payloadData>
- </streamDefinition>
+ <description>average memory consumption stats</description>
+ <nickName>average memory consumption stats</nickName>
+ <metaData>
+ </metaData>
+ <correlationData>
+ </correlationData>
+ <payloadData>
+ <property name="member_id" type="String"/>
+ <property name="cluster_id" type="String"/>
+ <property name="cluster_instance_id" type="String"/>
+ <property name="network_partition_id" type="String"/>
+ <property name="member_average_memory_consumption" type="double"/>
+ <property name="timestamp" type="Long"/>
+ </payloadData>
+ </streamDefinition>
<streamDefinition name="member_gradient_load_average_stats" version="1.0.0">
- <description>gradient load average stats</description>
- <nickName>gradient load average stats</nickName>
- <metaData>
- </metaData>
- <correlationData>
- </correlationData>
- <payloadData>
- <property name="member_id" type="String" />
- <property name="cluster_id" type="String" />
- <property name="cluster_instance_id" type="String"/>
- <property name="network_partition_id" type="String"/>
- <property name="member_gradient_load_average" type="double"/>
- </payloadData>
- </streamDefinition>
+ <description>gradient load average stats</description>
+ <nickName>gradient load average stats</nickName>
+ <metaData>
+ </metaData>
+ <correlationData>
+ </correlationData>
+ <payloadData>
+ <property name="member_id" type="String"/>
+ <property name="cluster_id" type="String"/>
+ <property name="cluster_instance_id" type="String"/>
+ <property name="network_partition_id" type="String"/>
+ <property name="member_gradient_load_average" type="double"/>
+ </payloadData>
+ </streamDefinition>
<streamDefinition name="member_gradient_memory_consumption_stats" version="1.0.0">
- <description>gradient memoryconsumption stats</description>
- <nickName>gradient memoryconsumption stats</nickName>
- <metaData>
- </metaData>
- <correlationData>
- </correlationData>
- <payloadData>
- <property name="member_id" type="String" />
- <property name="cluster_id" type="String" />
- <property name="cluster_instance_id" type="String"/>
- <property name="network_partition_id" type="String"/>
- <property name="member_gradient_memory_consumption" type="double"/>
- </payloadData>
- </streamDefinition>
+ <description>gradient memoryconsumption stats</description>
+ <nickName>gradient memoryconsumption stats</nickName>
+ <metaData>
+ </metaData>
+ <correlationData>
+ </correlationData>
+ <payloadData>
+ <property name="member_id" type="String"/>
+ <property name="cluster_id" type="String"/>
+ <property name="cluster_instance_id" type="String"/>
+ <property name="network_partition_id" type="String"/>
+ <property name="member_gradient_memory_consumption" type="double"/>
+ </payloadData>
+ </streamDefinition>
<streamDefinition name="member_second_derivative_memory_consumption_stats" version="1.0.0">
- <description>second derivative memory consumption stats</description>
- <nickName>second derivative memory consumption stats</nickName>
- <metaData>
- </metaData>
- <correlationData>
- </correlationData>
- <payloadData>
- <property name="member_id" type="String" />
- <property name="cluster_id" type="String" />
- <property name="cluster_instance_id" type="String"/>
- <property name="network_partition_id" type="String"/>
- <property name="member_second_derivative_memory_consumption" type="double"/>
- </payloadData>
- </streamDefinition>
+ <description>second derivative memory consumption stats</description>
+ <nickName>second derivative memory consumption stats</nickName>
+ <metaData>
+ </metaData>
+ <correlationData>
+ </correlationData>
+ <payloadData>
+ <property name="member_id" type="String"/>
+ <property name="cluster_id" type="String"/>
+ <property name="cluster_instance_id" type="String"/>
+ <property name="network_partition_id" type="String"/>
+ <property name="member_second_derivative_memory_consumption" type="double"/>
+ </payloadData>
+ </streamDefinition>
<streamDefinition name="member_second_derivative_load_average_stats" version="1.0.0">
- <description>second derivative load average stats</description>
- <nickName>second derivative load average stats</nickName>
- <metaData>
- </metaData>
- <correlationData>
- </correlationData>
- <payloadData>
- <property name="member_id" type="String" />
- <property name="cluster_id" type="String" />
- <property name="cluster_instance_id" type="String"/>
- <property name="network_partition_id" type="String"/>
- <property name="member_second_derivative_load_average" type="double"/>
- </payloadData>
- </streamDefinition>
+ <description>second derivative load average stats</description>
+ <nickName>second derivative load average stats</nickName>
+ <metaData>
+ </metaData>
+ <correlationData>
+ </correlationData>
+ <payloadData>
+ <property name="member_id" type="String"/>
+ <property name="cluster_id" type="String"/>
+ <property name="cluster_instance_id" type="String"/>
+ <property name="network_partition_id" type="String"/>
+ <property name="member_second_derivative_load_average" type="double"/>
+ </payloadData>
+ </streamDefinition>
-</streamManagerConfiguration>
+</streamManagerConfiguration>
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/stratos/blob/01699c92/extensions/cep/modules/artifacts/wso2cep-3.1.0/eventformatters/AverageInFlightRequestsEventFormatter.xml
----------------------------------------------------------------------
diff --git a/extensions/cep/modules/artifacts/wso2cep-3.1.0/eventformatters/AverageInFlightRequestsEventFormatter.xml b/extensions/cep/modules/artifacts/wso2cep-3.1.0/eventformatters/AverageInFlightRequestsEventFormatter.xml
index 5955866..f812d89 100644
--- a/extensions/cep/modules/artifacts/wso2cep-3.1.0/eventformatters/AverageInFlightRequestsEventFormatter.xml
+++ b/extensions/cep/modules/artifacts/wso2cep-3.1.0/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}}","value":"{{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}}","timestamp":"{{timestamp}}"}}}</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/01699c92/extensions/cep/modules/artifacts/wso2cep-3.1.0/eventformatters/AverageLoadAverageEventFormatter.xml
----------------------------------------------------------------------
diff --git a/extensions/cep/modules/artifacts/wso2cep-3.1.0/eventformatters/AverageLoadAverageEventFormatter.xml b/extensions/cep/modules/artifacts/wso2cep-3.1.0/eventformatters/AverageLoadAverageEventFormatter.xml
index a0e2052..5ef7f07 100644
--- a/extensions/cep/modules/artifacts/wso2cep-3.1.0/eventformatters/AverageLoadAverageEventFormatter.xml
+++ b/extensions/cep/modules/artifacts/wso2cep-3.1.0/eventformatters/AverageLoadAverageEventFormatter.xml
@@ -24,7 +24,7 @@
statistics="disable" trace="enable" xmlns="http://wso2.org/carbon/eventformatter">
<from streamName="average_load_average_stats" version="1.0.0"/>
<mapping customMapping="enable" type="json">
- <inline>{"org.apache.stratos.messaging.event.health.stat.AverageLoadAverageEvent":{"message":{"clusterId":"{{cluster_id}}","clusterInstanceId":"{{cluster_instance_id}}","networkPartitionId":"{{network_partition_id}}","value":"{{average_load_average}}"}}}</inline>
+ <inline>{"org.apache.stratos.messaging.event.health.stat.AverageLoadAverageEvent":{"message":{"clusterId":"{{cluster_id}}","clusterInstanceId":"{{cluster_instance_id}}","networkPartitionId":"{{network_partition_id}}","value":"{{average_load_average}}","timestamp":"{{timestamp}}"}}}</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/01699c92/extensions/cep/modules/artifacts/wso2cep-3.1.0/eventformatters/AverageMemoryConsumptionEventFormatter.xml
----------------------------------------------------------------------
diff --git a/extensions/cep/modules/artifacts/wso2cep-3.1.0/eventformatters/AverageMemoryConsumptionEventFormatter.xml b/extensions/cep/modules/artifacts/wso2cep-3.1.0/eventformatters/AverageMemoryConsumptionEventFormatter.xml
index cbcab0a..21cba89 100644
--- a/extensions/cep/modules/artifacts/wso2cep-3.1.0/eventformatters/AverageMemoryConsumptionEventFormatter.xml
+++ b/extensions/cep/modules/artifacts/wso2cep-3.1.0/eventformatters/AverageMemoryConsumptionEventFormatter.xml
@@ -24,7 +24,7 @@
statistics="disable" trace="enable" xmlns="http://wso2.org/carbon/eventformatter">
<from streamName="average_memory_consumption_stats" version="1.0.0"/>
<mapping customMapping="enable" type="json">
- <inline>{"org.apache.stratos.messaging.event.health.stat.AverageMemoryConsumptionEvent":{"message":{"clusterId":"{{cluster_id}}","clusterInstanceId":"{{cluster_instance_id}}","networkPartitionId":"{{network_partition_id}}","value":"{{average_memory_consumption}}"}}}</inline>
+ <inline>{"org.apache.stratos.messaging.event.health.stat.AverageMemoryConsumptionEvent":{"message":{"clusterId":"{{cluster_id}}","clusterInstanceId":"{{cluster_instance_id}}","networkPartitionId":"{{network_partition_id}}","value":"{{average_memory_consumption}}","timestamp":"{{timestamp}}"}}}</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/01699c92/extensions/cep/modules/artifacts/wso2cep-3.1.0/eventformatters/MemberAverageLoadAverageEventFormatter.xml
----------------------------------------------------------------------
diff --git a/extensions/cep/modules/artifacts/wso2cep-3.1.0/eventformatters/MemberAverageLoadAverageEventFormatter.xml b/extensions/cep/modules/artifacts/wso2cep-3.1.0/eventformatters/MemberAverageLoadAverageEventFormatter.xml
index cab6df6..1d3c110 100644
--- a/extensions/cep/modules/artifacts/wso2cep-3.1.0/eventformatters/MemberAverageLoadAverageEventFormatter.xml
+++ b/extensions/cep/modules/artifacts/wso2cep-3.1.0/eventformatters/MemberAverageLoadAverageEventFormatter.xml
@@ -24,7 +24,7 @@
statistics="disable" trace="enable" xmlns="http://wso2.org/carbon/eventformatter">
<from streamName="member_average_load_average_stats" version="1.0.0"/>
<mapping customMapping="enable" type="json">
- <inline>{"org.apache.stratos.messaging.event.health.stat.MemberAverageLoadAverageEvent":{"message":{"memberId":"{{member_id}}","clusterId":"{{cluster_id}}","clusterInstanceId":"{{cluster_instance_id}}","networkPartitionId":"{{network_partition_id}}","value":"{{member_average_load_average}}"}}}</inline>
+ <inline>{"org.apache.stratos.messaging.event.health.stat.MemberAverageLoadAverageEvent":{"message":{"memberId":"{{member_id}}","clusterId":"{{cluster_id}}","clusterInstanceId":"{{cluster_instance_id}}","networkPartitionId":"{{network_partition_id}}","value":"{{member_average_load_average}}","timestamp":"{{timestamp}}"}}}</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/01699c92/extensions/cep/modules/artifacts/wso2cep-3.1.0/eventformatters/MemberAverageMemoryConsumptionEventFormatter.xml
----------------------------------------------------------------------
diff --git a/extensions/cep/modules/artifacts/wso2cep-3.1.0/eventformatters/MemberAverageMemoryConsumptionEventFormatter.xml b/extensions/cep/modules/artifacts/wso2cep-3.1.0/eventformatters/MemberAverageMemoryConsumptionEventFormatter.xml
index 7f6e1f8..d6dba28 100644
--- a/extensions/cep/modules/artifacts/wso2cep-3.1.0/eventformatters/MemberAverageMemoryConsumptionEventFormatter.xml
+++ b/extensions/cep/modules/artifacts/wso2cep-3.1.0/eventformatters/MemberAverageMemoryConsumptionEventFormatter.xml
@@ -24,7 +24,7 @@
statistics="disable" trace="enable" xmlns="http://wso2.org/carbon/eventformatter">
<from streamName="member_average_memory_consumption_stats" version="1.0.0"/>
<mapping customMapping="enable" type="json">
- <inline>{"org.apache.stratos.messaging.event.health.stat.MemberAverageMemoryConsumptionEvent":{"message":{"memberId":"{{member_id}}","clusterId":"{{cluster_id}}","clusterInstanceId":"{{cluster_instance_id}}","networkPartitionId":"{{network_partition_id}}","value":"{{member_average_memory_consumption}}"}}}</inline>
+ <inline>{"org.apache.stratos.messaging.event.health.stat.MemberAverageMemoryConsumptionEvent":{"message":{"memberId":"{{member_id}}","clusterId":"{{cluster_id}}","clusterInstanceId":"{{cluster_instance_id}}","networkPartitionId":"{{network_partition_id}}","value":"{{member_average_memory_consumption}}","timestamp":"{{timestamp}}"}}}</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/01699c92/extensions/cep/modules/artifacts/wso2cep-3.1.0/executionplans/AverageHeathRequest.xml
----------------------------------------------------------------------
diff --git a/extensions/cep/modules/artifacts/wso2cep-3.1.0/executionplans/AverageHeathRequest.xml b/extensions/cep/modules/artifacts/wso2cep-3.1.0/executionplans/AverageHeathRequest.xml
index 0a6881b..630b38b 100644
--- a/extensions/cep/modules/artifacts/wso2cep-3.1.0/executionplans/AverageHeathRequest.xml
+++ b/extensions/cep/modules/artifacts/wso2cep-3.1.0/executionplans/AverageHeathRequest.xml
@@ -1,16 +1,24 @@
<?xml version="1.0" encoding="UTF-8"?>
<!--
- ~ Copyright 2005-2009 WSO2, Inc. (http://wso2.com)
- ~ Licensed under the Apache License, Version 2.0 (the "License");
- ~ you may not use this file except in compliance with the License.
- ~ You may obtain a copy of the License at
- ~ http://www.apache.org/licenses/LICENSE-2.0
- ~ Unless required by applicable law or agreed to in writing, software
- ~ distributed under the License is distributed on an "AS IS" BASIS,
- ~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- ~ See the License for the specific language governing permissions and
- ~ limitations under the License.
- -->
+
+ Licensed to the Apache Software Foundation (ASF) under one
+ or more contributor license agreements. See the NOTICE file
+ distributed with this work for additional information
+ regarding copyright ownership. The ASF licenses this file
+ to you under the Apache License, Version 2.0 (the
+ "License"); you may not use this file except in compliance
+ with the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing,
+ software distributed under the License is distributed on an
+ "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ KIND, either express or implied. See the License for the
+ specific language governing permissions and limitations
+ under the License.
+
+-->
<executionPlan name="AverageHeathRequest" statistics="disable"
trace="enable" xmlns="http://wso2.org/carbon/eventprocessor">
@@ -32,20 +40,20 @@
define partition health_avg_cluster_partition by health_avg_concatinator.health_grad_cluster_network;
define partition member_health_avg_cluster_partition by health_avg_processsor.member_id;
from health_avg_concatinator [health_description == 'load_average']
- #window.timeBatch(1 min) select cluster_id, cluster_instance_id, network_partition_id, avg(value) as average_load_average
- insert into average_load_average_stats
+ #window.timeBatch(1 min) select cluster_id, cluster_instance_id, network_partition_id, avg(value) as average_load_average, stratos:now() as timestamp
+ insert into average_load_average_stats
partition by health_avg_cluster_partition;
- from health_avg_processsor [health_description == 'load_average']
- #window.timeBatch(1 min) select member_id, cluster_id, cluster_instance_id, network_partition_id, avg(value) as member_average_load_average
- insert into member_average_load_average_stats
+ from health_avg_processsor [health_description == 'load_average']
+ #window.timeBatch(1 min) select member_id, cluster_id, cluster_instance_id, network_partition_id, avg(value) as member_average_load_average, stratos:now() as timestamp
+ insert into member_average_load_average_stats
partition by member_health_avg_cluster_partition;
- from health_avg_processsor [health_description == 'memory_consumption']
- #window.timeBatch(1 min) select member_id, cluster_id, cluster_instance_id, network_partition_id, avg(value) as member_average_memory_consumption
- insert into member_average_memory_consumption_stats
+ from health_avg_processsor [health_description == 'memory_consumption']
+ #window.timeBatch(1 min) select member_id, cluster_id, cluster_instance_id, network_partition_id, avg(value) as member_average_memory_consumption, stratos:now() as timestamp
+ insert into member_average_memory_consumption_stats
partition by member_health_avg_cluster_partition;
- from health_avg_concatinator [health_description == 'memory_consumption']
- #window.timeBatch(1 min) select cluster_id, cluster_instance_id, network_partition_id, avg(value) as average_memory_consumption
- insert into average_memory_consumption_stats
+ from health_avg_concatinator [health_description == 'memory_consumption']
+ #window.timeBatch(1 min) select cluster_id, cluster_instance_id, network_partition_id, avg(value) as average_memory_consumption, stratos:now() as timestamp
+ insert into average_memory_consumption_stats
partition by health_avg_cluster_partition;
]]></queryExpressions>
<exportedStreams>
http://git-wip-us.apache.org/repos/asf/stratos/blob/01699c92/extensions/cep/modules/artifacts/wso2cep-3.1.0/executionplans/AverageInFlightRequestsFinder.xml
----------------------------------------------------------------------
diff --git a/extensions/cep/modules/artifacts/wso2cep-3.1.0/executionplans/AverageInFlightRequestsFinder.xml b/extensions/cep/modules/artifacts/wso2cep-3.1.0/executionplans/AverageInFlightRequestsFinder.xml
index 0c950c6..ee668b3 100644
--- a/extensions/cep/modules/artifacts/wso2cep-3.1.0/executionplans/AverageInFlightRequestsFinder.xml
+++ b/extensions/cep/modules/artifacts/wso2cep-3.1.0/executionplans/AverageInFlightRequestsFinder.xml
@@ -1,16 +1,24 @@
<?xml version="1.0" encoding="UTF-8"?>
<!--
- ~ Copyright 2005-2009 WSO2, Inc. (http://wso2.com)
- ~ Licensed under the Apache License, Version 2.0 (the "License");
- ~ you may not use this file except in compliance with the License.
- ~ You may obtain a copy of the License at
- ~ http://www.apache.org/licenses/LICENSE-2.0
- ~ Unless required by applicable law or agreed to in writing, software
- ~ distributed under the License is distributed on an "AS IS" BASIS,
- ~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- ~ See the License for the specific language governing permissions and
- ~ limitations under the License.
- -->
+
+ Licensed to the Apache Software Foundation (ASF) under one
+ or more contributor license agreements. See the NOTICE file
+ distributed with this work for additional information
+ regarding copyright ownership. The ASF licenses this file
+ to you under the Apache License, Version 2.0 (the
+ "License"); you may not use this file except in compliance
+ with the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing,
+ software distributed under the License is distributed on an
+ "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ KIND, either express or implied. See the License for the
+ specific language governing permissions and limitations
+ under the License.
+
+-->
<executionPlan name="AverageInFlightRequestsFinder" statistics="disable"
trace="enable" xmlns="http://wso2.org/carbon/eventprocessor">
@@ -29,8 +37,8 @@
insert into avg_rif_concat;
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
+ select cluster_id, cluster_instance_id, network_partition_id, avg(in_flight_request_count) as count, stratos:now() as timestamp
+ insert into average_in_flight_requests
partition by avg_rif_cluster_partition;
]]></queryExpressions>
<exportedStreams>
http://git-wip-us.apache.org/repos/asf/stratos/blob/01699c92/extensions/cep/modules/artifacts/wso2cep-3.1.0/streamdefinitions/stream-manager-config.xml
----------------------------------------------------------------------
diff --git a/extensions/cep/modules/artifacts/wso2cep-3.1.0/streamdefinitions/stream-manager-config.xml b/extensions/cep/modules/artifacts/wso2cep-3.1.0/streamdefinitions/stream-manager-config.xml
index 4c4c7e0..4d6f43a 100644
--- a/extensions/cep/modules/artifacts/wso2cep-3.1.0/streamdefinitions/stream-manager-config.xml
+++ b/extensions/cep/modules/artifacts/wso2cep-3.1.0/streamdefinitions/stream-manager-config.xml
@@ -23,287 +23,292 @@
<streamManagerConfiguration xmlns="http://wso2.org/carbon/streammanager">
<!-- in-flight requests stream definitions start -->
<streamDefinition name="in_flight_requests" version="1.0.0">
- <description>in-flight request count</description>
- <nickName>in-flight requests</nickName>
- <metaData>
- </metaData>
- <correlationData>
- </correlationData>
- <payloadData>
- <property name="cluster_id" type="String"/>
- <property name="cluster_instance_id" type="String"/>
- <property name="network_partition_id" type="String"/>
- <property name="in_flight_request_count" type="double"/>
- </payloadData>
- </streamDefinition>
+ <description>in-flight request count</description>
+ <nickName>in-flight requests</nickName>
+ <metaData>
+ </metaData>
+ <correlationData>
+ </correlationData>
+ <payloadData>
+ <property name="cluster_id" type="String"/>
+ <property name="cluster_instance_id" type="String"/>
+ <property name="network_partition_id" type="String"/>
+ <property name="in_flight_request_count" type="double"/>
+ </payloadData>
+ </streamDefinition>
<streamDefinition name="gradient_in_flight_requests" version="1.0.0">
- <description>gradient of in flight request count</description>
- <nickName>gradient in flight requests</nickName>
- <metaData>
- </metaData>
- <correlationData>
- </correlationData>
- <payloadData>
- <property name="cluster_id" type="String"/>
- <property name="cluster_instance_id" type="String"/>
- <property name="network_partition_id" type="String"/>
- <property name="count" type="double"/>
- </payloadData>
- </streamDefinition>
+ <description>gradient of in flight request count</description>
+ <nickName>gradient in flight requests</nickName>
+ <metaData>
+ </metaData>
+ <correlationData>
+ </correlationData>
+ <payloadData>
+ <property name="cluster_id" type="String"/>
+ <property name="cluster_instance_id" type="String"/>
+ <property name="network_partition_id" type="String"/>
+ <property name="count" type="double"/>
+ </payloadData>
+ </streamDefinition>
<streamDefinition name="average_in_flight_requests" version="1.0.0">
- <description>average of in-flight request count</description>
- <nickName>average in-flight requests</nickName>
- <metaData>
- </metaData>
- <correlationData>
- </correlationData>
- <payloadData>
- <property name="cluster_id" type="String"/>
- <property name="cluster_instance_id" type="String"/>
- <property name="network_partition_id" type="String"/>
- <property name="count" type="double"/>
- </payloadData>
- </streamDefinition>
+ <description>average of in-flight request count</description>
+ <nickName>average in-flight requests</nickName>
+ <metaData>
+ </metaData>
+ <correlationData>
+ </correlationData>
+ <payloadData>
+ <property name="cluster_id" type="String"/>
+ <property name="cluster_instance_id" type="String"/>
+ <property name="network_partition_id" type="String"/>
+ <property name="count" type="double"/>
+ <property name="timestamp" type="Long"/>
+ </payloadData>
+ </streamDefinition>
<streamDefinition name="second_derivative_in_flight_requests" version="1.0.0">
- <description>second derivative of in-flight request count</description>
- <nickName>second derivative in-flight requests</nickName>
- <metaData>
- </metaData>
- <correlationData>
- </correlationData>
- <payloadData>
- <property name="cluster_id" type="String"/>
- <property name="cluster_instance_id" type="String"/>
- <property name="network_partition_id" type="String"/>
- <property name="count" type="double"/>
- </payloadData>
+ <description>second derivative of in-flight request count</description>
+ <nickName>second derivative in-flight requests</nickName>
+ <metaData>
+ </metaData>
+ <correlationData>
+ </correlationData>
+ <payloadData>
+ <property name="cluster_id" type="String"/>
+ <property name="cluster_instance_id" type="String"/>
+ <property name="network_partition_id" type="String"/>
+ <property name="count" type="double"/>
+ </payloadData>
</streamDefinition>
<!-- in-flight requests stream definitions end -->
<!-- cartridge agent health stats stream definitions start -->
<streamDefinition name="cartridge_agent_health_stats" version="1.0.0">
- <description>agent health stats</description>
- <nickName>agent health stats</nickName>
- <metaData>
- </metaData>
- <correlationData>
- </correlationData>
- <payloadData>
- <property name="cluster_id" type="String" />
- <property name="cluster_instance_id" type="String"/>
- <property name="network_partition_id" type="String"/>
- <property name="member_id" type="String" />
- <property name="partition_id" type="String" />
- <property name="health_description" type="String"/>
- <property name="value" type="double"/>
- </payloadData>
- </streamDefinition>
+ <description>agent health stats</description>
+ <nickName>agent health stats</nickName>
+ <metaData>
+ </metaData>
+ <correlationData>
+ </correlationData>
+ <payloadData>
+ <property name="cluster_id" type="String"/>
+ <property name="cluster_instance_id" type="String"/>
+ <property name="network_partition_id" type="String"/>
+ <property name="member_id" type="String"/>
+ <property name="partition_id" type="String"/>
+ <property name="health_description" type="String"/>
+ <property name="value" type="double"/>
+ </payloadData>
+ </streamDefinition>
<streamDefinition name="average_load_average_stats" version="1.0.0">
- <description>average load average stats</description>
- <nickName>average load average stats</nickName>
- <metaData>
- </metaData>
- <correlationData>
- </correlationData>
- <payloadData>
- <property name="cluster_id" type="String" />
- <property name="cluster_instance_id" type="String"/>
- <property name="network_partition_id" type="String"/>
- <property name="average_load_average" type="double"/>
- </payloadData>
- </streamDefinition>
+ <description>average load average stats</description>
+ <nickName>average load average stats</nickName>
+ <metaData>
+ </metaData>
+ <correlationData>
+ </correlationData>
+ <payloadData>
+ <property name="cluster_id" type="String"/>
+ <property name="cluster_instance_id" type="String"/>
+ <property name="network_partition_id" type="String"/>
+ <property name="average_load_average" type="double"/>
+ <property name="timestamp" type="Long"/>
+ </payloadData>
+ </streamDefinition>
<streamDefinition name="average_memory_consumption_stats" version="1.0.0">
- <description>average memory consumption stats</description>
- <nickName>average memory consumption stats</nickName>
- <metaData>
- </metaData>
- <correlationData>
- </correlationData>
- <payloadData>
- <property name="cluster_id" type="String"/>
- <property name="cluster_instance_id" type="String"/>
- <property name="network_partition_id" type="String"/>
- <property name="average_memory_consumption" type="double"/>
- </payloadData>
- </streamDefinition>
+ <description>average memory consumption stats</description>
+ <nickName>average memory consumption stats</nickName>
+ <metaData>
+ </metaData>
+ <correlationData>
+ </correlationData>
+ <payloadData>
+ <property name="cluster_id" type="String"/>
+ <property name="cluster_instance_id" type="String"/>
+ <property name="network_partition_id" type="String"/>
+ <property name="average_memory_consumption" type="double"/>
+ <property name="timestamp" type="Long"/>
+ </payloadData>
+ </streamDefinition>
<streamDefinition name="gradient_load_average_stats" version="1.0.0">
- <description>gradient load average stats</description>
- <nickName>gradient load average stats</nickName>
- <metaData>
- </metaData>
- <correlationData>
- </correlationData>
- <payloadData>
- <property name="cluster_id" type="String" />
- <property name="cluster_instance_id" type="String"/>
- <property name="network_partition_id" type="String"/>
- <property name="gradient_load_average" type="double"/>
- </payloadData>
- </streamDefinition>
+ <description>gradient load average stats</description>
+ <nickName>gradient load average stats</nickName>
+ <metaData>
+ </metaData>
+ <correlationData>
+ </correlationData>
+ <payloadData>
+ <property name="cluster_id" type="String"/>
+ <property name="cluster_instance_id" type="String"/>
+ <property name="network_partition_id" type="String"/>
+ <property name="gradient_load_average" type="double"/>
+ </payloadData>
+ </streamDefinition>
<streamDefinition name="gradient_memory_consumption_stats" version="1.0.0">
- <description>gradient memoryconsumption stats</description>
- <nickName>gradient memoryconsumption stats</nickName>
- <metaData>
- </metaData>
- <correlationData>
- </correlationData>
- <payloadData>
- <property name="cluster_id" type="String" />
- <property name="cluster_instance_id" type="String"/>
- <property name="network_partition_id" type="String"/>
- <property name="gradient_memory_consumption" type="double"/>
- </payloadData>
- </streamDefinition>
+ <description>gradient memoryconsumption stats</description>
+ <nickName>gradient memoryconsumption stats</nickName>
+ <metaData>
+ </metaData>
+ <correlationData>
+ </correlationData>
+ <payloadData>
+ <property name="cluster_id" type="String"/>
+ <property name="cluster_instance_id" type="String"/>
+ <property name="network_partition_id" type="String"/>
+ <property name="gradient_memory_consumption" type="double"/>
+ </payloadData>
+ </streamDefinition>
<streamDefinition name="second_derivative_memory_consumption_stats" version="1.0.0">
- <description>second derivative memory consumption stats</description>
- <nickName>second derivative memory consumption stats</nickName>
- <metaData>
- </metaData>
- <correlationData>
- </correlationData>
- <payloadData>
- <property name="cluster_id" type="String" />
- <property name="cluster_instance_id" type="String"/>
- <property name="network_partition_id" type="String"/>
- <property name="second_derivative_memory_consumption" type="double"/>
- </payloadData>
- </streamDefinition>
+ <description>second derivative memory consumption stats</description>
+ <nickName>second derivative memory consumption stats</nickName>
+ <metaData>
+ </metaData>
+ <correlationData>
+ </correlationData>
+ <payloadData>
+ <property name="cluster_id" type="String"/>
+ <property name="cluster_instance_id" type="String"/>
+ <property name="network_partition_id" type="String"/>
+ <property name="second_derivative_memory_consumption" type="double"/>
+ </payloadData>
+ </streamDefinition>
<streamDefinition name="second_derivative_load_average_stats" version="1.0.0">
- <description>second derivative load average stats</description>
- <nickName>second derivative load average stats</nickName>
- <metaData>
- </metaData>
- <correlationData>
- </correlationData>
- <payloadData>
- <property name="cluster_id" type="String" />
- <property name="cluster_instance_id" type="String"/>
- <property name="network_partition_id" type="String"/>
- <property name="second_derivative_load_average" type="double"/>
- </payloadData>
- </streamDefinition>
+ <description>second derivative load average stats</description>
+ <nickName>second derivative load average stats</nickName>
+ <metaData>
+ </metaData>
+ <correlationData>
+ </correlationData>
+ <payloadData>
+ <property name="cluster_id" type="String"/>
+ <property name="cluster_instance_id" type="String"/>
+ <property name="network_partition_id" type="String"/>
+ <property name="second_derivative_load_average" type="double"/>
+ </payloadData>
+ </streamDefinition>
<streamDefinition name="fault_message" version="1.0.0">
- <description>fault message</description>
- <nickName>fault message</nickName>
- <metaData>
- </metaData>
- <correlationData>
- </correlationData>
- <payloadData>
- <property name="cluster_id" type="String"/>
- <property name="cluster_instance_id" type="String"/>
- <property name="network_partition_id" type="String"/>
- <property name="member_id" type="String"/>
- <property name="partition_id" type="String"/>
- </payloadData>
+ <description>fault message</description>
+ <nickName>fault message</nickName>
+ <metaData>
+ </metaData>
+ <correlationData>
+ </correlationData>
+ <payloadData>
+ <property name="cluster_id" type="String"/>
+ <property name="cluster_instance_id" type="String"/>
+ <property name="network_partition_id" type="String"/>
+ <property name="member_id" type="String"/>
+ <property name="partition_id" type="String"/>
+ </payloadData>
</streamDefinition>
<!-- cartridge agent health stats stream definitions end -->
<!-- This is for member_id wise grouping-->
<streamDefinition name="member_average_load_average_stats" version="1.0.0">
- <description>average load average stats</description>
- <nickName>average load average stats</nickName>
- <metaData>
- </metaData>
- <correlationData>
- </correlationData>
- <payloadData>
- <property name="member_id" type="String" />
- <property name="cluster_id" type="String" />
- <property name="cluster_instance_id" type="String"/>
- <property name="network_partition_id" type="String"/>
- <property name="member_average_load_average" type="double"/>
- </payloadData>
- </streamDefinition>
+ <description>average load average stats</description>
+ <nickName>average load average stats</nickName>
+ <metaData>
+ </metaData>
+ <correlationData>
+ </correlationData>
+ <payloadData>
+ <property name="member_id" type="String"/>
+ <property name="cluster_id" type="String"/>
+ <property name="cluster_instance_id" type="String"/>
+ <property name="network_partition_id" type="String"/>
+ <property name="member_average_load_average" type="double"/>
+ <property name="timestamp" type="Long"/>
+ </payloadData>
+ </streamDefinition>
<streamDefinition name="member_average_memory_consumption_stats" version="1.0.0">
- <description>average memory consumption stats</description>
- <nickName>average memory consumption stats</nickName>
- <metaData>
- </metaData>
- <correlationData>
- </correlationData>
- <payloadData>
- <property name="member_id" type="String"/>
- <property name="cluster_id" type="String"/>
- <property name="cluster_instance_id" type="String"/>
- <property name="network_partition_id" type="String"/>
- <property name="member_average_memory_consumption" type="double"/>
- </payloadData>
- </streamDefinition>
+ <description>average memory consumption stats</description>
+ <nickName>average memory consumption stats</nickName>
+ <metaData>
+ </metaData>
+ <correlationData>
+ </correlationData>
+ <payloadData>
+ <property name="member_id" type="String"/>
+ <property name="cluster_id" type="String"/>
+ <property name="cluster_instance_id" type="String"/>
+ <property name="network_partition_id" type="String"/>
+ <property name="member_average_memory_consumption" type="double"/>
+ <property name="timestamp" type="Long"/>
+ </payloadData>
+ </streamDefinition>
<streamDefinition name="member_gradient_load_average_stats" version="1.0.0">
- <description>gradient load average stats</description>
- <nickName>gradient load average stats</nickName>
- <metaData>
- </metaData>
- <correlationData>
- </correlationData>
- <payloadData>
- <property name="member_id" type="String" />
- <property name="cluster_id" type="String" />
- <property name="cluster_instance_id" type="String"/>
- <property name="network_partition_id" type="String"/>
- <property name="member_gradient_load_average" type="double"/>
- </payloadData>
- </streamDefinition>
+ <description>gradient load average stats</description>
+ <nickName>gradient load average stats</nickName>
+ <metaData>
+ </metaData>
+ <correlationData>
+ </correlationData>
+ <payloadData>
+ <property name="member_id" type="String"/>
+ <property name="cluster_id" type="String"/>
+ <property name="cluster_instance_id" type="String"/>
+ <property name="network_partition_id" type="String"/>
+ <property name="member_gradient_load_average" type="double"/>
+ </payloadData>
+ </streamDefinition>
<streamDefinition name="member_gradient_memory_consumption_stats" version="1.0.0">
- <description>gradient memoryconsumption stats</description>
- <nickName>gradient memoryconsumption stats</nickName>
- <metaData>
- </metaData>
- <correlationData>
- </correlationData>
- <payloadData>
- <property name="member_id" type="String" />
- <property name="cluster_id" type="String" />
- <property name="cluster_instance_id" type="String"/>
- <property name="network_partition_id" type="String"/>
- <property name="member_gradient_memory_consumption" type="double"/>
- </payloadData>
- </streamDefinition>
+ <description>gradient memoryconsumption stats</description>
+ <nickName>gradient memoryconsumption stats</nickName>
+ <metaData>
+ </metaData>
+ <correlationData>
+ </correlationData>
+ <payloadData>
+ <property name="member_id" type="String"/>
+ <property name="cluster_id" type="String"/>
+ <property name="cluster_instance_id" type="String"/>
+ <property name="network_partition_id" type="String"/>
+ <property name="member_gradient_memory_consumption" type="double"/>
+ </payloadData>
+ </streamDefinition>
<streamDefinition name="member_second_derivative_memory_consumption_stats" version="1.0.0">
- <description>second derivative memory consumption stats</description>
- <nickName>second derivative memory consumption stats</nickName>
- <metaData>
- </metaData>
- <correlationData>
- </correlationData>
- <payloadData>
- <property name="member_id" type="String" />
- <property name="cluster_id" type="String" />
- <property name="cluster_instance_id" type="String"/>
- <property name="network_partition_id" type="String"/>
- <property name="member_second_derivative_memory_consumption" type="double"/>
- </payloadData>
- </streamDefinition>
+ <description>second derivative memory consumption stats</description>
+ <nickName>second derivative memory consumption stats</nickName>
+ <metaData>
+ </metaData>
+ <correlationData>
+ </correlationData>
+ <payloadData>
+ <property name="member_id" type="String"/>
+ <property name="cluster_id" type="String"/>
+ <property name="cluster_instance_id" type="String"/>
+ <property name="network_partition_id" type="String"/>
+ <property name="member_second_derivative_memory_consumption" type="double"/>
+ </payloadData>
+ </streamDefinition>
<streamDefinition name="member_second_derivative_load_average_stats" version="1.0.0">
- <description>second derivative load average stats</description>
- <nickName>second derivative load average stats</nickName>
- <metaData>
- </metaData>
- <correlationData>
- </correlationData>
- <payloadData>
- <property name="member_id" type="String" />
- <property name="cluster_id" type="String" />
- <property name="cluster_instance_id" type="String"/>
- <property name="network_partition_id" type="String"/>
- <property name="member_second_derivative_load_average" type="double"/>
- </payloadData>
- </streamDefinition>
+ <description>second derivative load average stats</description>
+ <nickName>second derivative load average stats</nickName>
+ <metaData>
+ </metaData>
+ <correlationData>
+ </correlationData>
+ <payloadData>
+ <property name="member_id" type="String"/>
+ <property name="cluster_id" type="String"/>
+ <property name="cluster_instance_id" type="String"/>
+ <property name="network_partition_id" type="String"/>
+ <property name="member_second_derivative_load_average" type="double"/>
+ </payloadData>
+ </streamDefinition>
</streamManagerConfiguration>
http://git-wip-us.apache.org/repos/asf/stratos/blob/01699c92/extensions/cep/modules/stratos-cep-extension/wso2cep-3.0.0/src/main/java/org/apache/stratos/cep/extension/SystemTimeWindowProcessor.java
----------------------------------------------------------------------
diff --git a/extensions/cep/modules/stratos-cep-extension/wso2cep-3.0.0/src/main/java/org/apache/stratos/cep/extension/SystemTimeWindowProcessor.java b/extensions/cep/modules/stratos-cep-extension/wso2cep-3.0.0/src/main/java/org/apache/stratos/cep/extension/SystemTimeWindowProcessor.java
new file mode 100644
index 0000000..05c6e7e
--- /dev/null
+++ b/extensions/cep/modules/stratos-cep-extension/wso2cep-3.0.0/src/main/java/org/apache/stratos/cep/extension/SystemTimeWindowProcessor.java
@@ -0,0 +1,48 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.stratos.cep.extension;
+import org.wso2.siddhi.core.config.SiddhiContext;
+import org.wso2.siddhi.core.executor.function.FunctionExecutor;
+import org.wso2.siddhi.query.api.definition.Attribute;
+import org.wso2.siddhi.query.api.extension.annotation.SiddhiExtension;
+
+/**
+ * CEP Window Processor to get current system time.
+ */
+@SiddhiExtension(namespace = "stratos", function = "now")
+public class SystemTimeWindowProcessor extends FunctionExecutor {
+ Attribute.Type returnType = Attribute.Type.LONG;
+ @Override
+ public void init(Attribute.Type[] types, SiddhiContext siddhiContext) {
+ }
+
+ @Override
+ protected Object process(Object obj) {
+ return System.currentTimeMillis();
+ }
+
+ @Override
+ public void destroy() {
+ }
+
+ @Override
+ public Attribute.Type getReturnType() {
+ return returnType;
+ }
+}
http://git-wip-us.apache.org/repos/asf/stratos/blob/01699c92/extensions/cep/modules/stratos-cep-extension/wso2cep-3.1.0/src/main/java/org/apache/stratos/cep/extension/SystemTimeWindowProcessor.java
----------------------------------------------------------------------
diff --git a/extensions/cep/modules/stratos-cep-extension/wso2cep-3.1.0/src/main/java/org/apache/stratos/cep/extension/SystemTimeWindowProcessor.java b/extensions/cep/modules/stratos-cep-extension/wso2cep-3.1.0/src/main/java/org/apache/stratos/cep/extension/SystemTimeWindowProcessor.java
new file mode 100644
index 0000000..b30f0f9
--- /dev/null
+++ b/extensions/cep/modules/stratos-cep-extension/wso2cep-3.1.0/src/main/java/org/apache/stratos/cep/extension/SystemTimeWindowProcessor.java
@@ -0,0 +1,50 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.stratos.cep.extension;
+
+import org.wso2.siddhi.core.config.SiddhiContext;
+import org.wso2.siddhi.core.executor.function.FunctionExecutor;
+import org.wso2.siddhi.query.api.definition.Attribute;
+import org.wso2.siddhi.query.api.extension.annotation.SiddhiExtension;
+
+/**
+ * CEP Window Processor to get current system time.
+ */
+@SiddhiExtension(namespace = "stratos", function = "now")
+public class SystemTimeWindowProcessor extends FunctionExecutor {
+ Attribute.Type returnType = Attribute.Type.LONG;
+
+ @Override
+ public void init(Attribute.Type[] types, SiddhiContext siddhiContext) {
+ }
+
+ @Override
+ protected Object process(Object obj) {
+ return System.currentTimeMillis();
+ }
+
+ @Override
+ public void destroy() {
+ }
+
+ @Override
+ public Attribute.Type getReturnType() {
+ return returnType;
+ }
+}
http://git-wip-us.apache.org/repos/asf/stratos/blob/01699c92/products/stratos/modules/distribution/src/main/conf/siddhi/siddhi.extension
----------------------------------------------------------------------
diff --git a/products/stratos/modules/distribution/src/main/conf/siddhi/siddhi.extension b/products/stratos/modules/distribution/src/main/conf/siddhi/siddhi.extension
index 61fc9df..cfea765 100644
--- a/products/stratos/modules/distribution/src/main/conf/siddhi/siddhi.extension
+++ b/products/stratos/modules/distribution/src/main/conf/siddhi/siddhi.extension
@@ -3,3 +3,4 @@ org.apache.stratos.cep.extension.SecondDerivativeFinderWindowProcessor
org.apache.stratos.cep.extension.FaultHandlingWindowProcessor
org.apache.stratos.cep.extension.ConcatWindowProcessor
org.apache.stratos.cep.extension.MemeberRequestHandlingCapabilityWindowProcessor
+org.wso2.ppaas.cep.extension.SystemTimeWindowProcessor