extrema
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.0Summary
The siddhi-execution-extrema extension is an extension to Siddhi that processes event streams based on different arithmetic properties. Different types of processors are available to extract the extremas from the event streams according to the specified attribute in the stream.
Features provided by extrema extension
-
bottomKLengthBatch
bottomKLengthBatch counts the frequency of different values of a specified attribute inside a batch window, and emits the lowest (k) number of frequency values. -
topKLengthBatch
topKLengthBatch counts the frequency of different values of a specified attribute inside a batch window, and emits the highest (k) number of frequency values. -
bottomK
bottomK counts the frequency of different values of a specified attribute, and emits the lowest (k) number of frequency values. -
topK
topK counts the frequency of different values of a specified attribute, and emits the highest (k) number of frequency values. -
bottomKTimeBatch
bottomKTimeBatch counts the frequency of different values of a specified attribute inside a time window, and emits the lowest (k) number of frequency values. -
topKTimeBatch
topKTimeBatch counts the frequency of different values of a specified attribute inside a time window, and emits the highest (k) number of frequency values. -
maxByLengthBatch
maxByLengthBatch calculates the maximum value of a specified attribute inside a batch window and emits it. -
minByLengthBatch
minByLengthBatch calculates the minimum value of a specified attribute within a batch window and emits it. -
maxByLength
minByLength calculates the maximum value of a specified attribute, and emits it. -
minByLength
minByLength calculates the minimum value of a specified attribute and emits it. -
maxByTimeBatch
maxByTimeBatch calculates the maximum value of a specified attribute within a time window, and emits it. -
minByTimeBatch
minByTimeBatch calculates the minimum value of a specified attribute within a time window and emits it. -
maxByTime
maxByTime calculates the maximum value of a specified attribute within a sliding time window and emits it. -
minByTime
minByTime calculates the minimum value of a specified attribute within a sliding time window and emits it. -
kalmanMinMax
kalmanMinMax uses the kalman filter to smooth the time series values in the given window size, and then determine the maxima and/or minima of that set of values. -
kernalMinMax
kernalMinMax uses Gaussian Kernel to smooth the time series values in the given window size, and then determine the maxima and minima of that set of values. -
minMax
minMax finds the minimum and/or the maximum value within a given length window (maxPreBound+maxPostBound), where following conditions are met.
Extension
Download the JAR files of released versextremans from Maven Central:
https://mvnrepository.com/artifact/org.wso2.extension.siddhi.execution.extrema/siddhi-execution-extrema
Social Sites