This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch STREAMPIPES-319
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git.
from c121c68 [STREAMPIPES-319] Refactor environment variable provider
add 606fb96 Added new entries to streampipes vocabulary
add 793a362 updated flinkruntime jobstatus checks
add f65b27c Merge pull request #33 from mfaizanse/dev
add f2d26de Merge branch 'dev' of github.com:apache/incubator-streampipes
into dev
add 67f782f [STREAMPIPES-174] add missing http protocol to url
add 774da0b [STREAMPIPES-336] removed connect-master service build
section from docker-compose.yml
add 35b6e11 STREAMPIPES-336:removed connect-master service build section
from docker-compose.yml
add dd06736 removed connect-master service build section from
docker-compose.yml
add 326790f Merge branch 'STREAMPIPES-336' of
https://github.com/sndp2693/incubator-streampipes into STREAMPIPES-336
add 34ed26b Merge branch 'STREAMPIPES-336' of
https://github.com/sndp2693/incubator-streampipes into STREAMPIPES-336
add 3c968db Merge pull request #35 from sndp2693/STREAMPIPES-336
add c0ebbb9 [STREAMPIPES-337] Add missing functionalities for
Aggregations in Siddhi wrapper
add 859660d Merge pull request #36 from sndp2693/STREAMPIPES-337
add a566e3a [STREAMPIPES-337] Added ASF license information
add 1daef26 Merge pull request #37 from sndp2693/STREAMPIPES-337
add 02ab3dd Merge branch 'dev' of github.com:apache/incubator-streampipes
into dev
new 52b6f07 Merge branch 'dev' into STREAMPIPES-319
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
docker-compose.yml | 18 -------
.../java/org/apache/streampipes/vocabulary/SO.java | 2 +
.../apache/streampipes/vocabulary/SPSensor.java | 6 +++
.../streampipes/wrapper/flink/FlinkRuntime.java | 22 ++++++--
.../siddhi/query/expression/Expressions.java | 60 +++++++++++++++++++++-
...untExpression.java => AggregationFunction.java} | 39 +++++++-------
.../{CountExpression.java => AndExpression.java} | 31 ++++++-----
...CountExpression.java => AverageExpression.java} | 28 +++++-----
.../expression/aggregation/CountExpression.java | 2 +-
...xpression.java => DistinctCountExpression.java} | 28 +++++-----
.../{CountExpression.java => MaxExpression.java} | 28 +++++-----
...ntExpression.java => MaxForeverExpression.java} | 27 +++++-----
.../{CountExpression.java => MinExpression.java} | 28 +++++-----
...ntExpression.java => MinForeverExpression.java} | 28 +++++-----
.../{CountExpression.java => OrExpression.java} | 28 +++++-----
...ssion.java => StandardDeviationExpression.java} | 27 +++++-----
.../{CountExpression.java => SumExpression.java} | 26 +++++-----
...ountExpression.java => UnionSetExpression.java} | 28 +++++-----
.../StreamPipesExternalDataProcessor.java | 3 +-
19 files changed, 257 insertions(+), 202 deletions(-)
copy
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/aggregation/{CountExpression.java
=> AggregationFunction.java} (57%)
copy
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/aggregation/{CountExpression.java
=> AndExpression.java} (67%)
copy
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/aggregation/{CountExpression.java
=> AverageExpression.java} (67%)
copy
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/aggregation/{CountExpression.java
=> DistinctCountExpression.java} (66%)
copy
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/aggregation/{CountExpression.java
=> MaxExpression.java} (67%)
copy
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/aggregation/{CountExpression.java
=> MaxForeverExpression.java} (67%)
copy
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/aggregation/{CountExpression.java
=> MinExpression.java} (67%)
copy
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/aggregation/{CountExpression.java
=> MinForeverExpression.java} (67%)
copy
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/aggregation/{CountExpression.java
=> OrExpression.java} (68%)
copy
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/aggregation/{CountExpression.java
=> StandardDeviationExpression.java} (66%)
copy
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/aggregation/{CountExpression.java
=> SumExpression.java} (67%)
copy
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/aggregation/{CountExpression.java
=> UnionSetExpression.java} (67%)
