increase() function

The increase() function calculates the total non-negative difference between values in a table. A main use case is tracking changes in counter values which may wrap over time when they hit a threshold or are reset. In the case of a wrap/reset, we can assume that the absolute delta between two points will be at least their non-negative difference.

Function type: Aggregate
Output data type: Float

increase(columns: ["_values"])



The list of columns for which the increase is calculated. Defaults to ["_value"].

Data type: Array of strings


from(bucket: "telegraf/autogen")
  |> range(start: -24h)
  |> filter(fn: (r) =>
    r._measurement == "system" and
    r._field == "n_users"
  |> increase()

Given the following input table:

_time _value
00001 1
00002 5
00003 3
00004 4

increase() produces the following table:

_time _value
00002 4
00003 7
00004 8

Function definition

increase = (tables=<-, columns=["_value"]) =>
		|> difference(nonNegative: true, columns:columns)
		|> cumulativeSum()

Bug Reports and Feedback

Thank you for being willing to help test InfluxDB v2.0 alpha! Feedback and bug reports are welcome and encouraged both for InfluxDB and this documentation.

Submit feedback in the InfluxData Community