Re: [Dev] [CEP] Help on TimeWindowProcessor

[Pranavan Theivendiram]

Thanks suho. This what I am exactly looking for. :)

*T. Pranavan*
*BSc Eng Undergraduate| Department of Computer Science & Engineering
,University of Moratuwa*
*Mobile| *0775136836

On 11 August 2015 at 22:05, Sriskandarajah Suhothayan  wrote:

> You could do some thing like below, and replace firstd, secondd, thirdd
> values within the extension with the computed results.
>
> define stream health_second_der_concat (cluster_id, cluster_instance_id,
> network_partition_id, value )
>
> define stream health_second_der_concat_temp (cluster_id,
> cluster_instance_id, network_partition_id, value, firstd double, secondd
> double, thirdd double)
>
> from health_second_der_concat
> select cluster_id, cluster_instance_id, network_partition_id, 0.0 as firstd,
> 0.0 as secondd, 0.0 as thirdd
> insert into health_second_der_concat_temp
>
> from health_second_der_concat_temp [health_description == 
> 'memory_consumption']
>*#window.stratos:secondDerivative(1 min, value, *firstd, secondd, thirdd*)*
>
> select *
>
>insert into second_derivative_memory_consumption_stats
>partition by health_second_der_cluster_partition;
>
>
> On Tue, Aug 11, 2015 at 7:18 PM, Pranavan Theivendiram <
> pranavan...@cse.mrt.ac.lk> wrote:
>
>> Hi Suho,
>>
>> The following is sample execution plan query. Here we are getting one
>> result as value. Can I get three values using this kind of queries?
>>
>> *The Query* [1]
>> 
>>
>> from health_second_der_concat [health_description == 'memory_consumption']
>>*#window.stratos:secondDerivative(1 min, value)* select cluster_id, 
>> cluster_instance_id, network_partition_id, value as 
>> second_derivative_memory_consumption
>>insert into second_derivative_memory_consumption_stats
>>partition by health_second_der_cluster_partition;
>>
>> *The annotation in SecondDerivativeWindowProcessor* [2] 
>> 
>>
>> @SiddhiExtension(namespace = "stratos", function = "secondDerivative")
>>
>> Here they are getting only one value. Can you point me out a way that I can 
>> have all three here?
>>
>>
>> Thanks
>>
>>
>> *T. Pranavan*
>> *BSc Eng Undergraduate| Department of Computer Science & Engineering
>> ,University of Moratuwa*
>> *Mobile| *0775136836
>>
>> On 9 August 2015 at 09:27, Sriskandarajah Suhothayan 
>> wrote:
>>
>>> Thats possible, you have to have 3 dummy fields on the input stream
>>> which you can populate at the window with the coefficients and output
>>> the events. Let me know if there are specific issues
>>>
>>> Suho
>>>
>>> On Sun, Aug 9, 2015 at 8:46 AM, Pranavan Theivendiram <
>>> pranavan...@cse.mrt.ac.lk> wrote:
>>>
 Hi Suho,

 In my case, I am generating a second order polynomial(Three
 coefficients). I am taking inputs of a 10 minute window.(A sliding window-
 every one minute , the window will be get update. New events will come into
 the window and the oldest events will get removed from the window)

 Thanks

 *T. Pranavan*
 *BSc Eng Undergraduate| Department of Computer Science & Engineering
 ,University of Moratuwa*
 *Mobile| *0775136836

 On 9 August 2015 at 08:40, Sriskandarajah Suhothayan 
 wrote:

> Time window is to buffer events and expire based on some condition
> (time/length/etc), its not for creating new attributes by default. here 
> the
> expired events are generated to inform the other processes the event have
> expired and hence they can do adjust their calculations based on that. If
> you dont have a avg() kind of aggregate functions on select then you dont
> need to send expired events.
>
> For you predictions how many inputs you have (input attributes used
> for production) and how many outputs will be generated (is it only one co
> efficient value)?
> If you are generating one value then you have to extend an Output
> aggregator. e.g.[1]
>
> Suho
>
> [1]
> https://svn.wso2.org/repos/wso2/carbon/platform/branches/turing/dependencies/commons/siddhi/2.0.0-wso2v5/modules/siddhi-core/src/main/java/org/wso2/siddhi/core/query/selector/attribute/handler/avg/AvgOutputAttributeAggregatorDouble.java
>
> On Sat, Aug 8, 2015 at 5:14 PM, Pranavan Theivendiram <
> pranavan...@cse.mrt.ac.lk> wrote:
>
>> Hi All,
>>
>> I am working on writing a custom TimeWindowProcessor (SlidingWindow)
>> to handle the curvefitting prediction. I followed the this implementation
>> [1] and referred this documentation[2]. In my case, I need to get the
>> events received during the 10 mins and use it for the calculation of the
>> curve fitting and set the co efficient of curve fitting as a event. I am
>> fin

