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!

The future of Flux

Flux is going into maintenance mode. You can continue using it as you currently are without any changes to your code.

Read more