WSO2 Complex Event Processor is succeeded by WSO2 Stream Processor. To view the latest documentation for WSO2 SP, see WSO2 Stream Processor Documentation.

Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Syntax<long> distinctcount(<int|long|double|float|string> arg)
Extension TypeAggregate Function
DescriptionReturns the count of distinct occurrences for a given arg.
Parameterarg: The value that should be counted.
Return TypeReturns the count of distinct occurances for a given arg.
Example

distinctcount(pageID) for the following output returns 3.

 "WEB_PAGE_1"
 "WEB_PAGE_1"
 "WEB_PAGE_2"
 "WEB_PAGE_3"
 "WEB_PAGE_1"
 "WEB_PAGE_2"

...

Syntax<int|long|double|float> maxForever (<int|long|double|float> arg)
Extension TypeAggregate Function
DescriptionThis is the attribute aggregator to store the maximum value for a given attribute throughout the lifetime of the query regardless of any windows in-front.
Parameterarg: The value that needs to be compared to find the maximum value.
Return TypeReturns the maximum value in the same data type as the input.
ExamplemaxForever(temp) returns the maximum temp value recorded for all the events throughout the lifetime of the query.

Forever Minimum 
Anchor
Forever Minimum
Forever Minimum

Syntax<int|long|double|float> minForever (<int|long|double|float> arg)
Extension TypeAggregate Function
DescriptionThis is the attribute aggregator to store the minimum value for a given attribute throughout the lifetime of the query regardless of any windows in-front.
Parameterarg: The value that needs to be compared to find the minimum value.
Return TypeReturns the minimum value in the same data type as the input.
ExampleminForever(temp) returns the minimum temp value recorded for all the events throughout the lifetime of the query.
Excerpt
hiddentrue

average

Todo add other aggregate functions

...