GroupByDynamicStage

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

opOp (string)필수

상수 값: group_by_dynamic

index_columnIndex Column (string)필수

everyEvery (string)필수

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
• null

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
• null

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]

기본값: left

by object

하나 이상(anyOf)

• string[]
• null

Array [

string

]

agg object[]필수

Array [

nameName (string)필수

Output column name

exprExpr (string)필수

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"
    }
  ]
}