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
_______________________________________________ Dev mailing list [email protected] http://wso2.org/cgi-bin/mailman/listinfo/dev
