You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@streampipes.apache.org by "Dominik Riemer (Jira)" <ji...@apache.org> on 2022/11/26 14:26:00 UTC
[jira] [Commented] (STREAMPIPES-337) Add missing functionalities for Aggregations in Siddhi wrapper/processors
[ https://issues.apache.org/jira/browse/STREAMPIPES-337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17639227#comment-17639227 ]
Dominik Riemer commented on STREAMPIPES-337:
--------------------------------------------
This issue has been migrated to https://github.com/apache/streampipes/issues/527
> Add missing functionalities for Aggregations in Siddhi wrapper/processors
> -------------------------------------------------------------------------
>
> Key: STREAMPIPES-337
> URL: https://issues.apache.org/jira/browse/STREAMPIPES-337
> Project: StreamPipes
> Issue Type: Task
> Components: Backend, Pipeline Elements
> Reporter: Sandeep Kumar
> Priority: Major
> Labels: pull-request-available, suggestion-done
>
> Currently we have support of count aggregation function in Siddhi wrapper. Extend that to include below aggregation functions :
>
> [https://siddhi.io/en/v5.1/docs/query-guide/#aggregate-function] :
> |[sum|https://siddhi.io/en/v5.1/docs/api/latest/#sum-aggregate-function]|Calculates the sum from a set of values.|
> |[count|https://siddhi.io/en/v5.1/docs/api/latest/#count-aggregate-function]|Calculates the count from a set of values.|
> |[distinctCount|https://siddhi.io/en/v5.1/docs/api/latest/#distinctcount-aggregate-function]|Calculates the distinct count based on a parameter from a set of values.|
> |[avg|https://siddhi.io/en/v5.1/docs/api/latest/#avg-aggregate-function]|Calculates the average from a set of values.|
> |[max|https://siddhi.io/en/v5.1/docs/api/latest/#max-aggregate-function]|Finds the maximum value from a set of values.|
> |[min|https://siddhi.io/en/v5.1/docs/api/latest/#min-aggregate-function]|Finds the minimum value from a set of values.|
> |[maxForever|https://siddhi.io/en/v5.1/docs/api/latest/#maxforever-aggregate-function]|Finds the maximum value from all events throughout its lifetime irrespective of the windows.|
> |[minForever|https://siddhi.io/en/v5.1/docs/api/latest/#minforever-aggregate-function]|Finds the minimum value from all events throughout its lifetime irrespective of the windows.|
> |[stdDev|https://siddhi.io/en/v5.1/docs/api/latest/#stddev-aggregate-function]|Calculates the standard deviation from a set of values.|
> |[and|https://siddhi.io/en/v5.1/docs/api/latest/#and-aggregate-function]|Calculates boolean {{and}} from a set of values.|
> |[or|https://siddhi.io/en/v5.1/docs/api/latest/#or-aggregate-function]|Calculates boolean {{or}} from a set of values.|
> |[unionSet|https://siddhi.io/en/v5.1/docs/api/latest/#unionset-aggregate-function]|Constructs a Set by unioning set of values.|
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)