stateCount() returns the number of consecutive rows in a given state.
The state is defined by the
fn predicate function. For each consecutive
record that evaluates to
true, the state count is incremented. When a record
false, the value is set to
-1 and the state count is reset.
If the record generates an error during evaluation, the point is discarded,
and does not affect the state count.
The state count is added as an additional column to each record.
Function type signature
(<-tables: stream[A], fn: (r: A) => bool, ?column: string) => stream[B] where A: Record, B: Record
(Required) Predicate function that identifies the state of a record.
Column to store the state count in. Default is
Input data. Default is piped-forward data (
Count the number rows in a specific state
import "sampledata" sampledata.int() |> stateCount(fn: (r) => r._value < 10)
Was this page helpful?
Thank you for your feedback!
Support and feedback
Thank you for being part of our community! We welcome and encourage your feedback and bug reports for Flux and this documentation. To find support, use the following resources:
Customers with an annual or support contract can contact InfluxData Support.