Page Comparison

...

The execution plan used in this sample is as follows.

• The following query triggers an event in the periodicalTriggerStream event stream every 5 seconds.

  Code Block
  language sql
  define trigger periodicalTriggerStream at every 5 sec ;

• The following query forwards a processed event as an output to the cronTriggerStream every 10 seconds.

  Code Block
  language sql
  define trigger cronTriggerStream at '*/10 * * * * ?' ;

• The following query merges the periodicalTriggerStream and sensorStream event streams.

  Code Block
  language sql
  from periodicalTriggerStream join sensorStream#window.time(10 sec) select meta_timestamp, meta_isPowerSaverEnabled, meta_sensorId, meta_sensorName, correlation_longitude, correlation_latitude, triggered_time, humidity, sensorValue insert into periodicalTriggeredSensorStream;

• The following query merges the cronTriggerStream and sensorStream event streams

  Code Block
  language sql
  from cronTriggerStream join sensorStream#window.time(10 sec) select meta_timestamp, meta_isPowerSaverEnabled, meta_sensorId, meta_sensorName, correlation_longitude, correlation_latitude, triggered_time, humidity, sensorValue insert into cronTriggeredSensorStream;

...