You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@edgent.apache.org by "Dale LaBossiere (JIRA)" <ji...@apache.org> on 2016/09/12 19:35:20 UTC
[jira] [Closed] (EDGENT-246) Aggregate Function and Console
[ https://issues.apache.org/jira/browse/EDGENT-246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Dale LaBossiere closed EDGENT-246.
----------------------------------
Resolution: Invalid
Closing this "question" jira. Please use dev@edgent.apache.org for any follow-on questions.
> 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
> Priority: Trivial
> 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)