HI Chamin, Try this and see.. [assuming that rejectedCount is a table]
from inputStream [(pan == rejectedCount.pan and rejectedCount. rejected_count>=3) in rejectedCount)] select inputStream.pan insert into rejectedThreeTimesStream; Thanks and Best Regards, Saneth Dharmakeerthi Senior Software Engineer WSO2, Inc. Mobile: +94772325511 On Mon, Oct 27, 2014 at 11:09 AM, Chamin Nalinda <cha...@wso2.com> wrote: > follow the following query > > > // check pan count>=3 if yes rejectedThreeTimesStream > > from inputStream join rejectedCount[rejected_count>=3] > > on inputStream.pan = rejectedCount.pan > > select inputStream.pan > > insert into rejectedThreeTimesStream > > //else > > from inputStream join rejectedCount[rejectedCount <3] > > on inputStream.pan = rejectedCount.pan > > select * > > insert into OutStream > > > On Mon, Oct 27, 2014 at 11:04 AM, Chamin Nalinda <cha...@wso2.com> wrote: > >> Hi All, >> >> What I need from the below query to check, >> >> if the rejected_count >= 3, >> forward stream to rejectedThreeTimesStream >> else >> forward to outStream >> >> Here, rejectedCount table is a mysql table. >> >> Is this valid (below query) ? >> >> >> from inputStream join rejectedCount[rejected_count>=3] >> >> on inputStream.pan = countTable.pan >> >> select inputStream.pan >> insert into rejectedThreeTimesStream >> >> >> What is the recommended way of checking a mysql db table condition with >> incoming stream ? >> >> Regards >> >> >> -- >> *Chamin Nalinda* >> >> Intern - Engineering >> WSO2 Inc. http://www.wso2.com >> lean.enterprise.middleware >> >> Mobile: (+94) 77 241 66 04 >> Linkedin: https://www.linkedin.com/in/chaminnalinda >> Web: http://www.ckreativity.com >> Blog: http://techspiro.blogspot.com/ >> >> > > > -- > *Chamin Nalinda* > > Intern - Engineering > WSO2 Inc. http://www.wso2.com > lean.enterprise.middleware > > Mobile: (+94) 77 241 66 04 > Linkedin: https://www.linkedin.com/in/chaminnalinda > Web: http://www.ckreativity.com > Blog: http://techspiro.blogspot.com/ > > > _______________________________________________ > Dev mailing list > Dev@wso2.org > http://wso2.org/cgi-bin/mailman/listinfo/dev > >
_______________________________________________ Dev mailing list Dev@wso2.org http://wso2.org/cgi-bin/mailman/listinfo/dev
