Skip to main content

GroupByDynamicStage

Aggregate into time (or integer-index) windows over a sorted index column.

opOp (string)required
Constant value: group_by_dynamic
index_columnIndex Column (string)required
everyEvery (string)required

Possible values: Value must match regular expression ^-?[0-9]+(ns|us|ms|s|m|h|d|w|mo|q|y|i)$

period object

Window length; defaults to every

anyOf
string

Possible values: Value must match regular expression ^-?[0-9]+(ns|us|ms|s|m|h|d|w|mo|q|y|i)$

offset object

Window boundary offset; defaults to 0

anyOf
string

Possible values: Value must match regular expression ^-?[0-9]+(ns|us|ms|s|m|h|d|w|mo|q|y|i)$

closedClosed (string)

Possible values: [left, right, both, none]

Default value: left
by object
anyOf
  • Array [
    • string
  • ]
    • agg object[]required
  • Array [
    • nameName (string)required

    Output column name

    exprExpr (string)required

    Polars-SQL expression, e.g. 'qty * unit_price'

  • ]
    • GroupByDynamicStage
    {
      "op": "group_by_dynamic",
      "index_column": "string",
      "every": "string",
      "period": "string",
      "offset": "string",
      "closed": "left",
      "by": [
        "string"
      ],
      "agg": [
        {
          "name": "string",
          "expr": "string"
        }
      ]
    }