CreateWindowRequest

Payload to create or update a processing window

namestringrequired

Example: payments-5min

profileIdstring

Associate with a profile (optional)

Example: acme-corp

windowTypeWindowType (string)required

Processing window strategy

Possible values: [TUMBLING, SLIDING, SESSION, TIME_BASED, COUNT_BASED, EVENT_TRIGGERED]

Example: TUMBLING

durationMsinteger<int64>

Window duration in milliseconds (time-based windows)

Example: 300000

maxRecordsinteger<int64>

Maximum records before flushing (count-based windows)

Example: 10000

cronExpressionstring

Flush schedule for TIME_BASED windows

Example: 0 0 * * *

allowLateArrivalsboolean

Accept records arriving after the window closes

Default value: false

latencyToleranceMsinteger<int64>

Grace period for late records (ms)

Example: 5000

CreateWindowRequest

{
  "name": "payments-5min",
  "profileId": "acme-corp",
  "windowType": "TUMBLING",
  "durationMs": 300000,
  "maxRecords": 10000,
  "cronExpression": "0 0 * * *",
  "allowLateArrivals": false,
  "latencyToleranceMs": 5000
}