experimental.diff() function

experimental.diff() is subject to change at any time.

experimental.diff() takes two table streams as input and produces a diff.

experimental.diff() compares tables with the same group key. If compared tables are different, the function returns a table for that group key with one or more rows. If there are no differences, the function does not return a table for that group key.

Note: experimental.diff() cannot tell the difference between an empty table and a non-existent table.

Important: The output format of the diff is not considered stable and the algorithm used to produce the diff may change. The only guarantees are those mentioned above.

Function type signature
(<-got: stream[A], want: stream[A]) => stream[{A with _diff: string}]
For more information, see Function type signatures.



(Required) Input stream for the - side of the diff.


Input stream for the + side of the diff.


Output a diff between two streams of tables

import "sampledata"
import "experimental"

want =
got =
        |> map(fn: (r) => ({r with _value: if r._value > 15 then r._value + 1 else r._value}))

experimental.diff(got: got, want: want)

View example input

Return a diff between a stream of tables and the expected output

import "experimental"

want = from(bucket: "backup-example-bucket") |> range(start: -5m)

from(bucket: "example-bucket")
    |> range(start: -5m)
    |> experimental.diff(want: want)

Was this page helpful?

Thank you for your feedback!

Upgrade to InfluxDB Cloud or InfluxDB 2.0!

InfluxDB Cloud and InfluxDB OSS 2.0 ready for production.