Re: [Dev] [CEP] Help on TimeWindowProcessor

[Sriskandarajah Suhothayan]

You could do some thing like below, and replace firstd, secondd, thirdd
values within the extension with the computed results.

define stream health_second_der_concat (cluster_id, cluster_instance_id,
network_partition_id, value )

define stream health_second_der_concat_temp (cluster_id,
cluster_instance_id, network_partition_id, value, firstd double, secondd
double, thirdd double)

from health_second_der_concat
select cluster_id, cluster_instance_id, network_partition_id, 0.0 as firstd,
0.0 as secondd, 0.0 as thirdd
insert into health_second_der_concat_temp

from health_second_der_concat_temp [health_description == 'memory_consumption']
   *#window.stratos:secondDerivative(1 min, value, *firstd, secondd, thirdd*)*

select *

   insert into second_derivative_memory_consumption_stats
   partition by health_second_der_cluster_partition;


On Tue, Aug 11, 2015 at 7:18 PM, Pranavan Theivendiram <
pranavan...@cse.mrt.ac.lk> wrote:

> Hi Suho,
>
> The following is sample execution plan query. Here we are getting one
> result as value. Can I get three values using this kind of queries?
>
> *The Query* [1]
> 
>
> from health_second_der_concat [health_description == 'memory_consumption']
>*#window.stratos:secondDerivative(1 min, value)* select cluster_id, 
> cluster_instance_id, network_partition_id, value as 
> second_derivative_memory_consumption
>insert into second_derivative_memory_consumption_stats
>partition by health_second_der_cluster_partition;
>
> *The annotation in SecondDerivativeWindowProcessor* [2] 
> 
>
> @SiddhiExtension(namespace = "stratos", function = "secondDerivative")
>
> Here they are getting only one value. Can you point me out a way that I can 
> have all three here?
>
>
> Thanks
>
>
> *T. Pranavan*
> *BSc Eng Undergraduate| Department of Computer Science & Engineering
> ,University of Moratuwa*
> *Mobile| *0775136836
>
> On 9 August 2015 at 09:27, Sriskandarajah Suhothayan 
> wrote:
>
>> Thats possible, you have to have 3 dummy fields on the input stream which
>> you can populate at the window with the coefficients and output the
>> events. Let me know if there are specific issues
>>
>> Suho
>>
>> On Sun, Aug 9, 2015 at 8:46 AM, Pranavan Theivendiram <
>> pranavan...@cse.mrt.ac.lk> wrote:
>>
>>> Hi Suho,
>>>
>>> In my case, I am generating a second order polynomial(Three
>>> coefficients). I am taking inputs of a 10 minute window.(A sliding window-
>>> every one minute , the window will be get update. New events will come into
>>> the window and the oldest events will get removed from the window)
>>>
>>> Thanks
>>>
>>> *T. Pranavan*
>>> *BSc Eng Undergraduate| Department of Computer Science & Engineering
>>> ,University of Moratuwa*
>>> *Mobile| *0775136836
>>>
>>> On 9 August 2015 at 08:40, Sriskandarajah Suhothayan 
>>> wrote:
>>>
 Time window is to buffer events and expire based on some condition
 (time/length/etc), its not for creating new attributes by default. here the
 expired events are generated to inform the other processes the event have
 expired and hence they can do adjust their calculations based on that. If
 you dont have a avg() kind of aggregate functions on select then you dont
 need to send expired events.

 For you predictions how many inputs you have (input attributes used for
 production) and how many outputs will be generated (is it only one co
 efficient value)?
 If you are generating one value then you have to extend an Output
 aggregator. e.g.[1]

 Suho

 [1]
 https://svn.wso2.org/repos/wso2/carbon/platform/branches/turing/dependencies/commons/siddhi/2.0.0-wso2v5/modules/siddhi-core/src/main/java/org/wso2/siddhi/core/query/selector/attribute/handler/avg/AvgOutputAttributeAggregatorDouble.java

 On Sat, Aug 8, 2015 at 5:14 PM, Pranavan Theivendiram <
 pranavan...@cse.mrt.ac.lk> wrote:

