[
https://issues.apache.org/jira/browse/STREAMPIPES-337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319073#comment-17319073
]
ASF subversion and git services commented on STREAMPIPES-337:
-------------------------------------------------------------
Commit 859660dfc86fc266b04c8ce113e05a37c4ca1e61 in incubator-streampipes's
branch refs/heads/STREAMPIPES-319 from Dominik Riemer
[ https://gitbox.apache.org/repos/asf?p=incubator-streampipes.git;h=859660d ]
Merge pull request #36 from sndp2693/STREAMPIPES-337
[STREAMPIPES-337] Add missing functionalities for Aggregations.
> 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
>
> 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.3.4#803005)
