unique

thumbnail
(0)

Version 4.1.1  by WSO2

Category : Siddhi Execution
Supported Product Version : SP 4.0.0 SP 4.1.0 SP 4.2.0 SP 4.3.0 SP 4.4.0  

Summary

The siddhi-execution-unique extension is an extension to Siddhi that processes event streams based on unique events. Different types of unique windows are available to hold unique events based on the given unique key parameter.


Associated Tags

siddhi siddhi-execution unique

Features provided by unique extension


  • Ever window

    This is a window that is updated with the latest events based on a unique key parameter.
    When a new event that arrives, has the same value for the unique key parameter as an existing event, the existing event expires, and it is replaced by the later event.
  • ExternalTimeBatch window

    This is a batch (tumbling) time window that is determined based on external time (i.e., time stamps specified via an attribute in the events).
    It holds the latest unique events that arrived during the last window time period.
    The unique events are determined based on the value for a specified unique key parameter.
    When a new event arrives within the time window with a value for the unique key parameter that is the same as that of an existing event in the window, the existing event expires and it is replaced by the later event.
  • First Window

    This is a window that holds only the first unique events that are unique according to the unique key parameter.
    When a new event arrives with a key that is already in the window, that event is not processed by the window.
  • FirstLengthBatch window

    This is a batch (tumbling) window that holds a specific number of unique events (depending on which events arrive first).
    The unique events are selected based on a specific parameter that is considered as the unique key.
    When a new event arrives with a value for the unique key parameter that matches the same of an existing event in the window, that event is not processed by the window.
  • Length window

    This is a sliding length window that holds the latest window length unique events according to the unique key parameter and gets updated for each event arrival and expiry.
    When a new event arrives with the key that is already there in the window, then the previous event is expired and new event is kept within the window.
  • LengthBatch window

    This is a batch (tumbling) window that holds a specified number of latest unique events.
    The unique events are determined based on the value for a specified unique key parameter.
    The window is updated for every window length (i.e., for the last set of events of the specified number in a tumbling manner).
    When a new event that arrives within the a window length has the same value for the unique key parameter as an existing event is the window, the previous event is replaced by the new event.
  • Time window

    This is a sliding time window that holds the latest unique events that arrived during the last window time period.
    The unique events are determined based on the value for a specified unique key parameter.
    The window is updated with each event arrival and expiry.
    When a new event that arrives within a window time period has the same value for the unique key parameter as an existing event in the window, the previous event is replaced by the later event.
  • TimeBatch window

    This is a batch (tumbling) time window that is updated with the latest events based on a unique key parameter.
    If a new event that arrives within the window time period has a value for the key parameter which matches that of an existing event, the existing event expires and it is replaced by the later event.
  • TimeLengthBatch window

    This is a batch (tumbling) time length window that is updated with the latest events based on a unique key parameter.
    The window will tumble upon elapse of the time window or when length number of unique events have arrived.
    If a new event that arrives within the window period has a value for the key parameter which matches that of an existing event, the existing event expires and it is replaced by the later event.

Extension


Social Sites