Fix invalid values in cep query

revert-dabc3590
charitha 9 years ago
parent 042265bae1
commit 92973efc0c

@ -1,11 +1,11 @@
define stream fireAlarmEventStream (deviceID string, temp int); define stream fireAlarmEventStream (deviceID string, temp int);
from fireAlarmEventStream#window.time(7886776 sec) from fireAlarmEventStream#window.time(10 sec)
select deviceID, max(temp) as maxValue select deviceID, max(temp) as maxValue
group by deviceID group by deviceID
insert into analyzeStream for expired-events; insert into analyzeStream for expired-events;
from analyzeStream[maxValue < 88] from analyzeStream[maxValue < 60]
select maxValue select maxValue
insert into bulbOnStream; insert into bulbOnStream;
from fireAlarmEventStream[temp > 1093] from fireAlarmEventStream[temp > 60]
select deviceID, temp select deviceID, temp
insert into bulbOffStream; insert into bulbOffStream;
Loading…
Cancel
Save