Hi Chamin,
Are you going to do the validation at client side. Or are you going to
create a RDBMS, connect to it and get results and them compare those
results with incoming stream? Can you please explain your approach?
On Mon, Oct 27, 2014 at 11:33 AM, Chamin Nalinda wrote:
> Hi Saneth,
>
> Tha
Hi Saneth,
Thanks, it seems better I create db and tables and check the validity.
Appreciate your help.
On Mon, Oct 27, 2014 at 11:18 AM, Saneth Dharmakeerthi
wrote:
> HI Chamin,
>
> Try this and see.. [assuming that rejectedCount is a table]
>
> from inputStream [(pan == rejectedCount.pan and
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
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
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
