Dear All
*In the Following Execution Plan the event staying forever in the one min
time window "ins#window.time(1 min)" *
/* Enter a unique ExecutionPlan */
@Plan:name('R_H_Match')
/* Enter a unique description for ExecutionPlan */
-- @Plan:description('ExecutionPlan')
/* define streams/tables and write queries here ... */
@Import('RelatedStream:1.0.0')
define stream rs (ID string, product string, uc1 string, state string,
brand string, model string, type string);
@Import('InputStream:1.0.0')
define stream ins (ID string, product string, uc1 string, state string,
brand string, model string, type string, tweet string);
@Export('matchingStream:1.0.0')
define stream ms (rID string, rproduct string, ruc1 string, rstate string,
rbrand string, rmodel string, rtype string, hID string, hproduct string,
huc1 string, hstate string, hbrand string, hmodel string, htype string);
from ins#window.time(1 min) as R
join rs#window.length(1) as H
on R.product == H.product and R.brand==H.brand and R.type==H.type and
R.state!=H.state
select R.ID as rID, R.product as rproduct , R.uc1 as ruc1 , R.state as
rstate, R.brand as rbrand , R.model as rmodel , R.type as rtype ,H.ID as
hID , H.product as hproduct , H.uc1 as huc1 , H.state as hstate , H.brand
as hbrand, H.model as hmodel , H.type as htype
insert into ms;
Thanks & Best Regards
--
*M.R.M.Rilfi
M.Sc in Computer Science (Reading) Moratuwa
B.Sc Sp. Computer Science
Dept. Computer Science & Engineering,University of Moratuwa
[email protected] <[email protected]> , [email protected] <[email protected]>
+94776284627 *
_______________________________________________
Dev mailing list
[email protected]
http://wso2.org/cgi-bin/mailman/listinfo/dev
