extrema

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-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.

Associated Tags

extrema siddhi siddhi-execution

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