Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

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

    Code Block
    languagesql
    define trigger cronTriggerStream at '*/10 * * * * ?' ;
  • The following query merges the periodicalTriggerStream and sensorStream event streams. Only the values of the attributes specified in the query are merged. Attribute values are taken from the sensorStream event stream and inserted into the  periodicalTriggerStream event stream.

    Code Block
    languagesql
    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.  Only the values of the attributes specified in the query are merged. Attribute values are taken from the sensorStream event stream and inserted into the cronTrigerredSensorStream event stream.

    Code Block
    languagesql
    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 pageSet up the prerequisites required for all samples.

Building the sample

Start the WSO2 CEP server with the sample configuration numbered 0119. For instructions, see Starting sample CEP configurations. This sample configuration does the following:

...