MovingKeyCount
For each incoming key value, counts how many times that key appeared in the last window_size messages (sliding window).
- Input port i1: NumberData — key value
- Output port o1: NumberData — count of this key in the current window
Properties
| Property | Type | Description |
|---|---|---|
id | string | Operator identifier |
window_size | integer ≥ 1 | Sliding window size |
Use Case
Pre-filter for HAVING MOVING_COUNT(N) > threshold before a KeyedPipeline, so only active (frequently-seen) keys pass through.