Skip to Content
Create a Moving Average on an Event Stream Using an Aggregation Window

Create a Moving Average on an Event Stream Using an Aggregation Window

Beginner
20 min.
SAP HANA streaming analytics, Internet of Things, SAP HANA, express edition, Tutorial, Beginner
Add an aggregate window to create a moving average on the event data, smoothing out the raw data.
You will learn
  • How to add an aggregate window to hold multiple data entry and observe patterns
  • How to use a time-based sliding event window to compute metrics and monitor trends

Prerequisites

Unlike streams, which are stateless, windows are like tables that hold information from one event to the next. Here you will add an aggregate window that is keyed by MACHINEID, which will hold a set of aggregate values for each machine.

If you don’t want to use the visual editor, then you can skip to step 8 to view the CCL and copy it into your project.

  • Step 1

    Click on Aggregate in the Streams and Windows drawer of the Palette and then click on the canvas to add it to your project.

    drop aggregate window

    Rename the stream to AVG_TEMP by clicking on the aggregate symbol, then press Enter.

    rename
  • Step 2

    Select the Connector tool in the Palette and click on DEVICE_EVENTS first, then on AVG_TEMP to connect them.

    connector

    What is the fourth option in the list of Streams and Windows in the Palette?

  • Step 3

    Click the Add Column Expression ( f(x) ) button shown below.

    add column

    Choose Copy Columns from Input from the menu to open the column selection dialog.

    copy columns

    Select every option by clicking Select All or pressing Alt+s. Uncheck DEVICE_EVENTS.EVENT_NAME, DEVICE_EVENTS.EVENT_DESCRIPTION, and DEVICE_EVENTS.MACHINETYPE. Click OK.

    select columns to copy
  • Step 4

    Now you will set a retention policy on the input to this aggregation. This determines the set of events you are aggregating over. In this case, you’ll define it by time.

    Expand the Inputs tab and right-click on DEVICE_EVENTS. Select Keep Policy to open a dialog box to configure the policy.

    keep policy

    Click Time and enter 30 seconds in the entry box. Click OK.

    policy edit
  • Step 5

    To define the GROUP BY clause, expand the Group By compartment in the AVG_TEMP element by clicking on +.

    Double-click on GROUP BY unassigned_group_by.

    group info

    Select the entry DEVICE_EVENTS.MACHINEID, then click Add >> and OK.

    group criteria
  • Step 6

    Now you need to add a GROUP filter, since we only want to aggregate temperature readings. This will filter out the Door open/close events and the Power on/off events before you aggregate.

    Click the Add Group Clause ( { } ) button shown below.

    group filter clause

    Choose Group Filter Clause from the menu to add the group filter expression.

    click group filter clause

    Double-click on Group Filter 1.

    rename group filter

    Enter DEVICE_EVENTS.EVENT_NAME='TEMP' as the filter expression in the text field. You can use Ctrl+Space for content assist. Confirm your entry by pressing Enter.

    name group filter
  • Step 7

    Expand the Column Expressions compartment to edit expressions.

    go to column expression

    Double-click on DEVICE_EVENTS.EVENT_TIME.

    change event time

    Edit the expression for EVENT_TIME. Change it to: last(DEVICE_EVENTS.EVENT_TIME). This will cause the aggregate values for the group to show the event time of the last event received in the group. Confirm your entry by pressing Enter.

    last event time

    Double-click on the name EVENT_VALUE and rename this column to AVG_TEMP. Confirm your entry by pressing Enter.

    20-change event value name

    Double-click on the expression for AVG_TEMP, which is currently set to DEVICE_EVENTS.EVENT_VALUE.

    You are now going to edit this expression to compute an average. Also, since the value field is a string, before you can compute an average, you need to convert it to a number. Change the expression to: avg(to_decimal(DEVICE_EVENTS.EVENT_VALUE, 4, 2)). Confirm your entry by pressing Enter.

    average event value
  • Step 8

    At this point you can compile the project to check for errors. If you switch to the CCL editor ( F6 or click the Switch to Text button in the Eclipse toolbar), your code should look like this:

    SQL
    Copy

    /**@SIMPLEQUERY=AGGREGATE*/
CREATE OUTPUT WINDOW AVG_TEMP
PRIMARY KEY DEDUCED
KEEP ALL
AS SELECT
    DEVICE_EVENTS.MACHINEID MACHINEID ,
	LAST ( DEVICE_EVENTS.EVENT_TIME ) EVENT_TIME ,
	avg ( to_decimal(DEVICE_EVENTS.EVENT_VALUE, 4, 2) ) AVG_TEMP ,
	DEVICE_EVENTS.MAX_TEMP MAX_TEMP ,
	DEVICE_EVENTS.MIN_TEMP MIN_TEMP ,
	DEVICE_EVENTS.LOCATION LOCATION ,
	DEVICE_EVENTS.TEMP_UNIT TEMP_UNIT
FROM DEVICE_EVENTS KEEP 30 SEC
GROUP FILTER DEVICE_EVENTS.EVENT_NAME = 'TEMP'
GROUP BY DEVICE_EVENTS.MACHINEID ;
Back to Top
Back to top