2.8 KiB
2.8 KiB
title | description | menu | weight | flux/v0/tags | introduced | ||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
experimental.distinct() function | `experimental.distinct()` returns unique values from the `_value` column. |
|
101 |
|
0.112.0 |
experimental.distinct()
returns unique values from the _value
column.
The _value
of each output record is set to a distinct value in the specified column.
null
is considered a distinct value.
experimental.distinct()
drops all columns not in the group key and
drops empty tables.
Function type signature
(<-tables: stream[{A with _value: B}]) => stream[{A with _value: B}]
{{% caption %}} For more information, see Function type signatures. {{% /caption %}}
Parameters
tables
Input data. Default is piped-forward data (<-
).
Examples
Return distinct values from each input table
import "experimental"
import "sampledata"
sampledata.int(includeNull: true)
|> experimental.distinct()
{{< 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 | t1 | |
2021-01-01T00:00:20Z | 7 | t1 |
2021-01-01T00:00:30Z | t1 | |
2021-01-01T00:00:40Z | t1 | |
2021-01-01T00:00:50Z | 4 | t1 |
_time | _value | *tag |
---|---|---|
2021-01-01T00:00:00Z | 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 | t2 | |
2021-01-01T00:00:50Z | 1 | t2 |
Output data
*tag | _value |
---|---|
t1 | -2 |
t1 | |
t1 | 7 |
t1 | 4 |
*tag | _value |
---|---|
t2 | |
t2 | 4 |
t2 | -3 |
t2 | 19 |
t2 | 1 |
{{% /expand %}} {{< /expand-wrapper >}}