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:04 UTC
[incubator-streampipes] branch STREAMPIPES-234 updated (acd61fe ->
bdd73c3)
This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a change to branch STREAMPIPES-234
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git.
from acd61fe Time-series explorer supports now new label colors
add b762769 [STREAMPIPES-246] Remove obsolete module streampipes-app-file-export
add 0821dae [STREAMPIPES-247] Fix bug that caused alternative static properties to be validated incorrectly
add 5714f20 [hotfix] Properly reload pipeline element recommendations
add d4bfb14 [maven-release-plugin] rollback the release of streampipes-parent-0.67.1
add b75e4fd Revert "[maven-release-plugin] rollback the release of streampipes-parent-0.67.1"
add 6ddd4ed [STREAMPIPES-249] Add classes for more compact data processor and sink definition
add 4491819 Merge branch 'dev' of github.com:apache/incubator-streampipes into dev
add c7a41ba Merge branch 'dev' of github.com:apache/incubator-streampipes into dev
add bc87abc Activate image labeling app
add 36c86b8 Merge branch 'dev' of github.com:apache/incubator-streampipes into dev
add 6cdeb31 [STREAMPIPES-250] Refactor Siddhi wrapper
add 6e1c9ef [STREAMPIPES-249] Add compact data sink
add 8c5beb8 [STREAMPIPES-250] Refactor Siddhi Wrapper
add da995b5 [STREAMPIPES-250] Improve Siddhi wrapper
add a6ac30a Update Jenkinsfile
add 8d79f57 Merge branch 'dev' of github.com:apache/incubator-streampipes into dev
add 8617c35 [STREAMPIPES-250] Add Siddhi EPL object model for select statements
add 16388c1 [hotfix] use correct build-args in CI
add f015efc Merge branch 'dev' of github.com:apache/incubator-streampipes into dev
add 563a3a7 [STREAMPIPES-250] Extend Siddhi object model
add 4b6e64b [hotfix] Fix bug in static mapping property renderer
new bdd73c3 Merge branch 'dev' into STREAMPIPES-234
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:
.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/api/IElasticsearch.java | 36 ---
.../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 | 20 +-
.../wrapper/siddhi/engine/SiddhiEngine.java | 127 ++++++++
.../wrapper/siddhi/engine/SiddhiEventEngine.java | 274 ++----------------
.../siddhi/engine/SiddhiStatementGenerator.java | 11 +-
.../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 | 31 +-
.../engine/generator/SiddhiAppGenerator.java | 86 ++++++
.../generator/SiddhiInvocationConfigGenerator.java | 65 +++++
.../wrapper/siddhi/model/EventPropertyDef.java | 25 +-
.../siddhi/model/SiddhiProcessorParams.java | 100 +++++++
.../siddhi/query/AbstractQueryGenerator.java | 27 +-
.../wrapper/siddhi/query/FromClause.java | 35 +--
.../wrapper/siddhi/query/SelectClause.java | 78 +++++
.../wrapper/siddhi/query/SiddhiStatement.java | 30 +-
.../siddhi/query/expression/EqualsExpression.java | 10 +-
.../siddhi/query/expression/Expression.java | 63 ++++
.../siddhi/query/expression/Expressions.java | 157 ++++++++++
.../query/expression/GreaterEqualsExpression.java | 18 +-
.../query/expression/GreaterThanExpression.java | 25 +-
.../query/expression/LesserEqualsExpression.java | 18 +-
.../query/expression/LesserThanExpression.java | 10 +-
.../query/expression/PropertyExpression.java | 48 ++++
.../query/expression/PropertyExpressionBase.java | 6 +-
.../query/expression/PropertyRenameExpression.java | 23 +-
.../expression/RelationalOperator.java} | 24 +-
.../expression/RelationalOperatorExpression.java | 29 +-
.../query/expression/SequenceExpression.java | 27 +-
.../siddhi/query/expression/SiddhiTimeUnit.java | 21 +-
.../siddhi/query/expression/StreamExpression.java | 58 ++++
.../query/expression/StreamFilterExpression.java | 57 ++++
.../siddhi/query/expression/WithinExpression.java | 30 +-
.../expression/list/CollectListExpression.java | 24 +-
.../expression/list/ContainsListExpression.java | 52 ++++
.../query/expression/math/MathAddExpression.java | 13 +-
.../expression/math/MathDivideExpression.java | 10 +-
.../query/expression/math/MathExpression.java | 29 +-
.../expression/math/MathMultiplyExpression.java | 17 +-
.../siddhi/query/expression/math/MathOperator.java | 18 +-
.../expression/math/MathSubtractExpression.java | 13 +-
.../query/expression/pattern/EveryExpression.java | 21 +-
.../expression/pattern/PatternCountExpression.java | 54 ++++
.../expression/pattern/PatternCountOperator.java | 7 +-
.../expression/pattern/PatternExpression.java | 60 ++++
.../expression/window/BatchWindowExpression.java | 14 +-
.../expression/window/TimeWindowExpression.java | 37 +--
.../query/expression/window/WindowExpression.java | 32 +--
.../wrapper/siddhi/utils/SiddhiUtils.java | 85 ++++++
...redEventProcessor.java => ProcessorParams.java} | 17 +-
.../{ConfiguredEventSink.java => SinkParams.java} | 17 +-
...rocessor.java => StreamPipesDataProcessor.java} | 14 +-
...uredEventSink.java => StreamPipesDataSink.java} | 13 +-
.../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 +-
79 files changed, 1819 insertions(+), 1322 deletions(-)
delete mode 100644 streampipes-app-file-export/pom.xml
delete mode 100644 streampipes-app-file-export/src/main/java/org/apache/streampipes/app/file/export/ElasticsearchAppData.java
delete mode 100644 streampipes-app-file-export/src/main/java/org/apache/streampipes/app/file/export/ElasticsearchConfig.java
delete mode 100644 streampipes-app-file-export/src/main/java/org/apache/streampipes/app/file/export/api/IElasticsearch.java
delete mode 100644 streampipes-app-file-export/src/main/java/org/apache/streampipes/app/file/export/converter/JsonConverter.java
delete mode 100644 streampipes-app-file-export/src/main/java/org/apache/streampipes/app/file/export/impl/Elasticsearch.java
create mode 100644 streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/constants/SiddhiConstants.java
copy streampipes-sdk/src/main/java/org/apache/streampipes/sdk/helpers/Locales.java => streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/constants/SiddhiStreamSelector.java (69%)
create mode 100644 streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/SiddhiEngine.java
copy streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/FlinkDataProcessorDeclarer.java => streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/SiddhiStatementGenerator.java (72%)
create mode 100644 streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/StreamPipesSiddhiProcessor.java
copy streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/{ => callback}/SiddhiDebugCallback.java (93%)
create mode 100644 streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/callback/SiddhiOutputStreamCallback.java
rename streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/{SiddhiDebugCallback.java => callback/SiddhiOutputStreamDebugCallback.java} (55%)
create mode 100644 streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/generator/EventTypeGenerator.java
copy archetypes/streampipes-archetype-pe-processors-flink/src/main/resources/archetype-resources/src/main/java/pe/processor/__packageName__/__classNamePrefix__Parameters.java => streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/generator/InputStreamNameGenerator.java (55%)
create mode 100644 streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/generator/SiddhiAppGenerator.java
create mode 100644 streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/generator/SiddhiInvocationConfigGenerator.java
copy streampipes-model/src/main/java/org/apache/streampipes/model/runtime/SourceInfo.java => streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/model/EventPropertyDef.java (70%)
create mode 100644 streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/model/SiddhiProcessorParams.java
copy streampipes-sdk/src/main/java/org/apache/streampipes/sdk/helpers/Filetypes.java => streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/AbstractQueryGenerator.java (63%)
copy streampipes-maven-plugin/src/main/java/org/apache/streampipes/smp/util/DuplicateRemover.java => streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/FromClause.java (51%)
create mode 100644 streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/SelectClause.java
rename streampipes-app-file-export/src/main/java/org/apache/streampipes/app/file/export/model/IndexInfo.java => streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/SiddhiStatement.java (58%)
copy streampipes-code-generation/src/main/java/org/apache/streampipes/codegeneration/api/IDeclareModelGenerator.java => streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/EqualsExpression.java (75%)
create mode 100644 streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/Expression.java
create mode 100644 streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/Expressions.java
copy streampipes-commons/src/main/java/org/apache/streampipes/commons/exceptions/ElementNotFoundException.java => streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/GreaterEqualsExpression.java (73%)
copy ui/src/scss/sp/pipeline-element.scss => streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/GreaterThanExpression.java (75%)
copy streampipes-commons/src/main/java/org/apache/streampipes/commons/exceptions/ElementNotFoundException.java => streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/LesserEqualsExpression.java (73%)
copy streampipes-code-generation/src/main/java/org/apache/streampipes/codegeneration/api/IDeclareModelGenerator.java => streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/LesserThanExpression.java (74%)
create mode 100644 streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/PropertyExpression.java
copy streampipes-container/src/main/java/org/apache/streampipes/container/declarer/EventStreamDeclarer.java => streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/PropertyExpressionBase.java (86%)
copy streampipes-performance-tests/src/main/java/org/apache/streampipes/performance/simulation/SimulationStatusNotifier.java => streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/PropertyRenameExpression.java (54%)
copy streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/{manager/SpSiddhiManager.java => query/expression/RelationalOperator.java} (68%)
copy streampipes-dataformat-json/src/main/java/org/apache/streampipes/dataformat/json/JsonDataFormatFactory.java => streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/RelationalOperatorExpression.java (51%)
copy streampipes-sdk/src/main/java/org/apache/streampipes/sdk/helpers/Filetypes.java => streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/SequenceExpression.java (58%)
copy streampipes-sdk/src/main/java/org/apache/streampipes/sdk/helpers/Locales.java => streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/SiddhiTimeUnit.java (71%)
create mode 100644 streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/StreamExpression.java
create mode 100644 streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/StreamFilterExpression.java
copy ui/src/app/connect/services/icon.service.ts => streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/WithinExpression.java (60%)
copy streampipes-dataformat-json/src/main/java/org/apache/streampipes/dataformat/json/JsonDataFormatFactory.java => streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/list/CollectListExpression.java (51%)
create mode 100644 streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/list/ContainsListExpression.java
rename streampipes-app-file-export/src/main/java/org/apache/streampipes/app/file/export/application/AppFileExportApplication.java => streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/math/MathAddExpression.java (70%)
copy streampipes-code-generation/src/main/java/org/apache/streampipes/codegeneration/api/IDeclareModelGenerator.java => streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/math/MathDivideExpression.java (70%)
copy streampipes-dataformat-fst/src/main/java/org/apache/streampipes/dataformat/fst/FstDataFormatFactory.java => streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/math/MathExpression.java (50%)
copy ui/src/app/editor/components/pipeline-assembly/pipeline-assembly.component.scss => streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/math/MathMultiplyExpression.java (71%)
copy streampipes-maven-plugin/src/main/java/org/apache/streampipes/smp/generator/MarkdownTitleRemover.java => streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/math/MathOperator.java (72%)
copy streampipes-backend/src/main/java/org/apache/streampipes/backend/WelcomePageController.java => streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/math/MathSubtractExpression.java (69%)
copy streampipes-maven-plugin/src/main/java/org/apache/streampipes/smp/parser/PipelineElementDescriptionReplacer.java => streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/pattern/EveryExpression.java (58%)
create mode 100644 streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/pattern/PatternCountExpression.java
copy streampipes-commons/src/main/java/org/apache/streampipes/commons/exceptions/NoSuitableSepasAvailableException.java => streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/pattern/PatternCountOperator.java (85%)
create mode 100644 streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/pattern/PatternExpression.java
copy streampipes-sources/src/main/java/org/apache/streampipes/sources/AbstractAdapterIncludedStream.java => streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/window/BatchWindowExpression.java (65%)
copy streampipes-connect/src/main/java/org/apache/streampipes/connect/adapter/util/PollingSettings.java => streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/window/TimeWindowExpression.java (56%)
copy streampipes-config/src/main/java/org/apache/streampipes/config/backend/SpDataFormat.java => streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/window/WindowExpression.java (53%)
create mode 100644 streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/utils/SiddhiUtils.java
copy streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/{ConfiguredEventProcessor.java => ProcessorParams.java} (69%)
copy streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/{ConfiguredEventSink.java => SinkParams.java} (72%)
copy streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/{ConfiguredEventProcessor.java => StreamPipesDataProcessor.java} (62%)
copy streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/{ConfiguredEventSink.java => StreamPipesDataSink.java} (65%)
[incubator-streampipes] 01/01: Merge branch 'dev' into
STREAMPIPES-234
Posted by ze...@apache.org.
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(-)