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%)
