You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ze...@apache.org on 2020/10/27 10:34:05 UTC
[incubator-streampipes] 01/01: Merge branch 'dev' into
STREAMPIPES-234
This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a commit to branch STREAMPIPES-234
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git
commit bdd73c3991171b0db35a7339130e663ecb7317b6
Merge: acd61fe 4b6e64b
Author: Philipp Zehnder <ze...@fzi.de>
AuthorDate: Tue Oct 27 11:33:48 2020 +0100
Merge branch 'dev' into STREAMPIPES-234
.github/workflows/build.yml | 20 +-
Jenkinsfile | 6 +-
pom.xml | 1 -
streampipes-app-file-export/pom.xml | 79 -----
.../app/file/export/ElasticsearchAppData.java | 83 ------
.../app/file/export/ElasticsearchConfig.java | 60 ----
.../app/file/export/converter/JsonConverter.java | 65 -----
.../app/file/export/impl/Elasticsearch.java | 320 ---------------------
streampipes-backend/pom.xml | 5 -
.../backend/StreamPipesBackendApplication.java | 9 -
.../commons/exceptions/SpException.java | 2 +-
.../sdk/extractor/AbstractParameterExtractor.java | 39 +++
.../apache/streampipes/sdk/utils/Datatypes.java | 8 +
streampipes-wrapper-siddhi/pom.xml | 6 +
.../wrapper/siddhi/constants/SiddhiConstants.java | 55 ++++
.../siddhi/constants/SiddhiStreamSelector.java | 16 +-
.../wrapper/siddhi/engine/SiddhiEngine.java | 127 ++++++++
.../wrapper/siddhi/engine/SiddhiEventEngine.java | 274 ++----------------
...Callback.java => SiddhiStatementGenerator.java} | 9 +-
.../siddhi/engine/StreamPipesSiddhiProcessor.java | 57 ++++
.../engine/{ => callback}/SiddhiDebugCallback.java | 2 +-
.../callback/SiddhiOutputStreamCallback.java | 54 ++++
.../SiddhiOutputStreamDebugCallback.java} | 24 +-
.../engine/generator/EventTypeGenerator.java | 77 +++++
.../engine/generator/InputStreamNameGenerator.java | 35 ++-
.../engine/generator/SiddhiAppGenerator.java | 86 ++++++
.../generator/SiddhiInvocationConfigGenerator.java | 65 +++++
.../wrapper/siddhi/model/EventPropertyDef.java | 25 +-
.../siddhi/model/SiddhiProcessorParams.java | 100 +++++++
.../siddhi/query/AbstractQueryGenerator.java | 19 +-
.../wrapper/siddhi/query/FromClause.java | 48 ++++
.../wrapper/siddhi/query/SelectClause.java | 78 +++++
.../wrapper/siddhi/query/SiddhiStatement.java | 30 +-
.../expression/EqualsExpression.java} | 11 +-
.../siddhi/query/expression/Expression.java | 63 ++++
.../siddhi/query/expression/Expressions.java | 157 ++++++++++
.../expression/GreaterEqualsExpression.java} | 11 +-
.../expression/GreaterThanExpression.java} | 11 +-
.../expression/LesserEqualsExpression.java} | 11 +-
.../expression/LesserThanExpression.java} | 11 +-
.../query/expression/PropertyExpression.java | 48 ++++
.../expression/PropertyExpressionBase.java} | 7 +-
.../query/expression/PropertyRenameExpression.java | 34 +--
.../query/expression/RelationalOperator.java | 21 +-
.../expression/RelationalOperatorExpression.java | 36 +--
.../query/expression/SequenceExpression.java | 28 +-
.../siddhi/query/expression/SiddhiTimeUnit.java | 25 +-
.../siddhi/query/expression/StreamExpression.java | 58 ++++
.../query/expression/StreamFilterExpression.java | 57 ++++
.../siddhi/query/expression/WithinExpression.java | 33 +--
.../expression/list/CollectListExpression.java | 35 +--
.../expression/list/ContainsListExpression.java | 52 ++++
.../query/expression/math/MathAddExpression.java | 13 +-
.../expression/math/MathDivideExpression.java | 13 +-
.../query/expression/math/MathExpression.java | 44 +++
.../expression/math/MathMultiplyExpression.java | 13 +-
.../siddhi/query/expression/math/MathOperator.java | 18 +-
.../expression/math/MathSubtractExpression.java | 13 +-
.../query/expression/pattern/EveryExpression.java | 30 +-
.../expression/pattern/PatternCountExpression.java | 54 ++++
.../expression/pattern/PatternCountOperator.java} | 10 +-
.../expression/pattern/PatternExpression.java | 60 ++++
.../expression/window/BatchWindowExpression.java | 16 +-
.../expression/window/TimeWindowExpression.java | 33 +--
.../query/expression/window/WindowExpression.java | 32 +--
.../wrapper/siddhi/utils/SiddhiUtils.java | 85 ++++++
.../wrapper/standalone/ProcessorParams.java | 31 +-
.../streampipes/wrapper/standalone/SinkParams.java | 18 +-
.../standalone/StreamPipesDataProcessor.java | 35 +++
.../wrapper/standalone/StreamPipesDataSink.java | 33 +--
.../app/app-overview/app-overview.component.html | 4 +-
ui/src/app/app-overview/app-overview.component.ts | 13 +-
.../filter/display-recommended.pipe.ts | 2 +-
.../static-alternatives.component.html | 4 +-
.../static-alternatives.component.ts | 1 -
.../static-mapping-unary.component.ts | 2 -
.../static-mapping/static-mapping.ts | 1 +
.../pipeline-element-recommendation.component.ts | 26 +-
78 files changed, 1915 insertions(+), 1282 deletions(-)