Hi Lasantha, I am using it. But I have some problems in getting the snapshot events of 1 minute. Can you tell me a method how can I get those?
Thanks *T. Pranavan* *BSc Eng Undergraduate| Department of Computer Science & Engineering ,University of Moratuwa* *Mobile| *0775136836 On 16 July 2015 at 11:32, Lasantha Fernando <lasan...@wso2.com> wrote: > [Please copy dev list as well so that we can get input/feedback from a > wider community in any discussions] > > Hi Pranavan, > > If you want to output every 1 min, you can use output rate limiting of > Siddhi [1]. i.e. Keep a window of 10 min, and put output rate limiting to > output all every 1 min. > > Will that work for your usecase? Can you write your curve fitting > extension as a normal sliding time window and then put output rate limiting > in front of that window and see if that fits your usecase? > > [1] https://docs.wso2.com/display/CEP310/Output+Rate+Limiting > > Thanks, > Lasantha > > On 15 July 2015 at 20:41, Pranavan Theivendiram <pranavan...@cse.mrt.ac.lk > > wrote: > >> >> Hi Lasantha, >> The thing is that I have a window of 10 min. I am outputiing the events >> every one min. >> So I need to save the events as ten chunks of event lists. ( 10 lists of >> events) >> ? >> >> Is that possible? >> >> Thanks >> >> *T. Pranavan* >> *BSc Eng Undergraduate| Department of Computer Science & Engineering >> ,University of Moratuwa* >> *Mobile| *0775136836 >> >> On 15 July 2015 at 11:34, Lasantha Fernando <lasan...@wso2.com> wrote: >> >>> Hi Pranavan, >>> >>> Can you elaborate more on what you mean by keeping the events in 10 >>> blocks and removing and adding of 1 min of events? >>> >>> If you need to output when 10 events are accumulated, then you have to >>> write that logic where nextProcessor.process() is called in the run() >>> method. However, that would be similar to a length batch window, and you >>> won't be able to introduce any time constraint. >>> >>> If you want to process in batches of 10, you can modify the logic in >>> if(removeEvent == null) condition. >>> >>> Can you work a bit further to modify the logic as necessary for your >>> usecase? Then it will be easier to understand the issue you are facing by >>> looking at your code. >>> >>> Thanks, >>> Lasantha >>> >>> On 14 July 2015 at 21:58, Pranavan Theivendiram < >>> pranavan...@cse.mrt.ac.lk> wrote: >>> >>>> Kind remainder >>>> >>>> Thanks >>>> >>>> *T. Pranavan* >>>> *BSc Eng Undergraduate| Department of Computer Science & Engineering >>>> ,University of Moratuwa* >>>> *Mobile| *0775136836 >>>> >>>> On 14 July 2015 at 08:05, Pranavan Theivendiram < >>>> pranavan...@cse.mrt.ac.lk> wrote: >>>> >>>>> Hi Lasantha, >>>>> >>>>> I am implementing a Sliding Window Processor for cep 3.1.0. The >>>>> execution plans can be found in the link below. >>>>> 1- >>>>> https://github.com/Pranavan135/stratos/blob/CurveFittingGSoC/extensions/cep/artifacts/executionplans/CurveFinderOfHealthRequest.xml >>>>> >>>>> The implementation of Window Processor can be found below. >>>>> >>>>> 2 - >>>>> https://github.com/Pranavan135/stratos/blob/CurveFittingGSoC/extensions/cep/stratos-cep-extension/src/main/java/org/apache/stratos/cep/extension/CurveFinderWindowProcessor.java >>>>> >>>>> Can you please suggest me a method where I can keep the events 10 >>>>> blocks. (Removing and Adding of 1 min of events)? >>>>> >>>>> Thanks >>>>> *T. Pranavan* >>>>> *BSc Eng Undergraduate| Department of Computer Science & Engineering >>>>> ,University of Moratuwa* >>>>> *Mobile| *0775136836 >>>>> >>>> >>>> >>> >>> >>> -- >>> *Lasantha Fernando* >>> Senior Software Engineer - Data Technologies Team >>> WSO2 Inc. http://wso2.com >>> >>> email: lasan...@wso2.com >>> mobile: (+94) 71 5247551 >>> >> >> > > > -- > *Lasantha Fernando* > Senior Software Engineer - Data Technologies Team > WSO2 Inc. http://wso2.com > > email: lasan...@wso2.com > mobile: (+94) 71 5247551 >
_______________________________________________ Dev mailing list Dev@wso2.org http://wso2.org/cgi-bin/mailman/listinfo/dev