> Hi All,
>
> I am working on writing a custom TimeWindowProcessor (SlidingWindow)
> to handle the curvefitting prediction. I followed the this implementation
> [1] and referred this documentation[2]. In my case, I need to get the
> events received during the 10 mins and use it for the calculation of the
> curve fitting and set the co efficient of curve fitting as a event. I am
> finding it hard to understand how the input events will reach the window
> processors and how the output events are passed throughout and what is the
> purpose of the processevent method. Processevent method is called in the
> run method on the expired events in the TimeWindowProcessor class. But 
> that
> is not the case I wanted.  I want to simply remove the expired eve

Re: [Dev] [CEP] Help on TimeWindowProcessor

[Pranavan Theivendiram]

Hi Suho,

The following is sample execution plan query. Here we are getting one
result as value. Can I get three values using this kind of queries?

*The Query* [1]


from health_second_der_concat [health_description == 'memory_consumption']
   *#window.stratos:secondDerivative(1 min, value)* select cluster_id,
cluster_instance_id, network_partition_id, value as
second_derivative_memory_consumption
   insert into second_derivative_memory_consumption_stats
   partition by health_second_der_cluster_partition;

*The annotation in SecondDerivativeWindowProcessor* [2]


@SiddhiExtension(namespace = "stratos", function = "secondDerivative")

Here they are getting only one value. Can you point me out a way that
I can have all three here?


Thanks


*T. Pranavan*
*BSc Eng Undergraduate| Department of Computer Science & Engineering
,University of Moratuwa*
*Mobile| *0775136836

On 9 August 2015 at 09:27, Sriskandarajah Suhothayan  wrote:

