[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 <[email protected]> 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 <[email protected]> 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 < >> [email protected]> 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 < >>> [email protected]> 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: [email protected] >> mobile: (+94) 71 5247551 >> > > -- *Lasantha Fernando* Senior Software Engineer - Data Technologies Team WSO2 Inc. http://wso2.com email: [email protected] mobile: (+94) 71 5247551
_______________________________________________ Dev mailing list [email protected] http://wso2.org/cgi-bin/mailman/listinfo/dev
