Page Comparison

...

This sample demonstrates how to set up an execution plan to process events of one stream and forward the processed events to two other streams. This sample uses the Event simulator for inputs and the logger publisher for logging the outputs to the CEP console.

The execution plan used in this sample is as follows.

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

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

• 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;

• 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;

Prerequisites

See Prerequisites in the CEP Samples Setup page.

...