Count Window Collector
This unit is a Processor unit type.
This unit keeps events in memory until a certain number of events is received. It can be configured to either use a global window for all events or to create a new window for each key.
An event comes in through the in port. The event is stored in the window associated with the event key. If the size of the window reaches the threshold, all events are released.
Windowed events are sent to the out output port.
If an error occurs, the input events are enriched with standard error fields and sent to the error port.
After dragging this unit into the Flow canvas, double-click it to access its configuration options. The following table describes the configuration options of this unit:
|Name||Enter a name for the unit. It must start with a letter, and cannot contain spaces. Only letters, numbers, and underscores are allowed.|
|Key field(s)||Enter the name of the input event field(s) containing key(s).|
|Size||The number of events in a window. Must be greater than 1.|
The number of events to purge from the window when it is considered complete. If it's equal to "size", a tumbling window is used. If it's smaller, a sliding window is used.
|Key(s) field||Enter a name for the output event field containing key(s).|
Enter a name for the output event field containing the window list.
|Size field||Enter a name for the output event field containing the window size.|
|in||All events enter through this port.|
|out||Outputs events properly stored.|
|error||Signals when an error occurs. Outputs input events enriched with standard error fields.|