materialize
Class: management · Streaming: accumulating
Terminal stage: create a materialized view from the current pipeline.
Signature
| materialize <name> [retention=<duration>] [partition_by=<field_list>]
Positional Arguments
| Name | Type | Required | Description |
|---|---|---|---|
name | string | Yes | - |
Options
| Name | Type | Default | Description |
|---|---|---|---|
retention | duration | - | - |
partition_by | field_list | - | - |
Examples
stats count() by service, bin(_time, 5m) | materialize "mv_errors_5m" retention=90d
Generated from the LynxFlow registry. See RFC-002 for the full language specification.