2.8 KiB
2.8 KiB
title | description | menu | weight | flux/v0/tags | introduced | ||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
highestAverage() function | `highestAverage()` calculates the average of each input table and returns the highest `n` averages. |
|
101 |
|
0.7.0 |
highestAverage()
calculates the average of each input table and returns the
highest n
averages.
Note: highestAverage()
drops empty tables.
Function type signature
(<-tables: stream[A], n: int, ?column: string, ?groupColumns: [string]) => stream[B] where A: Record, B: Record
{{% caption %}} For more information, see Function type signatures. {{% /caption %}}
Parameters
n
({{< req >}}) Number of records to return.
column
Column to evaluate. Default is _value
.
groupColumns
List of columns to group by. Default is []
.
tables
Input data. Default is piped-forward data (<-
).
Examples
Return the highest table average from a stream of tables
import "sampledata"
sampledata.int()
|> highestAverage(n: 1, groupColumns: ["tag"])
{{< expand-wrapper >}} {{% expand "View example input and output" %}}
Input data
_time | _value | *tag |
---|---|---|
2021-01-01T00:00:00Z | -2 | t1 |
2021-01-01T00:00:10Z | 10 | t1 |
2021-01-01T00:00:20Z | 7 | t1 |
2021-01-01T00:00:30Z | 17 | t1 |
2021-01-01T00:00:40Z | 15 | t1 |
2021-01-01T00:00:50Z | 4 | t1 |
_time | _value | *tag |
---|---|---|
2021-01-01T00:00:00Z | 19 | t2 |
2021-01-01T00:00:10Z | 4 | t2 |
2021-01-01T00:00:20Z | -3 | t2 |
2021-01-01T00:00:30Z | 19 | t2 |
2021-01-01T00:00:40Z | 13 | t2 |
2021-01-01T00:00:50Z | 1 | t2 |
Output data
tag | _value |
---|---|
t2 | 8.833333333333334 |
{{% /expand %}} {{< /expand-wrapper >}}