Back to Influxdb

experimental.group() function

content/flux/v0/stdlib/experimental/group.md

latest3.1 KB
Original Source
<!------------------------------------------------------------------------------ IMPORTANT: This page was generated from comments in the Flux source code. Any edits made directly to this page will be overwritten the next time the documentation is generated. To make updates to this documentation, update the function comments above the function definition in the Flux source code: https://github.com/influxdata/flux/blob/master/stdlib/experimental/experimental.flux#L179-L179 Contributing to Flux: https://github.com/influxdata/flux#contributing Fluxdoc syntax: https://github.com/influxdata/flux/blob/master/docs/fluxdoc.md ------------------------------------------------------------------------------->

experimental.group() introduces an extend mode to the existing group() function.

Function type signature
js
(<-tables: stream[A], columns: [string], mode: string) => stream[A] where A: Record

{{% caption %}} For more information, see Function type signatures. {{% /caption %}}

Parameters

columns

({{< req >}}) List of columns to use in the grouping operation. Default is [].

mode

({{< req >}}) Grouping mode. extend is the only mode available to experimental.group().

Grouping modes

  • extend: Appends columns defined in the columns parameter to group keys.

tables

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

Examples

Add a column to the group key

js
import "experimental"

data
    |> experimental.group(columns: ["region"], mode: "extend")

{{< expand-wrapper >}} {{% expand "View example input and output" %}}

Input data

_time*hostregion_value
2021-01-01T00:00:00Zhost1east41
2021-01-01T00:01:00Zhost1east48
2021-01-01T00:00:00Zhost1west34
2021-01-01T00:01:00Zhost1west12
_time*hostregion_value
2021-01-01T00:00:00Zhost2east56
2021-01-01T00:01:00Zhost2east72
2021-01-01T00:00:00Zhost2west43
2021-01-01T00:01:00Zhost2west22

Output data

_time*host*region_value
2021-01-01T00:00:00Zhost1east41
2021-01-01T00:01:00Zhost1east48
_time*host*region_value
2021-01-01T00:00:00Zhost1west34
2021-01-01T00:01:00Zhost1west12
_time*host*region_value
2021-01-01T00:00:00Zhost2east56
2021-01-01T00:01:00Zhost2east72
_time*host*region_value
2021-01-01T00:00:00Zhost2west43
2021-01-01T00:01:00Zhost2west22

{{% /expand %}} {{< /expand-wrapper >}}