Brandon Swink created EDGENT-246:
------------------------------------
Summary: Aggregate Function and Console
Key: EDGENT-246
URL: https://issues.apache.org/jira/browse/EDGENT-246
Project: Edgent
Issue Type: Task
Components: Analytics
Affects Versions: 0.4.0
Environment: Demonstration (Meetup)
Reporter: Brandon Swink
Fix For: 0.4.0
I would like to use this function in a demo for my meetup in the next few weeks
and my modification seems to have a compile error on the aggregate. I would
also like to couple it with the Edgent Console. Do I need to modify this code
to include the console or do I need to trigger using another component?
//*****CODE
// Create a window on the stream of the last 50 readings partitioned
//TWindow<JsonObject,JsonElement> sensorWindow = sensors.last(50, j ->
j.get("ts"));
TWindow<JsonObject,Integer> sensorWindow = sensors.last(50,
unpartitioned());
// Aggregate the windows calculating the min, max, mean standard
deviation and Slope across each window independently.
sensors =
JsonAnalytics.aggregate(sensorWindow,"cpuTemperature","cpuVoltage", MIN, MAX,
MEAN, STDDEV, SLOPE);
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
