schema.fieldsAsCols() function

schema.fieldsAsCols() is a special application of pivot() that pivots input data on _field and _time columns to align fields within each input table that have the same timestamp.

Function type signature

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

Parameters

tables

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

Examples

Pivot InfluxDB fields into columns

import "influxdata/influxdb/schema"

data
    |> schema.fieldsAsCols()