Hi kasun, Thanks for the info.. On Tue, Oct 21, 2014 at 3:24 PM, Kasun De Silva <[email protected]> wrote:
> Hi Shashika, > > I belieive you have to write a custom OutputAggregator (see : > https://docs.wso2.com/display/CEP310/Writing+a+Custom+OutputAttributeAggregator) > and use it with length or time based window. > > I have done a similar project which implements a decaying aggregator. you > can find it from below link. > > svn link : > https://svn.wso2.com/wso2/interns/2013/Disk_Backed_and_Decayed_Window_for_CEP/decayingaggregator/ > > Thanks, > Kasun > > *Kasun de Silva* > Software Engineer | *WSO2 Inc.*; http://wso2.com > lean.enterprise.middleware > > email : [email protected] > mobile : +94 77 794 4260 > > > On Sun, Oct 19, 2014 at 5:19 PM, Lahiru Cooray <[email protected]> wrote: > >> Hi Awanthika, >> >> I totally agree with your point when we except result for each event. We >> can pass a single attribute to a custom function (in multiple >> events/streams) and store it. >> We wrote a function to calculate the cardinality (distinct event count in >> each stream).And there we updated a single instance for multiple streams. >> >> >> >> On Sun, Oct 19, 2014 at 4:31 PM, Awanthika Senarath <[email protected]> >> wrote: >> >>> Hi Lahiru, >>> >>> Yes, my bad. In that case he has to use a custom window. >>> >>> thanks and regards >>> >>> On Sun, Oct 19, 2014 at 3:21 PM, Lahiru Cooray <[email protected]> wrote: >>> >>>> Hi, >>>> I guess Shashika needs to read all the events in a single stream and >>>> out put a *single value.* >>>> >>>> *Stream1 * >>>> Event 1 >>>>> {BookID:'001'} {BookName:'aaa' } >>>> Event 2 >>>>> {BookID:'002'} {BookName:'bbb' } >>>> Event 3 >>>>> {BookID:'003'} {BookName:'ccc' } >>>> >>>> *Eg: Output the Book Count * >>>> >>>> As per my understanding we cannot use a custom function for this use >>>> case since it will output a result for each event. >>>> >>>> On Thu, Oct 16, 2014 at 6:42 PM, Shashika Karunatilaka < >>>> [email protected]> wrote: >>>> >>>>> Hi Mohanadarshan, >>>>> Thanks for the info, yes i have to go with the custom window. >>>>> >>>>> On Wed, Oct 15, 2014 at 6:03 PM, Mohanadarshan Vivekanandalingam < >>>>> [email protected]> wrote: >>>>> >>>>>> >>>>>> >>>>>> On Wed, Oct 15, 2014 at 5:52 PM, Shashika Karunatilaka < >>>>>> [email protected]> wrote: >>>>>> >>>>>>> Hi, >>>>>>> >>>>>> >>>>>> Hi Shashika, >>>>>> >>>>>> >>>>>>> >>>>>>> >>>>>> I'm in the process of creating siddhi custom function, its like an >>>>>>> aggregate function which inputs a set of data returns a single value. >>>>>>> Is there a way i can send data array to my custom function or else >>>>>>> can i handle that inside my custom function? >>>>>>> As an example there is a stream called "A", stream "A" has attribute >>>>>>> called "bookID", i need to pass all the bookID's in that stream to the >>>>>>> aggregate function and return a single value. >>>>>>> >>>>>>> >>>>>> Based on my understanding, i don't believe siddhi function is >>>>>> appropriate for your usecase.. You may need to use transform processor or >>>>>> window.. >>>>>> >>>>>> Thanks, >>>>>> Mohan >>>>>> >>>>>> >>>>>> >>>>>>> Thank you. >>>>>>> >>>>>>> -- >>>>>>> Shashika Prabath Karunatilaka, >>>>>>> Software Engineer, >>>>>>> WSO2, Inc: http://wso2.com/ >>>>>>> mobile : +94 77 7487792 >>>>>>> >>>>>>> _______________________________________________ >>>>>>> Dev mailing list >>>>>>> [email protected] >>>>>>> http://wso2.org/cgi-bin/mailman/listinfo/dev >>>>>>> >>>>>>> >>>>>> >>>>>> >>>>>> -- >>>>>> *V. Mohanadarshan* >>>>>> *Software Engineer,* >>>>>> *Data Technologies Team,* >>>>>> *WSO2, Inc. http://wso2.com <http://wso2.com> * >>>>>> *lean.enterprise.middleware.* >>>>>> >>>>>> email: [email protected] >>>>>> phone:(+94) 771117673 >>>>>> >>>>> >>>>> >>>>> >>>>> -- >>>>> Shashika Prabath Karunatilaka, >>>>> Software Engineer, >>>>> WSO2, Inc: http://wso2.com/ >>>>> mobile : +94 77 7487792 >>>>> >>>>> _______________________________________________ >>>>> Dev mailing list >>>>> [email protected] >>>>> http://wso2.org/cgi-bin/mailman/listinfo/dev >>>>> >>>>> >>>> >>>> >>>> -- >>>> *Lahiru Cooray* >>>> Software Engineer >>>> WSO2, Inc.;http://wso2.com/ >>>> lean.enterprise.middleware >>>> >>>> Mobile: +94 715 654154 >>>> >>>> _______________________________________________ >>>> Dev mailing list >>>> [email protected] >>>> http://wso2.org/cgi-bin/mailman/listinfo/dev >>>> >>>> >>> >>> >>> -- >>> Awanthika Senarath >>> Software Engineer, WSO2 Inc. >>> Mobile: +94717681791 >>> >>> >>> >> >> >> -- >> *Lahiru Cooray* >> Software Engineer >> WSO2, Inc.;http://wso2.com/ >> lean.enterprise.middleware >> >> Mobile: +94 715 654154 >> >> _______________________________________________ >> Dev mailing list >> [email protected] >> http://wso2.org/cgi-bin/mailman/listinfo/dev >> >> > -- Shashika Prabath Karunatilaka, Software Engineer, WSO2, Inc: http://wso2.com/ mobile : +94 77 7487792
_______________________________________________ Dev mailing list [email protected] http://wso2.org/cgi-bin/mailman/listinfo/dev
