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 2022/01/20 08:37:19 UTC
[incubator-streampipes] branch STREAMPIPES-507 updated (262211a -> 9fc1af7)
This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a change to branch STREAMPIPES-507
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git.
from 262211a [STREAMPIPES-507] Minor fix
add dbe82ca [STREAMPIPES-505] Improve runtime-resolvable configuration of adapters, split OPC adapter
add c1d7bae [STREAMPIPES-505] Rename OpcUa to SpUpcUaClient
add 8cce5db [STREAMPIPES-505] Extract node browser to own class
add 72d0676 [STREAMPIPES-505] Improve OPC-UA adapter
add 3c0d10d Merge branch 'dev' into STREAMPIPES-505
add 32ec0d4 [STREAMPIPES-505] Add test for OPC-UA adapter
add 776775d Merge branch 'STREAMPIPES-505' into dev
add c3bb575 [hotfix] Add headers
add 091c19f [hotfix] Fix dependency conflict
add e755dba [hotfix] Add auth header to pipeline element detach requests
add 352c560 [hotfix] Add reload button to adapter overview
add 94d6516 [test] Add e2e tests for trend detection
add ff57daa [hotfix] Add event index support to Siddhi query builder
add 0d9a470 [hotfix] Add cypress attribute to slider input
add 8181a39 [hotfix] Improve count aggregation
add 99082e6 [hotfix] Show default properties if none match recommended filter
add 131f6dc [test] Add test for count aggregation
add c833bbe Merge branch 'dev' of https://github.com/apache/incubator-streampipes into dev
add 8d25d1d cleaned up cloning
add a9dc67a Merge pull request #74 from patrickraoulphilipp/dev
new 9fc1af7 Merge branch 'dev' into STREAMPIPES-507
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:
.../constants/GlobalStreamPipesConstants.java | 2 +-
.../worker/management/RuntimeResovable.java | 25 +-
.../worker/rest/RuntimeResolvableResource.java | 17 +-
.../api/RuntimeResolvableRequestHandler.java | 18 +
streampipes-extensions/pom.xml | 2 +-
.../opcua/MiloOpcUaConfigurationProvider.java | 100 ++++
.../connect/iiot/adapters/opcua/OpcNode.java | 9 +
.../connect/iiot/adapters/opcua/OpcUa.java | 572 ---------------------
.../connect/iiot/adapters/opcua/OpcUaAdapter.java | 64 ++-
.../iiot/adapters/opcua/OpcUaNodeBrowser.java | 117 +++++
.../connect/iiot/adapters/opcua/SpOpcUaClient.java | 167 ++++++
.../opcua/configuration/SpOpcUaConfig.java | 215 ++++++++
.../opcua/configuration/SpOpcUaConfigBuilder.java | 99 ++++
.../adapters/opcua/utils/OpcUaNodeVariants.java | 2 +-
.../iiot/adapters/opcua/utils/OpcUaUtil.java | 48 +-
.../streampipes-pipeline-elements-all-jvm/pom.xml | 21 +-
.../processors/siddhi/count/CountAggregation.java | 11 +-
.../streampipes/processors/siddhi/trend/Trend.java | 2 +-
.../processors/siddhi/trend/TrendController.java | 2 +-
.../strings.en | 2 +-
.../model/staticproperty/TreeInputNode.java | 18 +
.../org/apache/streampipes/model/util/Cloner.java | 2 +
.../manager/execution/http/HttpRequestBuilder.java | 4 +-
.../sdk/extractor/AbstractParameterExtractor.java | 52 +-
streampipes-service-base/pom.xml | 6 +
.../wrapper/siddhi/engine/SiddhiEngine.java | 13 +-
.../engine/generator/EventTypeGenerator.java | 20 +-
.../engine/generator/SiddhiAppGenerator.java | 12 +-
.../generator/SiddhiInvocationConfigGenerator.java | 5 +-
.../wrapper/siddhi/model/EventPropertyDef.java | 10 +-
.../siddhi/model/SiddhiProcessorParams.java | 14 +-
.../siddhi/query/expression/Expressions.java | 4 +
.../query/expression/PropertyExpression.java | 6 +-
.../wrapper/siddhi/utils/SiddhiUtils.java | 3 +-
.../filters-siddhi/count1/description.json | 21 +
.../filters-siddhi/count1/expected.csv | 4 +
.../filters-siddhi/count1/input.csv | 4 +
.../filters-siddhi/increase1/description.json | 35 ++
.../filters-siddhi/increase1/expected.csv | 2 +
.../filters-siddhi/increase1/input.csv | 3 +
.../filters-siddhi/increase2/description.json | 35 ++
.../filters-siddhi/increase2/expected.csv | 0
.../filters-siddhi/increase2/input.csv | 3 +
.../filters-siddhi/increase3/description.json | 35 ++
.../filters-siddhi/increase3/expected.csv | 2 +
.../filters-siddhi/increase3/input.csv | 4 +
.../support/builder/SpecificAdapterBuilder.ts | 7 +-
ui/cypress/support/model/AdapterInput.ts | 1 +
ui/cypress/support/model/PipelineElementInput.ts | 1 +
ui/cypress/support/model/UserInput.ts | 2 +-
ui/cypress/support/utils/ConnectUtils.ts | 4 +
ui/cypress/support/utils/DataLakeUtils.ts | 4 +-
ui/cypress/support/utils/ParameterUtils.ts | 8 +
.../support/utils/ProcessingElementTestUtils.ts | 2 +-
ui/cypress/support/utils/StaticPropertyUtils.ts | 8 +-
.../adapter/machineDataSimulator.smoke.spec.ts | 2 -
ui/cypress/tests/adapter/opcAdapter.ts | 75 +++
.../tests/pipelineElement/SinglePipelineElement.ts | 2 +-
.../existing-adapters.component.html | 7 +
.../event-schema/event-schema.component.html | 2 +-
.../filter/display-recommended.pipe.ts | 17 +-
.../static-free-input.component.html | 21 +-
.../static-mapping-unary.component.html | 1 -
.../static-tree-input.component.html | 3 +
.../time-series-chart-widget-config.component.html | 4 +-
.../time-series-chart-widget.component.ts | 12 -
66 files changed, 1249 insertions(+), 746 deletions(-)
create mode 100644 streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/opcua/MiloOpcUaConfigurationProvider.java
delete mode 100644 streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/opcua/OpcUa.java
create mode 100644 streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/opcua/OpcUaNodeBrowser.java
create mode 100644 streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/opcua/SpOpcUaClient.java
create mode 100644 streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/opcua/configuration/SpOpcUaConfig.java
create mode 100644 streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/opcua/configuration/SpOpcUaConfigBuilder.java
create mode 100644 ui/cypress/fixtures/pipelineElement/filters-siddhi/count1/description.json
create mode 100644 ui/cypress/fixtures/pipelineElement/filters-siddhi/count1/expected.csv
create mode 100644 ui/cypress/fixtures/pipelineElement/filters-siddhi/count1/input.csv
create mode 100644 ui/cypress/fixtures/pipelineElement/filters-siddhi/increase1/description.json
create mode 100644 ui/cypress/fixtures/pipelineElement/filters-siddhi/increase1/expected.csv
create mode 100644 ui/cypress/fixtures/pipelineElement/filters-siddhi/increase1/input.csv
create mode 100644 ui/cypress/fixtures/pipelineElement/filters-siddhi/increase2/description.json
create mode 100644 ui/cypress/fixtures/pipelineElement/filters-siddhi/increase2/expected.csv
create mode 100644 ui/cypress/fixtures/pipelineElement/filters-siddhi/increase2/input.csv
create mode 100644 ui/cypress/fixtures/pipelineElement/filters-siddhi/increase3/description.json
create mode 100644 ui/cypress/fixtures/pipelineElement/filters-siddhi/increase3/expected.csv
create mode 100644 ui/cypress/fixtures/pipelineElement/filters-siddhi/increase3/input.csv
create mode 100644 ui/cypress/tests/adapter/opcAdapter.ts
[incubator-streampipes] 01/01: Merge branch 'dev' into STREAMPIPES-507
Posted by ze...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a commit to branch STREAMPIPES-507
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git
commit 9fc1af7a38d80a7e9cf6b9b76e79c1687e10398e
Merge: 262211a a9dc67a
Author: Philipp Zehnder <ze...@fzi.de>
AuthorDate: Thu Jan 20 09:34:35 2022 +0100
Merge branch 'dev' into STREAMPIPES-507
.../constants/GlobalStreamPipesConstants.java | 2 +-
.../worker/management/RuntimeResovable.java | 25 +-
.../worker/rest/RuntimeResolvableResource.java | 17 +-
.../api/RuntimeResolvableRequestHandler.java | 18 +
streampipes-extensions/pom.xml | 2 +-
.../opcua/MiloOpcUaConfigurationProvider.java | 100 ++++
.../connect/iiot/adapters/opcua/OpcNode.java | 9 +
.../connect/iiot/adapters/opcua/OpcUa.java | 572 ---------------------
.../connect/iiot/adapters/opcua/OpcUaAdapter.java | 64 ++-
.../iiot/adapters/opcua/OpcUaNodeBrowser.java | 117 +++++
.../connect/iiot/adapters/opcua/SpOpcUaClient.java | 167 ++++++
.../opcua/configuration/SpOpcUaConfig.java | 215 ++++++++
.../opcua/configuration/SpOpcUaConfigBuilder.java | 99 ++++
.../adapters/opcua/utils/OpcUaNodeVariants.java | 2 +-
.../iiot/adapters/opcua/utils/OpcUaUtil.java | 48 +-
.../streampipes-pipeline-elements-all-jvm/pom.xml | 21 +-
.../processors/siddhi/count/CountAggregation.java | 11 +-
.../streampipes/processors/siddhi/trend/Trend.java | 2 +-
.../processors/siddhi/trend/TrendController.java | 2 +-
.../strings.en | 2 +-
.../model/staticproperty/TreeInputNode.java | 18 +
.../org/apache/streampipes/model/util/Cloner.java | 2 +
.../manager/execution/http/HttpRequestBuilder.java | 4 +-
.../sdk/extractor/AbstractParameterExtractor.java | 52 +-
streampipes-service-base/pom.xml | 6 +
.../wrapper/siddhi/engine/SiddhiEngine.java | 13 +-
.../engine/generator/EventTypeGenerator.java | 20 +-
.../engine/generator/SiddhiAppGenerator.java | 12 +-
.../generator/SiddhiInvocationConfigGenerator.java | 5 +-
.../wrapper/siddhi/model/EventPropertyDef.java | 10 +-
.../siddhi/model/SiddhiProcessorParams.java | 14 +-
.../siddhi/query/expression/Expressions.java | 4 +
.../query/expression/PropertyExpression.java | 6 +-
.../wrapper/siddhi/utils/SiddhiUtils.java | 3 +-
.../filters-siddhi/count1/description.json | 21 +
.../filters-siddhi/count1/expected.csv | 4 +
.../filters-siddhi/count1/input.csv | 4 +
.../filters-siddhi/increase1/description.json | 35 ++
.../filters-siddhi/increase1/expected.csv | 2 +
.../filters-siddhi/increase1/input.csv | 3 +
.../filters-siddhi/increase2/description.json | 35 ++
.../filters-siddhi/increase2/expected.csv | 0
.../filters-siddhi/increase2/input.csv | 3 +
.../filters-siddhi/increase3/description.json | 35 ++
.../filters-siddhi/increase3/expected.csv | 2 +
.../filters-siddhi/increase3/input.csv | 4 +
.../support/builder/SpecificAdapterBuilder.ts | 7 +-
ui/cypress/support/model/AdapterInput.ts | 1 +
ui/cypress/support/model/PipelineElementInput.ts | 1 +
ui/cypress/support/model/UserInput.ts | 2 +-
ui/cypress/support/utils/ConnectUtils.ts | 4 +
ui/cypress/support/utils/DataLakeUtils.ts | 4 +-
ui/cypress/support/utils/ParameterUtils.ts | 8 +
.../support/utils/ProcessingElementTestUtils.ts | 2 +-
ui/cypress/support/utils/StaticPropertyUtils.ts | 8 +-
.../adapter/machineDataSimulator.smoke.spec.ts | 2 -
ui/cypress/tests/adapter/opcAdapter.ts | 75 +++
.../tests/pipelineElement/SinglePipelineElement.ts | 2 +-
.../existing-adapters.component.html | 7 +
.../event-schema/event-schema.component.html | 2 +-
.../filter/display-recommended.pipe.ts | 17 +-
.../static-free-input.component.html | 21 +-
.../static-mapping-unary.component.html | 1 -
.../static-tree-input.component.html | 3 +
.../time-series-chart-widget-config.component.html | 4 +-
.../time-series-chart-widget.component.ts | 12 -
66 files changed, 1249 insertions(+), 746 deletions(-)