@info(name='Input stream from device with current loop id')

define stream inputStream (timeStamp long, count int, value1 float, value2 double, timeS1 long, isCondition bool);

@sink(type='log')
define stream outputStream (count int, value2 object, value1 object);

from inputStream
select count, list:collect(value2) as v2 , list:collect(value1) as v1, isCondition
insert into stream1;

from stream1[isCondition == true]
select count, v2 as value2, v1 as value1
insert into outputStream;