> Thats possible, you have to have 3 dummy fields on the input stream which
> you can populate at the window with the coefficients and output the
> events. Let me know if there are specific issues
>
> Suho
>
> On Sun, Aug 9, 2015 at 8:46 AM, Pranavan Theivendiram <
> pranavan...@cse.mrt.ac.lk> wrote:
>
>> Hi Suho,
>>
>> In my case, I am generating a second order polynomial(Three
>> coefficients). I am taking inputs of a 10 minute window.(A sliding window-
>> every one minute , the window will be get update. New events will come into
>> the window and the oldest events will get removed from the window)
>>
>> Thanks
>>
>> *T. Pranavan*
>> *BSc Eng Undergraduate| Department of Computer Science & Engineering
>> ,University of Moratuwa*
>> *Mobile| *0775136836
>>
>> On 9 August 2015 at 08:40, Sriskandarajah Suhothayan 
>> wrote:
>>
>>> Time window is to buffer events and expire based on some condition
>>> (time/length/etc), its not for creating new attributes by default. here the
>>> expired events are generated to inform the other processes the event have
>>> expired and hence they can do adjust their calculations based on that. If
>>> you dont have a avg() kind of aggregate functions on select then you dont
>>> need to send expired events.
>>>
>>> For you predictions how many inputs you have (input attributes used for
>>> production) and how many outputs will be generated (is it only one co
>>> efficient value)?
>>> If you are generating one value then you have to extend an Output
>>> aggregator. e.g.[1]
>>>
>>> Suho
>>>
>>> [1]
>>> https://svn.wso2.org/repos/wso2/carbon/platform/branches/turing/dependencies/commons/siddhi/2.0.0-wso2v5/modules/siddhi-core/src/main/java/org/wso2/siddhi/core/query/selector/attribute/handler/avg/AvgOutputAttributeAggregatorDouble.java
>>>
>>> On Sat, Aug 8, 2015 at 5:14 PM, Pranavan Theivendiram <
>>> pranavan...@cse.mrt.ac.lk> wrote:
>>>
 Hi All,

 I am working on writing a custom TimeWindowProcessor (SlidingWindow) to
 handle the curvefitting prediction. I followed the this implementation [1]
 and referred this documentation[2]. In my case, I need to get the events
 received during the 10 mins and use it for the calculation of the curve
 fitting and set the co efficient of curve fitting as a event. I am finding
 it hard to understand how the input events will reach the window processors
 and how the output events are passed throughout and what is the purpose of
 the processevent method. Processevent method is called in the run method on
 the expired events in the TimeWindowProcessor class. But that is not the
 case I wanted.  I want to simply remove the expired events, but rather
 calculate the curve coefficients on active events and to send the
 coefficient as output events. I am bit confused in flow and out flow to the
 TimeWindowProcessor class.

 If anyone can directly point out the input events in the
 TimeWindowProcessor class that would be a great help for me.I really expect
 a help in the form of the tutorial or some explanations on this or pointing
 out some custom TimeWindowProcessor class.

 Note : I already have written evenformatters and executionplans. This
 is the point I got stucked. I really can`t find a good explanation about
 the TimeWindowProcessor class.

 [1]
 https://svn.wso2.org/repos/wso2/carbon/platform/branches/turing/dependencies/commons/siddhi/2.0.0-wso2v5/modules/siddhi-core/src/main/java/org/wso2/siddhi/core/query/processor/window/TimeWindowProcessor.java
 [2]https://docs.wso2.com/display/CEP300/Windows#Windows-timeWindow

 Thank you.


 *T. Pranavan*
 *BSc Eng Undergraduate| Department of Comput

Re: [Dev] [CEP] Help on TimeWindowProcessor

[Sriskandarajah Suhothayan]

Thats possible, you have to have 3 dummy fields on the input stream which
you can populate at the window with the coefficients and output the events.
Let me know if there are specific issues

Suho

On Sun, Aug 9, 2015 at 8:46 AM, Pranavan Theivendiram <
pranavan...@cse.mrt.ac.lk> wrote:

> Hi Suho,
>
> In my case, I am generating a second order polynomial(Three coefficients).
> I am taking inputs of a 10 minute window.(A sliding window- every one
> minute , the window will be get update. New events will come into the
> window and the oldest events will get removed from the window)
>
> Thanks
>
> *T. Pranavan*
> *BSc Eng Undergraduate| Department of Computer Science & Engineering
> ,University of Moratuwa*
> *Mobile| *0775136836
>
> On 9 August 2015 at 08:40, Sriskandarajah Suhothayan 
> wrote:
>
>> Time window is to buffer events and expire based on some condition
>> (time/length/etc), its not for creating new attributes by default. here the
>> expired events are generated to inform the other processes the event have
>> expired and hence they can do adjust their calculations based on that. If
>> you dont have a avg() kind of aggregate functions on select then you dont
>> need to send expired events.
>>
>> For you predictions how many inputs you have (input attributes used for
>> production) and how many outputs will be generated (is it only one co
>> efficient value)?
>> If you are generating one value then you have to extend an Output
>> aggregator. e.g.[1]
>>
>> Suho
>>
>> [1]
>> https://svn.wso2.org/repos/wso2/carbon/platform/branches/turing/dependencies/commons/siddhi/2.0.0-wso2v5/modules/siddhi-core/src/main/java/org/wso2/siddhi/core/query/selector/attribute/handler/avg/AvgOutputAttributeAggregatorDouble.java
>>
>> On Sat, Aug 8, 2015 at 5:14 PM, Pranavan Theivendiram <
>> pranavan...@cse.mrt.ac.lk> wrote:
>>
>>> Hi All,
>>>
>>> I am working on writing a custom TimeWindowProcessor (SlidingWindow) to
>>> handle the curvefitting prediction. I followed the this implementation [1]
>>> and referred this documentation[2]. In my case, I need to get the events
>>> received during the 10 mins and use it for the calculation of the curve
>>> fitting and set the co efficient of curve fitting as a event. I am finding
>>> it hard to understand how the input events will reach the window processors
>>> and how the output events are passed throughout and what is the purpose of
>>> the processevent method. Processevent method is called in the run method on
>>> the expired events in the TimeWindowProcessor class. But that is not the
>>> case I wanted.  I want to simply remove the expired events, but rather
>>> calculate the curve coefficients on active events and to send the
>>> coefficient as output events. I am bit confused in flow and out flow to the
>>> TimeWindowProcessor class.
>>>
>>> If anyone can directly point out the input events in the
>>> TimeWindowProcessor class that would be a great help for me.I really expect
>>> a help in the form of the tutorial or some explanations on this or pointing
>>> out some custom TimeWindowProcessor class.
>>>
>>> Note : I already have written evenformatters and executionplans. This is
>>> the point I got stucked. I really can`t find a good explanation about the
>>> TimeWindowProcessor class.
>>>
>>> [1]
>>> https://svn.wso2.org/repos/wso2/carbon/platform/branches/turing/dependencies/commons/siddhi/2.0.0-wso2v5/modules/siddhi-core/src/main/java/org/wso2/siddhi/core/query/processor/window/TimeWindowProcessor.java
>>> [2]https://docs.wso2.com/display/CEP300/Windows#Windows-timeWindow
>>>
>>> Thank you.
>>>
>>>
>>> *T. Pranavan*
>>> *BSc Eng Undergraduate| Department of Computer Science & Engineering
>>> ,University of Moratuwa*
>>> *Mobile| *0775136836
>>>
>>> ___
>>> Dev mailing list
>>> Dev@wso2.org
>>> http://wso2.org/cgi-bin/mailman/listinfo/dev
>>>
>>>
>>
>>
>> --
>>
>> *S. Suhothayan*
>> Technical Lead & Team Lead of WSO2 Complex Event Processor
>> *WSO2 Inc. *http://wso2.com
>> * *
>> lean . enterprise . middleware
>>
>>
>> *cell: (+94) 779 756 757 <%28%2B94%29%20779%20756%20757> | blog:
>> http://suhothayan.blogspot.com/ twitter:
>> http://twitter.com/suhothayan  | linked-in:
>> http://lk.linkedin.com/in/suhothayan *
>>
>
>


