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 <[email protected]> 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(-)
