Hi Pranavan, Based on your previous questions, I assume you're using siddhi 2.0.0-wso2v5. Please find my response inline.
On Wed, Aug 19, 2015 at 5:00 PM, Pranavan Theivendiram < [email protected]> wrote: > How often the run method of WindowProcessor will be called? > This depends on the specific implementation. For instance, in TimeWindowProcessor [1], each time we put an event into the window, we schedule an event-removing executor which will run t milliseconds later (where t is window size) So, basically run() will be called once for each time an event is put into the window. However, in distributed mode, if the delay isn't enough, run() can be invoked even more than that. To learn about what actually happens, you may try debugging a testcase such as 'WindowTestCase' [2] Are there any ways that I can control(Schedulers) ? > Could you please elaborate more on your requirement/usecase - as what exactly you want to control? [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://svn.wso2.org/repos/wso2/carbon/platform/branches/turing/dependencies/commons/siddhi/2.0.0-wso2v5/modules/siddhi-core/src/test/java/org/wso2/siddhi/test/standard/WindowTestCase.java Thanks, Dilini > > Can anyone explain me on this? > > Thanks > *T. Pranavan* > *BSc Eng Undergraduate| Department of Computer Science & Engineering > ,University of Moratuwa* > *Mobile| *0775136836 > > _______________________________________________ > Dev mailing list > [email protected] > http://wso2.org/cgi-bin/mailman/listinfo/dev > > -- *Dilini Muthumala* Software Engineer, WSO2 Inc. *E-mail :* [email protected] *Mobile: *+94 713-400-029
_______________________________________________ Dev mailing list [email protected] http://wso2.org/cgi-bin/mailman/listinfo/dev
