Page Comparison

@info(name = ‘query1') @dist(execGroup='group1')
from TempStream#window.time(2 min) 
select avg(temp) as avgTemp, roomNo, deviceID insert all events into AvgTempStream@App:name('Energy-Alert-App')
@App:description('Energy consumption and anomaly detection')

@source(type = 'http',  topic = 'device-power', @map(type = 'json'), @dist(parallel='2'))
define stream DevicePowerStream (type string, deviceID string, power int, roomID string);

@sink(type = 'email', to = '{{autorityContactEmail}}', username = 'john', address = 'john@gmail.com', password = 'test', subject = 'High power consumption of {{deviceID}}', @map(type = 'text', @payload('Device ID: {{deviceID}} of room : {{roomID}} power is consuming {{finalPower}}kW/h. ')))
define stream AlertStream (deviceID string, roomID string, initialPower double, finalPower double, autorityContactEmail string);

@info(name = ‘query2'monitered-filter') @dist(execGroup='group1001')
from TempStreamDevicePowerStream[temptype > 30.0]#window.time(1 min) as T join 
RegulatorStream[isOn ==false]#window.length(1) as R on T.roomNo == R.roomNo
select T.roomNo, R.deviceID, 'start' as action insert into RegulatorActionStream== 'monitored'] 
select deviceID, power, roomID 
insert current events into MonitoredDevicesPowerStream;

@info(name = 'power-increase-pattern')@dist(parallel='2', execGroup='002')
partition with (deviceID of MonitoredDevicesPowerStream)
begin
@info(name = 'avg-calculator')
from MonitoredDevicesPowerStream#window.time(2 min) 
select deviceID, avg(power) as avgPower, roomID 
insert current events into #AvgPowerStream;

@info(name = ‘query3') @dist(execGroup='group1''power-increase-detector')
from every( e1 =TempStream )#AvgPowerStream -> e2 =TempStream[e1.roomNo==roomNo and  #AvgPowerStream[(e1.tempavgPower + 5) <= temp avgPower] within 10 min 
select e1.roomNodeviceID as deviceID, e1.tempavgPower as initialTempinitialPower, e2.tempavgPower as finalPower, e1.roomID finalTemp
insert current events into AlertStreamRisingPowerStream;
end;


@info(name = ‘query4'power-range-filter') @dist(execGroupparallel='group22' ,parallel execGroup='2003')
from TempStream RisingPowerStream[(roomNofinalPower >= 100] and
roomNoselect < 110) and temp > 40 ] select roomNo, temp insert into HighTempStream;

deviceID, roomID, initialPower, finalPower, 'no-reply@powermanagement.com' as autorityContactEmail 
insert current events into AlertStream; 

@info(name = ‘query5'internal-filter') @dist(execGroup='group3' , parallel=’2’)
partition with ( deviceID of TempStream )
begin
    from TempStream#window.time(1 min)
    select roomNo, deviceID, temp, avg(temp) as avgTemp
    insert into #AvgTempStream;

    from #AvgTempStream[avgTemp > 20]#window.length(10)
    select roomNo, deviceID, max(temp) as maxTemp
    insert into deviceTempStream;
end;

004')
from DevicePowerStream[type == 'internal'] 
select deviceID, power 
insert current events into InternaltDevicesPowerStream;