The query I am trying to make work is :
@Import('SSHInStream:1.0.0')
define stream SSHInStream (ts string, uid string, id_orig_h string, id_orig_p
int, id_resp_h string, id_resp_p int, version int, client string, server
string, cipher_alg string, mac_alg string, compression_alg string, kex_alg
string, host_key_alg string, host_key string);
@Export('SSHOutStream:1.0.0')
define stream SSHOutStream (ts string, ssh_logins int);
from SSHInStream
select time:dateFormat(ts,'yyyy-MM-dd HH:mm') as ts, uid, id_orig_h, id_orig_p,
id_resp_h, id_resp_p
insert into intermediateStream;
from intermediateStream
select ts, count(ts) as ssh_logins
group by ts
insert into SSHOutStream;
And the error it generates is :
Different definition same as output stream definition
:StreamDefinition{id='SSHOutStream', attributeList=[Attribute{id='ts',
type=STRING}, Attribute{id='ssh_logins', type=LONG}], annotations=[]} already
exist as:StreamDefinition{id='SSHOutStream', attributeList=[Attribute{id='ts',
type=STRING}, Attribute{id='ssh_logins', type=INT}],
annotations=[Annotation{name='Export', elements=[Element{key='null',
value='SSHOutStream:1.0.0'}]}]} in execution plan "ExecutionPlan"
I am having a hard time to understand why compiler considering same streams as
two duplicates? I have studied samples given in WSO2CEP documentation and they
use the same syntax. Please help.
Regards, Aneela Safdar_______________________________________________
Dev mailing list
[email protected]
http://wso2.org/cgi-bin/mailman/listinfo/dev
