edgent-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Brandon Swink (JIRA)" <j...@apache.org>
Subject [jira] [Created] (EDGENT-246) Aggregate Function and Console
Date Tue, 06 Sep 2016 15:01:20 GMT
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)

Mime
View raw message