Hello WSO2 community.
I am trying to implement a siddhi query where 1 event in publisher can have
multiple event in subscriber. this fits well in pattern query but it looks
like it outputs as soon as 1 event is matched and there is no way to window
or tell the count.
here is the execution plan i have came up with that should have matches all
mapping but its not working that way, it only outputs 1 event, the first
one that matches.
can someone please look at this and help me figure out why it is not
working? or what would be right way to get this?
Thanks
Jay
Execution Plan:
@Plan:name('TestExecutionPlan')
define stream publisher (pid string, time string);
define stream subscriber (pid string, sid string, time string);
@info(name = 'query2')
from every( e1=publisher ) -> e2=subscriber[ e2.pid == e1.pid ]
select e1.pid, e2.sid, e2.time
insert into AlertStream;
here is the sample events if you want to try on siddhi-try-it tool
publisher=[1,2017-08-15 01:08:30.253]
publisher=[2,2017-08-15 02:08:30.253]
publisher=[3,2017-08-15 03:08:30.253]
subscriber=[1, 12,2017-08-15 21:08:30.253]
subscriber=[1, 13,2017-08-15 21:10:30.253]
_______________________________________________
Dev mailing list
[email protected]
http://wso2.org/cgi-bin/mailman/listinfo/dev
