Skip to main content

WindowRead Node

The WindowRead Node gets timestamp to the Input Port, requests counted aggregates, sends the selected aggregates to the Output Ports.

WindowRead Node
WindowRead Node

The WindowRead Node may get optional key to the Input Port to request windows counted for the key.

On the example above the WindowRead Node gets a pair of timestamp and key to the Input Port, and counts SUM by key for the 3 latests 5 seconds windows.

The optional window_ts Output Port sends the value of right boundary of the the latest completed window.

The WindowRead Node requires additional Configuration Parameters to be defined:

  • Aggregator. The function applied to the counted windows from the following list SUM, MEAN, MAX, MIN.
  • Default Empty Value. The value returned if the counted windows doesn't contain any values.
  • Collection name. The obligatory name for the collection of aggregates. Collection name is used by the WindowWrite Node to store windows.
  • Window size. The duration of the window in seconds from 0 to 172800 sec (48 hours).
  • Step size The offset between neighbour windows in seconds from 0 to 172800 seс (48 hours)