parent
0914b94dfc
commit
d211f3e358
@ -0,0 +1,11 @@
|
||||
define stream fireAlarmEventStream (deviceID string, temp int);
|
||||
from fireAlarmEventStream#window.time(7886776 sec)
|
||||
select deviceID, max(temp) as maxValue
|
||||
group by deviceID
|
||||
insert into analyzeStream for expired-events;
|
||||
from analyzeStream[maxValue < 88]
|
||||
select maxValue
|
||||
insert into bulbOnStream;
|
||||
from fireAlarmEventStream[temp > 1093]
|
||||
select deviceID, temp
|
||||
insert into bulbOffStream;
|
Loading…
Reference in new issue