-- 

*S. Suhothayan*
Technical Lead & Team Lead of WSO2 Complex Event Processor
*WSO2 Inc. *http://wso2.com
* *
lean . enterprise . middleware


*cell: (+94) 779 756 757 | blog: http://suhothayan.blogspot.com/
twitter: http://twitter.com/suhothayan
 | linked-in:
http://lk.linkedin.com/in/suhothayan *
___
Dev mailing list
Dev@wso2.org
http://wso2.org/cgi-bin/mailman/listinfo/dev

Re: [Dev] [CEP] Help on TimeWindowProcessor

[Pranavan Theivendiram]

Hi Suho,

In my case, I am generating a second order polynomial(Three coefficients).
I am taking inputs of a 10 minute window.(A sliding window- every one
minute , the window will be get update. New events will come into the
window and the oldest events will get removed from the window)

Thanks

*T. Pranavan*
*BSc Eng Undergraduate| Department of Computer Science & Engineering
,University of Moratuwa*
*Mobile| *0775136836

On 9 August 2015 at 08:40, Sriskandarajah Suhothayan  wrote:

> Time window is to buffer events and expire based on some condition
> (time/length/etc), its not for creating new attributes by default. here the
> expired events are generated to inform the other processes the event have
> expired and hence they can do adjust their calculations based on that. If
> you dont have a avg() kind of aggregate functions on select then you dont
> need to send expired events.
>
> For you predictions how many inputs you have (input attributes used for
> production) and how many outputs will be generated (is it only one co
> efficient value)?
> If you are generating one value then you have to extend an Output
> aggregator. e.g.[1]
>
> Suho
>
> [1]
> https://svn.wso2.org/repos/wso2/carbon/platform/branches/turing/dependencies/commons/siddhi/2.0.0-wso2v5/modules/siddhi-core/src/main/java/org/wso2/siddhi/core/query/selector/attribute/handler/avg/AvgOutputAttributeAggregatorDouble.java
>
> On Sat, Aug 8, 2015 at 5:14 PM, Pranavan Theivendiram <
> pranavan...@cse.mrt.ac.lk> wrote:
>
>> Hi All,
>>
>> I am working on writing a custom TimeWindowProcessor (SlidingWindow) to
>> handle the curvefitting prediction. I followed the this implementation [1]
>> and referred this documentation[2]. In my case, I need to get the events
>> received during the 10 mins and use it for the calculation of the curve
>> fitting and set the co efficient of curve fitting as a event. I am finding
>> it hard to understand how the input events will reach the window processors
>> and how the output events are passed throughout and what is the purpose of
>> the processevent method. Processevent method is called in the run method on
>> the expired events in the TimeWindowProcessor class. But that is not the
>> case I wanted.  I want to simply remove the expired events, but rather
>> calculate the curve coefficients on active events and to send the
>> coefficient as output events. I am bit confused in flow and out flow to the
>> TimeWindowProcessor class.
>>
>> If anyone can directly point out the input events in the
>> TimeWindowProcessor class that would be a great help for me.I really expect
>> a help in the form of the tutorial or some explanations on this or pointing
>> out some custom TimeWindowProcessor class.
>>
>> Note : I already have written evenformatters and executionplans. This is
>> the point I got stucked. I really can`t find a good explanation about the
>> TimeWindowProcessor class.
>>
>> [1]
>> https://svn.wso2.org/repos/wso2/carbon/platform/branches/turing/dependencies/commons/siddhi/2.0.0-wso2v5/modules/siddhi-core/src/main/java/org/wso2/siddhi/core/query/processor/window/TimeWindowProcessor.java
>> [2]https://docs.wso2.com/display/CEP300/Windows#Windows-timeWindow
>>
>> Thank you.
>>
>>
>> *T. Pranavan*
>> *BSc Eng Undergraduate| Department of Computer Science & Engineering
>> ,University of Moratuwa*
>> *Mobile| *0775136836
>>
>> ___
>> Dev mailing list
>> Dev@wso2.org
>> http://wso2.org/cgi-bin/mailman/listinfo/dev
>>
>>
>
>
> --
>
> *S. Suhothayan*
> Technical Lead & Team Lead of WSO2 Complex Event Processor
> *WSO2 Inc. *http://wso2.com
> * *
> lean . enterprise . middleware
>
>
> *cell: (+94) 779 756 757 <%28%2B94%29%20779%20756%20757> | blog:
> http://suhothayan.blogspot.com/ twitter:
> http://twitter.com/suhothayan  | linked-in:
> http://lk.linkedin.com/in/suhothayan *
>
___
Dev mailing list
Dev@wso2.org
http://wso2.org/cgi-bin/mailman/listinfo/dev

Re: [Dev] [CEP] Help on TimeWindowProcessor

[Sriskandarajah Suhothayan]

Time window is to buffer events and expire based on some condition
(time/length/etc), its not for creating new attributes by default. here the
expired events are generated to inform the other processes the event have
expired and hence they can do adjust their calculations based on that. If
you dont have a avg() kind of aggregate functions on select then you dont
need to send expired events.

For you predictions how many inputs you have (input attributes used for
production) and how many outputs will be generated (is it only one co
efficient value)?
If you are generating one value then you have to extend an Output
aggregator. e.g.[1]

Suho

[1]
https://svn.wso2.org/repos/wso2/carbon/platform/branches/turing/dependencies/commons/siddhi/2.0.0-wso2v5/modules/siddhi-core/src/main/java/org/wso2/siddhi/core/query/selector/attribute/handler/avg/AvgOutputAttributeAggregatorDouble.java

On Sat, Aug 8, 2015 at 5:14 PM, Pranavan Theivendiram <
pranavan...@cse.mrt.ac.lk> wrote:

> Hi All,
>
> I am working on writing a custom TimeWindowProcessor (SlidingWindow) to
> handle the curvefitting prediction. I followed the this implementation [1]
> and referred this documentation[2]. In my case, I need to get the events
> received during the 10 mins and use it for the calculation of the curve
> fitting and set the co efficient of curve fitting as a event. I am finding
> it hard to understand how the input events will reach the window processors
> and how the output events are passed throughout and what is the purpose of
> the processevent method. Processevent method is called in the run method on
> the expired events in the TimeWindowProcessor class. But that is not the
> case I wanted.  I want to simply remove the expired events, but rather
> calculate the curve coefficients on active events and to send the
> coefficient as output events. I am bit confused in flow and out flow to the
> TimeWindowProcessor class.
>
> If anyone can directly point out the input events in the
> TimeWindowProcessor class that would be a great help for me.I really expect
> a help in the form of the tutorial or some explanations on this or pointing
> out some custom TimeWindowProcessor class.
>
> Note : I already have written evenformatters and executionplans. This is
> the point I got stucked. I really can`t find a good explanation about the
> TimeWindowProcessor class.
>
> [1]
> https://svn.wso2.org/repos/wso2/carbon/platform/branches/turing/dependencies/commons/siddhi/2.0.0-wso2v5/modules/siddhi-core/src/main/java/org/wso2/siddhi/core/query/processor/window/TimeWindowProcessor.java
> [2]https://docs.wso2.com/display/CEP300/Windows#Windows-timeWindow
>
> Thank you.
>
>
> *T. Pranavan*
> *BSc Eng Undergraduate| Department of Computer Science & Engineering
> ,University of Moratuwa*
> *Mobile| *0775136836
>
> ___
> Dev mailing list
> Dev@wso2.org
> http://wso2.org/cgi-bin/mailman/listinfo/dev
>
>


-- 

*S. Suhothayan*
Technical Lead & Team Lead of WSO2 Complex Event Processor
*WSO2 Inc. *http://wso2.com
* *
lean . enterprise . middleware


*cell: (+94) 779 756 757 | blog: http://suhothayan.blogspot.com/
twitter: http://twitter.com/suhothayan
 | linked-in:
http://lk.linkedin.com/in/suhothayan *
___
Dev mailing list
Dev@wso2.org
http://wso2.org/cgi-bin/mailman/listinfo/dev