Hi Suho, Re attaching Srinath's test case for your reference.
Thanks Rajeev On Thu, Sep 26, 2013 at 9:03 PM, Sriskandarajah Suhothayan <[email protected]>wrote: > please write a test case in siddhi and give a patch > so I/We can run and see and verify > > Suho > > > On Thu, Sep 26, 2013 at 12:45 AM, Rajeev Sampath <[email protected]> wrote: > >> >> Copying dev list. >> >> ---------- Forwarded message ---------- >> From: Rajeev Sampath <[email protected]> >> Date: Thu, Sep 26, 2013 at 1:12 PM >> Subject: Re: CEP sample >> To: Srinath Perera <[email protected]> >> >> >> It seems all aggregation functions over joins (including window joins) >> are not functioning properly. They keep accumulating everything over time. >> I'll look into this. >> >> For array index out of bounds, the delete query can be fixed as follows: >> >> from InstanceHealth[action=='down'] >> delete liveInstances >> on ip==liveInstances.ip >> >> >> Thanks >> >> >> On Thu, Sep 26, 2013 at 6:46 AM, Srinath Perera <[email protected]> wrote: >> >>> Hi Rajeev, >>> >>> If I remove the following line, it still shows as 2 even with group by. >>> >>> stream1Handle1.send(new Object[]{"qsb", System.currentTimeMillis(), >>> "up", "192.121.0.2"}); >>> >>> Also do you find why array index outof bound happend when I uncomment >>> >>> >>> //stream1Handle1.send(new Object[]{"qsb", System.currentTimeMillis(), >>> "down", "192.121.0.1"}); >>> >>> --Srinath >>> >>> >>> >>> >>> >>> >>> >>> On Thu, Sep 26, 2013 at 12:02 AM, Rajeev Sampath <[email protected]>wrote: >>> >>>> Seems this is because group by is not used in the query. >>>> >>>> from StratosHealth as h unidirectional join liveInstances as ls >>>> on h.domain==ls.domain >>>> select count(ls.ip) as instanceCount, h.connections as connections >>>> group by ls.ip >>>> insert into AutoscaleData >>>> >>>> >>>> Again, this can still result in duplicate events since siddhi will emit >>>> the events in the resulting joined table instead of one event. >>>> >>>> >>>> On Wed, Sep 25, 2013 at 4:02 PM, Srinath Perera <[email protected]>wrote: >>>> >>>>> >>>>> >>>>> -- >>>>> ============================ >>>>> Srinath Perera, Ph.D. >>>>> Director, Research, WSO2 Inc. >>>>> Visiting Faculty, University of Moratuwa >>>>> Member, Apache Software Foundation >>>>> Research Scientist, Lanka Software Foundation >>>>> Blog: http://srinathsview.blogspot.com/ >>>>> Photos: http://www.flickr.com/photos/hemapani/ >>>>> Phone: 0772360902 >>>>> >>>> >>>> >>>> >>>> -- >>>> Rajeev Sampath >>>> Senior Software Engineer >>>> WSO2, Inc.; http://www.wso2.com. >>>> >>>> Mobile:* +94716265766 >>>> * >>>> >>> >>> >>> >>> -- >>> ============================ >>> Srinath Perera, Ph.D. >>> Director, Research, WSO2 Inc. >>> Visiting Faculty, University of Moratuwa >>> Member, Apache Software Foundation >>> Research Scientist, Lanka Software Foundation >>> Blog: http://srinathsview.blogspot.com/ >>> Photos: http://www.flickr.com/photos/hemapani/ >>> Phone: 0772360902 >>> >> >> >> >> -- >> Rajeev Sampath >> Senior Software Engineer >> WSO2, Inc.; http://www.wso2.com. >> >> Mobile:* +94716265766 >> * >> >> >> >> -- >> Rajeev Sampath >> Senior Software Engineer >> WSO2, Inc.; http://www.wso2.com. >> >> Mobile:* +94716265766 >> * >> > > > > -- > *S. Suhothayan > * > Associate Technical Lead, > *WSO2 Inc. *http://wso2.com * > <http://wso2.com/>* > lean . enterprise . middleware > > *cell: (+94) 779 756 757 | blog: http://suhothayan.blogspot.com/ > twitter: http://twitter.com/suhothayan | linked-in: > http://lk.linkedin.com/in/suhothayan* > * > * > -- Rajeev Sampath Senior Software Engineer WSO2, Inc.; http://www.wso2.com. Mobile:* +94716265766 *
SiddhiQuery1.java
Description: Binary data
_______________________________________________ Dev mailing list [email protected] http://wso2.org/cgi-bin/mailman/listinfo/dev
