Hi,
We had several offline discussions on the results returned by the following
partition by range Siddhi query. This query simply drops events which are
in the range 100-149 because those events do not fall into either small or
large partitions. Ideally we should throw an error when parsing this Siddhi
query since it does not include a partition for the (price>=100 and price
<150) case. However, currently Siddhi does not throw such error. We might
think of such scenario as user may not really interested of the values
between 100-149 and hence we should ignore that range. But it could lead to
errors which are created unintentionally because user might actually forget
to address the range 100-149. In such situation, throwing an error will
make the user to address the range 100-149 properly. Therefore, we should
throw an error if the user forget to cover the complete range of values in
a partition by range Siddhi query. WDYT?
@app:name('incrementalPersistenceTest10')
define stream cseEventStreamOne (symbol string, price float,volume int);
partition with (price<100 as 'small' or price>=150 as 'large' of
cseEventStreamOne)
begin @info(name = 'query1')
from cseEventStreamOne#window.length(4)
select symbol,sum(price) as price group by symbol insert into
OutStockStream ;
end
--
Thanks,
Miyuru Dayarathna
Senior Technical Lead
Mobile: +94713527783
Blog: http://miyurublog.blogspot.com
_______________________________________________
Architecture mailing list
[email protected]
https://mail.wso2.org/cgi-bin/mailman/listinfo/architecture
