Description
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.
Configuration
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:
Tab | Field | Description |
|---|---|---|
General | Name | Enter a name for the unit. It must start with a letter, and cannot contain spaces. Only letters, numbers, and underscores are allowed. |
Description | Enter a description detailing the scope of the unit. | |
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. | |
Purge size | 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). | |
Window field | 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. |
Input ports
Port | Description |
|---|---|
in | All events enter through this port. |
Output ports
Port | Description |
|---|---|
out | Outputs events properly stored. |
error | Signals when an error occurs. Outputs input events enriched with standard error fields. |
Example
In this example, we wish to accumulate five 404 status codes and send them via email when the threshold has been met to alert of the error.
To do this, we add a Tick unit to fire the request every time we need it. Then, we link it to the input port of the Count Window Collector unit and join its output port to an Email Sink unit to send it to the required recipients.
In the Tick unit, configure the key field to return the status code every time a 404 code is detected.
In the Count Window Collector properties, specify the key field that coincides with the Tick unit, in this case the 404StatusCode field earlier configured. Add the purge size as the same as the size field, in this case 5, to use a tumbling window.
In the Email Sink unit properties, you must specify the required subject and message of the emails and the list of addresses to which you want to notify.
📁 Download this example
You can try this flow by downloading the following JSON file and uploading it to your domain using the Import option: