increase() function

increase() returns the cumulative sum of non-negative differences between subsequent values.

The primary use case for increase() is tracking changes in counter values which may wrap overtime when they hit a threshold or are reset. In the case of a wrap/reset, increase() assumes that the absolute delta between two points is at least their non-negative difference.

Function type signature

(<-tables: stream[A], ?columns: [string]) => stream[B] where A: Record, B: Record

Parameters

columns

List of columns to operate on. Default is ["_value"].

tables

Input data. Default is piped-forward data (<-).

Examples

Normalize resets in counter metrics

import "sampledata"

sampledata.int()
    |> increase()