streamstats
Class: core · Streaming: row-at-a-time
Running/windowed values in row order.
Signature
| streamstats <aggs> [window=<int|duration>] [current=<bool>] [by=<field_list>]
Positional Arguments
| Name | Type | Required | Description |
|---|---|---|---|
aggs | agg_list | Yes | aggregates or window functions (lag, lead, row_number, ...) |
Options
| Name | Type | Default | Description |
|---|---|---|---|
window | `int | duration` | - |
current | bool | true | include the current row |
by | field_list | - | - |
Examples
streamstats window=3 avg(duration_ms) as rolling_avg
streamstats row_number() as rk by host
Generated from the LynxFlow registry. See RFC-002 for the full language specification.