This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch 1980-arrays-are-not-supported-for-s7-plcs
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 3c9fe1c27 feat(#1980): Add array support for S7 PLC registers
add 714f46232 Add configuration hint for Kafka users. (#1945)
add 9b4f8078a Bump numpydoc from 1.5.0 to 1.6.0 in
/streampipes-client-python (#1967)
add 513288680 monthly update of vulnerability report (#1982)
add 9e5fdc3cd [#1879] Inject DisplayRecommendedPipe to NaryMappingProperty
(#1981)
add 6cf56a911 chore(deps): bump org.yaml:snakeyaml from 2.1 to 2.2 (#1984)
add 2d67d15b5 Add deployment of Prometheus and Grafana to K8s (#1978)
add 598c13996 chore(deps-dev): bump pyupgrade in
/streampipes-client-python (#1987)
add 774753e2a chore(deps): bump org.simplejavamail:simple-java-mail (#1988)
add 59a59a8c8 chore(deps): bump urllib3 in /streampipes-client-python
(#1990)
add db47ce64e chore(deps-dev): remove org.ow2.asm:asm (#1989)
add e4eb677b1 chore(deps-dev): bump pillow in /streampipes-client-python
(#1995)
add 4829537b8 chore(deps): remove com.google.j2objc:j2objc-annotations
(#1997)
add 5ed09fdb3 Improvements to prometheus and Grafana (#1991)
add 7acaf752c chore(deps): bump org.checkerframework:checker-qual (#1996)
add 283d57918 chore(deps): bump io.nats:jnats from 2.16.1 to 2.17.0 (#1999)
add e680d47e0 refactor(#1960): Refactor transformation rules, add schema
restore (#1994)
add b51326d1f Set default Kafka auto offset explicitly if it is not
provided in configuration (#1992) (#1993)
add b751a1c79 chore(deps): bump org.mockito:mockito-core from 5.5.0 to
5.6.0 (#2006)
add d59fc7f94 chore(deps-dev): bump pyupgrade in
/streampipes-client-python (#2007)
add c156c72e0 chore(deps): bump org.simplejavamail:simple-java-mail (#2011)
add ed4dd8320 chore(deps): bump com.nimbusds:nimbus-jose-jwt from 9.35 to
9.36 (#2010)
add 8a565bc64 chore(deps-dev): bump webpack from 5.76.1 to 5.88.2 in /ui
(#2009)
add 9fbc9c9e7 fix typo in asset management caption (#2012)
add 7eb9c6f0d chore(deps-dev): bump mypy in /streampipes-client-python
(#2013)
add 905ebd38c chore(deps): bump shepherd.js from 11.1.1 to 11.2.0 in /ui
(#2019)
add 747fd46f1 chore(deps): remove org.immutables (#2015)
add e146961aa test(#2017): Add cypress test for configuration (#2018)
add 71a0ea32e [#1891] Implement Unit Tests for BooleanFilterProcessor
(#2022)
add d251268f9 [#1895] Implement unit tests for pipeline element
'MergeByTimeProcessor' (#2023)
add 813059c90 chore(deps-dev): bump pre-commit in
/streampipes-client-python (#2030)
add b8d38dadb chore(deps-dev): bump @types/jasmine from 4.3.1 to 5.1.0 in
/ui (#2027)
add 857edb366 fix(#1670): validate client config and create proper error
message (#2026)
add a2d4e617f fix: make data retrieval of IOLink sensor more robust (#2024)
add 87c684e04 style: Add last message info to adapter overview (#2031)
add d2ffe4f90 chore(deps-dev): bump ruff in /streampipes-client-python
(#2037)
add 5619781b7 [1902] Implement unit tests for pipeline element
'TextFilterProcessor' (#2025)
add 7bd1acc9e chore(deps-dev): bump @babel/traverse from 7.22.5 to 7.23.2
in /ui (#2038)
add 897d15bbd chore(deps): bump plotly.js from 2.22.0 to 2.26.2 in /ui
(#2036)
add fc58aaddb chore(deps): bump org.apache.inlong:tubemq-client from 1.7.0
to 1.9.0 (#2035)
add 7ddebeae7 chore: remove duplicate dependency (#2039)
add b792afb66 feat(#2023): Provide REST endpoint to fetch measurement
counts (#2033)
add 1b05ced92 docs: use GitHub admonitions for README (#2040)
add 3a61b2991 chore(deps): bump urllib3 in /streampipes-client-python
(#2047)
add 7f6f9c15b chore(deps-dev): bump assert from 2.0.0 to 2.1.0 in /ui
(#2048)
add e98c435f3 chore(deps-dev): bump black in /streampipes-client-python
(#2049)
add 23aa2e6bb Add Cypress UI tests for asset management (#2043)
add 3299dd894 chore(deps): clean up version definitions of
com.squareup.okhttp3:okhttp (#2053)
add f1d863920 refactor: remove references and artifacts for data sets
(#2041)
add 7ca3a885c feat(#2056): Make email templates configurable in UI (#2057)
add 19efa055a feat(#2061): Extend maven-assembly-plugin to generate
installer zip file (#2062)
add 6a388e859 refactor: rename logger (#2065)
add ddecc0d91 refactor: introduce conveniance method for service url
(#2064)
add 5ae4dfe9c refactor:minor adaption & improvement (#2071)
add 774d75caf chore(deps): remove com.nimbusds:nimbus-jose-jwt (#2034)
add 9fccc5f73 refactor: Add individual connector modules for adapters and
sinks (#2069)
add 40665f99b chore(deps): bump actions/setup-node from 3 to 4 (#2080)
add 1a5464954 refactor: Make interactive tutorial work again (#2068)
add 87d8a933e improve archetypes for adapter tutorial (#2076)
add 21779c0d6 Fix settings of maven-assembly-plugin (#2083)
add 5359adc45 chore(deps): bump nats-py in /streampipes-client-python
(#2084)
add 8b7f380ff chore(deps): bump confluent-kafka in
/streampipes-client-python (#2086)
add 2d81ea07b chore(deps-dev): bump jasmine-core from 4.6.0 to 5.1.1 in
/ui (#2085)
add bb324758b chore(deps): bump com.rabbitmq:amqp-client from 5.19.0 to
5.20.0 (#2087)
add f9f1bd55a feat(#1960): Allow modification of adapters with pipelines
(#1979)
add f8be8f622 refactor: remove legacy demo resources (#2066)
add 5987161e8 feat(#2002): Align adapter registration with other pipeline
elements (#2008)
add 3d654a716 fix(grammatical): correct typos and improve grammar (#2100)
add 388973d7e chore(deps-dev): bump browserify-sign from 4.2.1 to 4.2.2 in
/ui (#2091)
add 89c414fa4 refactor(#2088): Remove module streampipes-logging (#2089)
add 03a416c8a [#1936] Adapter Deletion: Show the Names of All Pipelines
Using the Adapter and Allow One Click Deletion (#2070)
add 5b04827ba introduce quickstart deployment mode (#1955)
add 1a7a17edc chore(deps): bump nats-py in /streampipes-client-python
(#2102)
add a34a4dda3 implement migration for adapter and pipeline element
configurations (#2077)
add 0497444a2 refactor(#2092): Use HttpStatus in stead of plain strings
(#2099)
add 79e7d1818 fix(#2112): Properly update broker configs (#2114)
add 32b694ddb fix(tests): Fix path when deleting adapters (#2116)
add e534038f1 monthly update of vulnerability report (#2115)
new 25da1dd36 Merge branch 'dev' into
1980-arrays-are-not-supported-for-s7-plcs
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/pr-labeler-config.yml | 1 -
.github/workflows/build.yml | 9 +-
.github/workflows/cypress-test.yml | 2 +-
.github/workflows/pr-validation.yml | 4 +-
.../sources_watertank_simulator_jvm.xml | 15 -
README.md | 8 +-
VULNERABILITY.md | 9 +-
.../src/main/resources/archetype-resources/pom.xml | 5 -
.../__classNamePrefix__GenericAdapter.java | 1 +
.../__classNamePrefix__SpecificAdapter.java | 1 +
.../deploy/standalone/kafka/docker-compose.dev.yml | 2 +-
.../docker-compose.dev.yml | 20 -
installer/cli/environments/full | 1 -
installer/cli/environments/lite | 1 -
installer/cli/environments/lite-nats | 1 -
installer/cli/environments/ui | 1 -
installer/compose/README.md | 20 +-
installer/compose/docker-compose.full.yml | 16 +-
...r-compose.yml => docker-compose.quickstart.yml} | 25 +-
installer/compose/docker-compose.yml | 16 +-
.../compose/quickstart}/Dockerfile | 10 +-
installer/compose/quickstart/upload.sh | 101 +
...set - Smart Factory Monitoring and Analysis.zip | Bin 0 -> 78596 bytes
installer/k8s/README.md | 42 +-
.../k8s/templates/core/backend-deployment.yaml | 2 +
.../core/extensions-all-iiot-deployment.yaml | 2 +
.../templates/external/kafka/kafka-deployment.yaml | 6 +-
.../templates/external/kafka/kafka-service.yaml | 4 +
.../grafana/grafana-deployment.yml} | 53 +-
.../grafana/grafana-pv.yml} | 23 +-
.../grafana/grafana-pvc.yml} | 21 +-
.../templates/monitor/grafana/grafana-service.yml} | 33 +-
.../monitor/prometheus/prometheus-configmap.yaml | 49 +
.../monitor/prometheus/prometheus-deployment.yml | 108 ++
.../prometheus/prometheus-pv.yml} | 23 +-
.../prometheus/prometheus-pvc.yml} | 21 +-
.../monitor/prometheus/prometheus-service.yml} | 30 +-
.../templates/monitor/prometheus/token-pvc.yml} | 20 +-
installer/k8s/values.yaml | 39 +
installer/scripts/epsg/Readme.md | 1 -
pom.xml | 137 +-
prometheus-grafana/grafana/dashboards/backend.json | 478 +----
.../grafana/dashboards/extensions-all-iiot.json | 386 +---
.../apache/streampipes/client/api/IAdminApi.java | 6 +-
...ive-data-from-the-streampipes-data-stream.ipynb | 2 +-
streampipes-client-python/poetry.lock | 348 ++--
streampipes-client-python/pyproject.toml | 12 +-
.../streampipes/client/client.py | 14 +
.../tests/client/test_client.py | 12 +
.../streampipes/client/api/AbstractClientApi.java | 5 +-
.../client/api/AbstractTypedClientApi.java | 4 +-
.../apache/streampipes/client/api/AdminApi.java | 30 +-
.../streampipes/client/http/HttpRequest.java | 5 +-
.../management/AdapterEventPreviewPipeline.java | 3 +-
.../management/AdapterMasterManagement.java | 19 -
.../management/AdapterMigrationManager.java | 113 ++
.../management/AdapterUpdateManagement.java | 208 ++
.../management/management/GuessManagement.java | 20 +-
.../management/WorkerAdministrationManagement.java | 56 +-
.../management/management/WorkerRestClient.java | 73 +-
streampipes-connect-shared/pom.xml | 10 +
.../shared/AdapterPipelineGeneratorBase.java | 95 +-
....java => SupportsNestedTransformationRule.java} | 45 +-
.../convert/ProvidesConversionResult.java | 17 +-
.../preprocessing/convert/SchemaConverter.java | 67 +
.../convert/ToOriginalSchemaConverter.java | 141 ++
.../convert/ToTransformedSchemaConverter.java | 165 ++
...a => AdapterTransformationPipelineElement.java} | 23 +-
.../TransformSchemaAdapterPipelineElement.java | 81 -
.../elements/TransformStreamAdapterElement.java | 71 -
.../TransformValueAdapterPipelineElement.java | 96 -
...StatefulTransformationRuleGeneratorVisitor.java | 99 +
...tatelessTransformationRuleGeneratorVisitor.java | 135 ++
.../TransformationRuleGeneratorVisitor.java | 26 +-
.../transform/TransformationRule.java | 2 +-
...onRule.java => AddValueTransformationRule.java} | 25 +-
.../schema/CreateNestedTransformationRule.java | 31 +-
.../transform/schema/DeleteTransformationRule.java | 29 +-
.../transform/schema/MoveTransformationRule.java | 18 +-
.../transform/schema/RenameTransformationRule.java | 36 +-
.../transform/schema/SchemaEventTransformer.java | 119 --
.../stream/DuplicateFilterPipelineElement.java | 8 +-
.../stream/EventRateTransformationRule.java | 10 +-
.../transform/stream/StreamEventTransformer.java | 66 -
...le.java => AddTimestampTransformationRule.java} | 16 +-
.../value/CorrectionValueTransformationRule.java | 68 +-
.../value/DatatypeTransformationRule.java | 18 +-
.../value/TimestampTranformationRuleMode.java | 13 +-
...nRule.java => TimestampTransformationRule.java} | 60 +-
.../transform/value/UnitTransformationRule.java | 59 +-
.../transform/value/ValueEventTransformer.java | 83 -
.../preprocessing/utils/ConversionUtils.java | 93 +
.../preprocessing/{Util.java => utils/Utils.java} | 16 +-
.../connect/shared/preprocessing/UtilsTest.java} | 37 +-
.../shared/preprocessing/convert/Helpers.java | 92 +
.../convert/ToOriginalSchemaConverterTest.java | 104 +
.../convert/ToTransformedSchemaConverterTest.java | 121 ++
.../AdapterTransformationPipelineElementTest.java | 60 +
.../schema/CreateNestedTransformationRuleTest.java | 4 +-
.../schema/DeleteTransformationRuleTest.java | 4 +-
.../schema/MoveTransformationRuleTest.java | 6 +-
.../schema/RenameTransformationRuleTest.java | 4 +-
.../schema/SchemaEventTransformerTest.java | 9 +-
.../transform/value/CorrectionValueTest.java | 14 +-
.../transform/value/UnitTransformRuleTest.java | 10 +-
.../transform/value/ValueEventTransformerTest.java | 10 +-
.../dataexplorer/commons/TimeSeriesStore.java | 2 +-
.../dataexplorer/DataExplorerQueryManagement.java | 4 +-
.../dataexplorer/DataExplorerSchemaManagement.java | 4 +
.../influx/DataLakeMeasurementCount.java | 101 +
.../IDataProcessorParameterExtractor.java | 4 +-
.../api/extractor/IDataSinkParameterExtractor.java | 4 +-
.../api/extractor/IParameterExtractor.java | 3 +-
.../api/extractor/IStaticPropertyExtractor.java | 4 +-
.../extensions/api/migration/DataSinkMigrator.java | 7 +-
.../extensions/api/migration/IAdapterMigrator.java | 9 +-
.../IDataProcessorMigrator.java} | 11 +-
.../extensions/api/migration/IModelMigrator.java | 52 +
.../api/migration/MigrationComparison.java | 11 +-
.../api/pe/param/IParameterGenerator.java | 2 +-
.../api/pe/param/IPipelineElementParameters.java | 2 +-
.../ResolvesContainerProvidedOutputStrategy.java | 2 +-
streampipes-extensions-management/pom.xml | 5 -
.../connect}/AbstractAdapterIncludedStream.java | 6 +-
.../connect}/AbstractAlreadyExistingStream.java | 6 +-
.../management/connect/GuessManagement.java | 13 +-
.../management/connect/SchemaUpdateManagement.java | 116 ++
.../connect/TransformationRuleUpdateVisitor.java | 151 ++
.../connect/adapter/AdapterPipelineGenerator.java | 32 +-
.../connect/adapter}/BrokerEventProcessor.java | 2 +-
.../adapter/model/pipeline/AdapterPipeline.java | 2 +-
.../management/locales/LabelGenerator.java | 8 +-
.../management/model/SpServiceDefinition.java | 25 +
.../model/SpServiceDefinitionBuilder.java | 16 +-
.../model/SpServiceDefinitionBuilderTest.java | 52 +
streampipes-extensions/docker-compose.yml | 22 -
streampipes-extensions/pom.xml | 9 +-
.../streampipes-connect-adapters-iiot/pom.xml | 46 +-
.../connect/iiot/ConnectAdapterIiotInit.java | 15 +-
.../iiot/adapters/iolink/IfmAlMqttAdapter.java | 80 +-
.../iiot/protocol/stream/HttpServerProtocol.java | 1 +
.../streampipes-connect-adapters/pom.xml | 9 +-
.../connect/adapters/flic/FlicMQTTAdapter.java | 6 +-
.../connect/adapters/netio/NetioMQTTAdapter.java | 6 +-
.../connect/adapters/netio/NetioRestAdapter.java | 7 +-
.../connect/adapters/ti/TISensorTag.java | 6 +-
.../connect/adapters/PullAdapterTest.java | 4 +-
.../generic/elements/AddTimestampTest.java | 6 +-
.../generic/elements/DuplicateFilterTest.java | 34 +-
.../generic/protocol/stream/HttpProtocolTest.java | 4 +-
.../streampipes-connectors-influx/pom.xml | 6 +
.../connectors/influx/shared/InfluxConfigs.java | 2 +-
.../connectors/influx/sink/InfluxDbSink.java | 9 +-
.../pom.xml | 41 +-
.../connectors/kafka/adapter}/KafkaProtocol.java | 7 +-
.../kafka/shared}/kafka/KafkaConfig.java | 9 +-
.../kafka/shared}/kafka/KafkaConnectUtils.java | 17 +-
.../connectors/kafka/sink}/KafkaParameters.java | 8 +-
.../connectors/kafka/sink}/KafkaPublishSink.java | 241 +--
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 0
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 0
.../streampipes-connectors-mqtt}/pom.xml | 13 +-
.../connectors/mqtt/adapter}/MqttProtocol.java | 9 +-
.../connectors/mqtt/shared}/MqttConfig.java | 2 +-
.../connectors/mqtt/shared}/MqttConnectUtils.java | 6 +-
.../connectors/mqtt/shared}/MqttConsumer.java | 2 +-
.../connectors/mqtt/sink/MqttPublisherSink.java | 157 ++
.../connectors/mqtt/sink/common}/MqttClient.java | 8 +-
.../connectors/mqtt/sink}/common/MqttOptions.java | 46 +-
.../connectors/mqtt/sink}/common/MqttUtils.java | 2 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 0
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 0
.../streampipes-connectors-nats}/pom.xml | 14 +-
.../connectors/nats/adapter}/NatsProtocol.java | 31 +-
.../connectors/nats/shared}/NatsConfigUtils.java | 4 +-
.../extensions/connectors/nats/sink/NatsSink.java} | 58 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 0
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 0
.../connectors/opcua/adapter/OpcUaAdapter.java | 2 +-
.../opcua/config/SharedUserConfiguration.java | 18 +-
.../opcua/config/SpOpcUaConfigExtractor.java | 4 +-
.../opcua/migration/OpcUaAdapterMigrationV1.java | 51 +
.../streampipes-connectors-pulsar}/pom.xml | 18 +-
.../connectors/pulsar/adapter}/PulsarConfig.java | 10 +-
.../connectors/pulsar/adapter}/PulsarProtocol.java | 4 +-
.../connectors/pulsar/adapter}/PulsarUtils.java | 2 +-
.../connectors/pulsar/sink}/PulsarParameters.java | 18 +-
.../pulsar/sink}/PulsarPublisherSink.java | 46 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 0
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 0
.../connectors}/pulsar/TestPulsarParameters.java | 17 +-
.../pulsar/TestPulsarPublisherSink.java | 59 +-
.../streampipes-connectors-rocketmq}/pom.xml | 17 +-
.../rocketmq/adapter}/RocketMQConsumer.java | 2 +-
.../rocketmq/adapter}/RocketMQProtocol.java | 4 +-
.../rocketmq/adapter}/RocketMQUtils.java | 2 +-
.../rocketmq/sink}/RocketMQParameters.java | 14 +-
.../rocketmq/sink}/RocketMQPublisherSink.java | 44 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 0
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 0
.../rocketmq/TestRocketMQPublisherSink.java | 26 +-
.../streampipes-connectors-tubemq}/pom.xml | 19 +-
.../connectors/tubemq/adapter}/TubeMQProtocol.java | 3 +-
.../connectors/tubemq/sink}/TubeMQParameters.java | 10 +-
.../tubemq/sink}/TubeMQPublisherSink.java | 32 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 0
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 0
.../extensions/all/iiot/AllExtensionsIIoTInit.java | 13 +
.../streampipes-extensions-all-jvm/Dockerfile | 2 +-
.../extensions/all/jvm/AllExtensionsInit.java | 13 +
.../pom.xml | 6 -
.../urldereferencing/UrlDereferencing.java | 3 -
.../streampipes-pipeline-elements-shared/pom.xml | 24 -
.../pe/shared/config/kafka/KafkaConnectUtils.java | 169 --
.../pe/shared/config/kafka/kafka/KafkaConfig.java | 84 -
.../streampipes-processors-filters-jvm/pom.xml | 6 +
.../jvm/processor/merge/MergeByTimeProcessor.java | 8 +-
.../processor/textfilter/TextFilterProcessor.java | 6 +-
.../booleanfilter/TestBooleanFilterProcessor.java | 153 ++
.../processor/merge/TestMergeByTimeProcessor.java | 193 ++
.../textfilter/TestTextFilterProcessor.java | 148 ++
.../streampipes-processors-geo-jvm/pom.xml | 1 -
.../inverter/BooleanInverterProcessor.java | 3 -
.../CsvMetadataEnrichmentProcessor.java | 2 +-
.../counter/StringCounterProcessor.java | 4 -
.../state/StringToStateProcessor.java | 4 -
.../stringoperator/timer/StringTimerProcessor.java | 4 -
.../change/TestChangedValueDetectionProcessor.java | 48 +-
.../streampipes-sinks-brokers-jvm/pom.xml | 21 -
.../sinks/brokers/jvm/BrokersJvmInit.java | 14 +-
.../sinks/brokers/jvm/mqtt/MqttPublisherSink.java | 153 --
.../sinks/databases/jvm/jdbcclient/JdbcClient.java | 30 +-
.../sinks/databases/jvm/postgresql/PostgreSql.java | 16 +-
.../Dockerfile | 24 -
.../development/env | 21 -
.../streampipes-sources-vehicle-simulator/pom.xml | 105 -
.../vehicle/simulator/VehicleSimulatorInit.java | 44 -
.../vehicle/simulator/config/ConfigKeys.java | 24 -
.../simulator/simulator/VehicleDataSimulator.java | 93 -
.../simulator/vehicle/streams/VehicleStream.java | 60 -
.../src/main/resources/streampipesDemoConfig.json | 21 -
.../main/resources/streampipesVehicleWorkflow.json | 68 -
.../development/env | 21 -
.../pom.xml | 125 --
.../simulator/WatertankSimulatorInit.java | 52 -
.../simulator/utils/WatertankDataSimulator.java | 99 -
.../simulator/vocabulary/WaterTankVocabulary.java | 38 -
.../watertank/streams/FlowRate1Stream.java | 84 -
.../watertank/streams/FlowRate2Stream.java | 93 -
.../watertank/streams/PressureTankStream.java | 66 -
.../watertank/streams/WaterLevel1Stream.java | 85 -
.../watertank/streams/WaterLevel2Stream.java | 71 -
.../icon.png | Bin 24336 -> 0 bytes
.../strings.en | 19 -
.../documentation.md | 37 -
.../icon.png | Bin 24500 -> 0 bytes
.../strings.en | 19 -
.../documentation.md | 35 -
.../icon.png | Bin 14592 -> 0 bytes
.../strings.en | 19 -
.../documentation.md | 36 -
.../icon.png | Bin 20898 -> 0 bytes
.../strings.en | 19 -
.../icon.png | Bin 20898 -> 0 bytes
.../strings.en | 19 -
.../src/main/resources/streampipesDemoConfig.json | 37 -
.../streampipesFestoFlowRateWorkflow.json | 34 -
.../streampipesFestoLevel101Workflow.json | 36 -
.../streampipesFestoLevel102Workflow.json | 33 -
.../streampipesFestoPressureWorkflow.json | 44 -
.../streampipesSiemensFlowRateWorkflow.json | 42 -
streampipes-integration-tests/pom.xml | 4 +
.../integration/adapters/AdaptersTest.java | 12 +-
.../integration/adapters/KafkaAdapterTester.java | 4 +-
.../integration/adapters/MqttAdapterTester.java | 4 +-
.../integration/adapters/PulsarAdapterTester.java | 2 +-
.../integration/containers/PulsarContainer.java | 3 +-
streampipes-logging/pom.xml | 46 -
.../apache/streampipes/logging/LoggerFactory.java | 31 -
.../logging/impl/EventStatisticLogger.java | 41 -
.../apache/streampipes/logging/impl/PeLogger.java | 62 -
.../org/apache/streampipes/logging/model/Log.java | 69 -
.../streampipes/logging/model/LogRequest.java | 50 -
.../org/apache/streampipes/mail/MailSender.java | 8 +-
.../mail/template/AbstractMailTemplate.java | 23 +-
.../template/AccountActiviationMailTemplate.java | 5 +-
...stMailTemplate.java => CustomMailTemplate.java} | 33 +-
.../mail/template/InitialPasswordMailTemplate.java | 5 +-
.../template/PasswordRecoveryMailTemplate.java | 6 +-
.../mail/template/TestMailTemplate.java | 5 +-
.../template/generation/DefaultPlaceholders.java | 2 -
.../template/generation/MailTemplateBuilder.java | 59 +-
.../mail/template/part/MailTemplatePart.java | 14 +-
.../src/main/resources/mail-template-footer.html | 39 -
.../main/resources/mail-template-inner-button.html | 70 +-
.../main/resources/mail-template-inner-plain.html | 29 +-
.../src/main/resources/mail-template-outer.html | 154 --
streampipes-maven-plugin/pom.xml | 1 -
streampipes-model/pom.xml | 10 -
.../model/base/ConsumableStreamPipesEntity.java | 6 +-
.../model/base/InvocableStreamPipesEntity.java | 27 +-
.../VersionedNamedStreamPipesEntity.java} | 33 +-
.../DefaultEmailTemplateConfiguration.java | 58 +
.../configuration/DefaultSpCoreConfiguration.java | 1 +
.../model/configuration/EmailTemplateConfig.java | 25 +-
.../model/configuration/SpCoreConfiguration.java | 9 +
.../model/connect/adapter/AdapterDescription.java | 15 +-
.../model/connect/adapter/PipelineUpdateInfo.java | 80 +
.../adapter/migration/GenericAdapterConverter.java | 17 +-
.../model/connect/guess/GuessSchema.java | 54 +-
...iption.java => ITransformationRuleVisitor.java} | 53 +-
.../rules/TransformationRuleDescription.java | 4 +
.../rules/TransformationRulePriority.java} | 38 +-
.../rules/schema/CreateNestedRuleDescription.java | 13 +
.../rules/schema/DeleteRuleDescription.java | 13 +
.../connect/rules/schema/MoveRuleDescription.java | 13 +
.../rules/schema/RenameRuleDescription.java | 13 +
.../EventRateTransformationRuleDescription.java | 13 +
...oveDuplicatesTransformationRuleDescription.java | 13 +
.../rules/value/AddTimestampRuleDescription.java | 13 +
.../AddValueTransformationRuleDescription.java | 69 +
...hangeDatatypeTransformationRuleDescription.java | 13 +
...rrectionValueTransformationRuleDescription.java | 13 +
.../TimestampTranfsformationRuleDescription.java | 13 +
.../rules/value/UnitTransformRuleDescription.java | 13 +
.../extensions/migration/MigrationRequest.java | 14 +-
.../svcdiscovery/SpServiceRegistration.java | 4 +
.../svcdiscovery/SpServiceTagPrefix.java | 3 +-
.../model/graph/DataProcessorInvocation.java | 8 +-
.../model/graph/DataSinkInvocation.java | 4 +
.../org/apache/streampipes/model/mail/SpEmail.java | 20 +-
.../streampipes/model/message/Notification.java | 7 +-
.../model/migration/MigrationResult.java | 33 +-
.../model/migration/ModelMigratorConfig.java | 53 +
.../streampipes/model/pipeline/Pipeline.java | 11 +
.../streampipes/model/schema/EventProperty.java | 14 +
.../src/main/resources/default-mail-template.html | 150 ++
.../model/migration/ModelMigratorConfigTest.java | 49 +
.../streampipes/manager/assets/AssetManager.java | 5 +
.../manager/endpoint/EndpointItemParser.java | 11 +-
.../endpoint/ExtensionsServiceEndpointUtils.java | 21 +-
.../manager/health/ServiceHealthCheck.java | 6 +-
.../matching/PipelineModificationGenerator.java | 21 +-
.../matching/PipelineVerificationHandlerV2.java | 59 +-
.../mapping/MappingPropertyCalculator.java | 12 +-
.../matching/v2/pipeline/ApplyGroundingStep.java | 15 +-
.../v2/pipeline/CheckCompletedVisitor.java | 24 +-
.../manager/matching/v2/pipeline/PrepareStep.java | 2 +-
.../migration/AbstractMigrationManager.java | 155 ++
.../manager/migration/IMigrationHandler.java | 14 +-
.../manager/migration/MigrationUtils.java | 73 +
.../migration/PipelineElementMigrationManager.java | 249 +++
.../manager/pipeline/PipelineManager.java | 8 +-
.../manager/recommender/ElementRecommender.java | 13 +-
...{DataSinkVerifier.java => AdapterVerifier.java} | 25 +-
.../verification/DataProcessorVerifier.java | 10 +-
.../manager/verification/DataSinkVerifier.java | 10 +-
.../manager/verification/DataStreamVerifier.java | 10 +-
.../manager/verification/ElementVerifier.java | 14 +-
.../manager/verification/StorageState.java | 2 +-
.../verification/extractor/TypeExtractor.java | 22 +-
.../manager/migration/MigrationUtilsTest.java | 77 +
.../streampipes/ps/DataLakeMeasureResourceV4.java | 12 +
.../AbstractPipelineElementResourceManager.java | 2 +-
.../AdapterDescriptionResourceManager.java | 24 +-
.../resource/management/SpResourceManager.java | 4 +
.../resource/management/UserResourceManager.java | 11 +
.../rest/core/base/impl/AbstractRestResource.java | 9 +-
streampipes-rest-extensions/pom.xml | 10 +-
.../extensions/AbstractExtensionsResource.java | 6 +-
.../AbstractPipelineElementResource.java | 7 +-
.../streampipes/rest/extensions/WelcomePage.java | 23 +-
.../connect/AdapterDescriptionResource.java | 65 +
.../connect/HttpServerAdapterResource.java | 4 +-
.../connect/RuntimeResolvableResource.java | 4 +-
.../rest/extensions/html/HTMLGenerator.java | 15 +-
.../rest/extensions/html/JSONGenerator.java | 14 +-
.../extensions/html/page/WelcomePageGenerator.java | 62 +-
.../migration/AdapterMigrationResource.java | 88 +
.../migration/DataProcessorMigrationResource.java | 87 +
.../migration/DataSinkMigrationResource.java | 84 +
.../migration/MigrateExtensionsResource.java | 141 ++
.../pe/DataStreamPipelineElementResource.java | 4 +-
.../pe/InvocablePipelineElementResource.java | 5 +-
.../migration/MigrateExtensionsResourceTest.java | 131 ++
streampipes-rest-shared/pom.xml | 9 +
.../shared/impl/AbstractSharedRestInterface.java | 14 +-
.../streampipes/rest/impl/PipelineResource.java | 1 +
.../apache/streampipes/rest/impl/UserResource.java | 3 +-
.../impl/admin/EmailConfigurationResource.java | 22 +
.../admin/ExtensionsServiceEndpointResource.java | 90 +-
.../rest/impl/admin/MigrationResource.java | 114 ++
.../rest/impl/admin/PipelineElementImport.java | 34 +-
.../rest/impl/connect/AdapterResource.java | 52 +-
.../impl/connect/WorkerAdministrationResource.java | 54 -
.../builder/AbstractProcessingElementBuilder.java | 4 +
.../sdk/builder/ProcessingElementBuilder.java | 59 +-
.../adapter/AdapterConfigurationBuilder.java | 32 +-
.../sdk/extractor/AbstractParameterExtractor.java | 2 +-
.../service/base/rest/ServiceHealthResource.java | 5 +-
.../streampipes/service/core/PostStartupTask.java | 156 ++
.../service/core/StreamPipesCoreApplication.java | 95 +-
.../service/core/StreamPipesResourceConfig.java | 4 +-
.../core/migrations/AvailableMigrations.java | 4 +-
.../core/migrations/v093/AdapterMigration.java | 29 +-
.../v093/StoreEmailTemplatesMigration.java | 58 +
.../api/model/SpServicePathPrefix.java | 1 -
.../api/model/SpServiceUrlProvider.java | 1 -
streampipes-service-discovery-consul/pom.xml | 5 -
.../svcdiscovery/SpServiceDiscoveryCore.java | 2 +-
.../extensions/ExtensionsModelSubmitter.java | 12 +-
.../extensions/ExtensionsResourceConfig.java | 28 +-
.../extensions/connect/ConnectRestClient.java | 46 -
.../connect/ConnectWorkerRegistrationService.java | 48 -
streampipes-sources/pom.xml | 45 -
.../streampipes/storage/api/IAdapterStorage.java | 6 +-
.../storage/api/IDataProcessorStorage.java | 6 +-
.../streampipes/storage/api/IDataSinkStorage.java | 6 +-
.../streampipes/storage/api/INoSqlStorage.java | 2 +-
.../api/IPipelineElementDescriptionStorage.java | 33 +-
.../IPipelineElementDescriptionStorageCache.java | 27 -
.../storage/couchdb/CouchDbStorageManager.java | 4 +-
.../impl/AdapterDescriptionStorageImpl.java | 56 +-
.../couchdb/impl/AdapterInstanceStorageImpl.java | 52 +-
.../couchdb/impl/DataProcessorStorageImpl.java | 10 +-
.../storage/couchdb/impl/DataSinkStorageImpl.java | 10 +-
.../PipelineElementDescriptionStorageImpl.java | 110 +-
.../couchdb/utils/CouchDbViewGenerator.java | 7 +-
.../storage/management/StorageManager.java | 4 +-
streampipes-test-utils/pom.xml | 12 +
.../test/extensions/api/StoreEventCollector.java | 57 +
.../java/org/apache/streampipes/vocabulary/SO.java | 1 +
.../distributed/runtime/DistributedRuntime.java | 2 +-
.../streampipes/wrapper/flink/FlinkRuntime.java | 2 +-
.../wrapper/flink/logger/StatisticLogger.java | 2 -
.../wrapper/kafka/KafkaStreamsRuntime.java | 2 +-
.../wrapper/kafka/converter/JsonToMapFormat.java | 2 -
.../runtime/StandalonePipelineElementRuntime.java | 2 +-
.../wrapper/params/PipelineElementParameters.java | 2 +-
.../wrapper/runtime/PipelineElementRuntime.java | 2 +-
tools/maven/installer.xml | 41 +
.../support/utils/ConnectEventSchemaUtils.ts | 27 +-
ui/cypress/support/utils/connect/ConnectUtils.ts | 2 +-
ui/cypress/tests/adapter/editAdapter.smoke.spec.ts | 12 +-
.../adapter/editAdapterWithPipeline.smoke.spec.ts | 54 -
.../tests/assetManagement/createAsset.spec.ts | 97 +
.../labels/general.spec.ts} | 29 +-
.../labels/labels.spec.ts} | 27 +-
.../userManagement/addUserAdmin.smoke.spec.ts | 2 +
ui/deployment/_variables.scss | 4 +-
ui/deployment/modules.yml | 4 +-
ui/package-lock.json | 2022 ++++++++++----------
ui/package.json | 12 +-
.../src/lib/apis/adapter.service.ts | 47 +-
.../src/lib/apis/datalake-rest.service.ts | 10 +
.../src/lib/apis/mail-config.service.ts | 12 +-
.../src/lib/model/email-config.model.ts | 4 +
.../src/lib/model/gen/streampipes-model-client.ts | 2 +-
.../src/lib/model/gen/streampipes-model.ts | 108 +-
ui/src/app/add/add.component.html | 7 +-
ui/src/app/add/add.routes.ts | 2 +-
.../endpoint-item/endpoint-item.component.scss | 2 -
.../endpoint-item/endpoint-item.component.ts | 8 +-
.../asset-details-panel.component.html | 8 +-
.../asset-details/asset-details.component.html | 1 +
.../asset-overview/asset-overview.component.html | 7 +-
.../edit-asset-link-dialog.component.html | 2 +-
.../manage-asset-links-dialog.component.html | 7 +-
ui/src/app/configuration/configuration.module.ts | 4 +
.../datalake-configuration.component.html | 17 +-
.../datalake-configuration.component.ts | 76 +-
.../email-configuration.component.html | 6 +
.../email-template-configuration.component.html | 87 +
.../email-template-configuration.component.scss} | 31 +-
.../email-template-configuration.component.ts | 92 +
.../export/data-export-import.component.html | 2 +
.../data-export-dialog.component.html | 3 +-
.../export-dialog/data-export-dialog.component.ts | 11 +-
.../data-import-dialog.component.html | 5 +-
.../general-configuration.component.html | 3 +
.../edit-label/edit-label.component.html | 9 +-
.../label-configuration.component.html | 4 +
.../broker-config/broker-config.component.html | 14 +-
.../broker-config/broker-config.component.ts | 8 +-
.../messaging-configuration.component.html | 21 +-
.../adapter-configuration.component.html | 5 +-
.../adapter-configuration.component.ts | 39 +-
.../adapter-settings.component.html | 1 +
.../error-message/error-message.component.html | 2 +-
.../event-property-row.component.html | 17 +-
.../event-property-row.component.scss | 11 +
.../event-property-row.component.ts | 70 +-
.../event-schema-preview.component.html | 1 +
.../event-schema/event-schema.component.html | 19 +-
.../event-schema/event-schema.component.scss | 8 -
.../event-schema/event-schema.component.ts | 125 +-
.../schema-editor-header.component.html | 37 +-
.../schema-editor-header.component.ts | 18 +-
.../adapter-options-panel.component.html | 15 +-
.../adapter-options-panel.component.scss | 3 +-
.../start-adapter-configuration.component.html | 7 +-
.../start-adapter-configuration.component.ts | 14 +-
.../adapter-description.component.html | 42 +-
.../adapter-description.component.scss | 26 +-
.../adapter-description.component.ts | 26 +-
.../data-marketplace.component.html | 16 -
.../data-marketplace/data-marketplace.component.ts | 8 +-
.../existing-adapters.component.html | 57 +-
.../existing-adapters.component.scss | 12 +-
.../existing-adapters.component.ts | 53 +-
ui/src/app/connect/connect.module.ts | 10 +-
.../adapter-started-dialog.component.html | 130 +-
.../adapter-started-dialog.component.scss | 14 -
.../adapter-started-dialog.component.ts | 164 +-
.../adapter-started-loading.component.html | 33 +-
.../adapter-started-loading.component.ts | 12 +-
.../adapter-started-preview.component.html | 23 +-
.../adapter-started-preview.component.ts | 61 +
.../adapter-started-success.component.html | 88 +
.../adapter-started-success.component.scss} | 6 +-
.../adapter-started-success.component.ts} | 24 +-
...adapter-started-update-migration.component.html | 57 +
...adapter-started-update-migration.component.scss | 13 +-
.../adapter-started-update-migration.component.ts | 34 +-
.../delete-adapter-dialog.component.html | 42 +-
.../delete-adapter-dialog.component.ts | 29 +-
.../edit-schema-transformation.component.html | 3 +-
.../edit-schema-transformation.component.ts | 13 +-
.../edit-unit-transformation.component.html | 27 +-
.../edit-unit-transformation.component.ts | 141 +-
.../edit-correction-value.component.html | 70 +-
.../edit-correction-value.component.scss | 8 +
.../edit-correction-value.component.ts | 10 +-
.../edit-timestamp-property.component.html | 16 +-
.../edit-value-transformation.component.html | 4 +-
.../edit-value-transformation.component.ts | 33 +-
.../edit-event-property.component.html | 2 +-
.../edit-event-property.component.ts | 125 +-
.../services/event-property-utils.service.ts | 64 +
.../services/static-value-transform.service.ts | 35 +-
.../services/transformation-rule.service.ts | 278 ++-
.../static-mapping-nary.component.ts | 17 +-
.../static-mapping-unary.component.ts | 1 -
.../pipeline-assembly.component.ts | 4 +
.../pipeline-element-icon-stand-row.component.html | 2 +-
.../pipeline-element-icon-stand.component.html | 9 -
.../pipeline-element-icon-stand.component.ts | 23 +-
.../components/pipeline/pipeline.component.ts | 23 +-
ui/src/app/editor/editor.component.html | 1 -
ui/src/app/editor/editor.component.ts | 118 +-
ui/src/app/editor/editor.module.ts | 7 -
ui/src/app/editor/model/editor.model.ts | 1 -
.../editor/services/pipeline-validation.service.ts | 29 +-
ui/src/app/editor/utils/editor.utils.ts | 2 -
ui/src/app/home/components/status.component.html | 4 +-
ui/src/app/home/components/status.component.ts | 49 +-
.../welcome-tour/welcome-tour.component.html | 7 +-
.../welcome-tour/welcome-tour.component.scss | 0
.../dialog/welcome-tour/welcome-tour.component.ts | 11 +-
ui/src/app/home/home.component.html | 10 +-
ui/src/app/home/home.component.ts | 163 +-
ui/src/app/home/home.module.ts | 3 +-
.../pipeline-overview.component.html | 58 +-
.../pipeline-overview.component.scss | 12 +-
ui/src/app/pipelines/pipelines.component.html | 9 +
ui/src/app/pipelines/pipelines.component.ts | 19 +-
ui/src/app/services/services.module.ts | 4 -
.../app/services/tour/adapter-tour-2.constants.ts | 141 --
.../app/services/tour/adapter-tour-3.constants.ts | 115 --
ui/src/app/services/tour/adapter-tour.constants.ts | 142 +-
.../tour/create-pipeline-tour.constants.ts | 85 +-
ui/src/app/services/tour/shepherd.service.ts | 32 +-
ui/src/app/services/tour/tour-provider.service.ts | 6 +-
ui/src/scss/sp/main.scss | 20 +-
ui/src/scss/sp/pipeline-element-options.scss | 5 -
ui/src/scss/sp/shepherd-new.scss | 748 ++------
600 files changed, 11873 insertions(+), 9841 deletions(-)
delete mode 100644 .idea/runConfigurations/sources_watertank_simulator_jvm.xml
delete mode 100644
installer/cli/deploy/standalone/sources-watertank-simulator/docker-compose.dev.yml
copy installer/compose/{docker-compose.yml => docker-compose.quickstart.yml}
(89%)
rename {streampipes-extensions/streampipes-sources-watertank-simulator =>
installer/compose/quickstart}/Dockerfile (78%)
create mode 100755 installer/compose/quickstart/upload.sh
create mode 100644 installer/compose/quickstart/zip_folder/Example Asset -
Smart Factory Monitoring and Analysis.zip
copy installer/k8s/templates/{core/extensions-all-iiot-deployment.yaml =>
monitor/grafana/grafana-deployment.yml} (56%)
copy installer/k8s/templates/{external/kafka/kafka-service.yaml =>
monitor/grafana/grafana-pv.yml} (62%)
copy installer/k8s/templates/{external/kafka/kafka-service.yaml =>
monitor/grafana/grafana-pvc.yml} (65%)
rename
installer/{cli/deploy/standalone/sources-watertank-simulator/docker-compose.yml
=> k8s/templates/monitor/grafana/grafana-service.yml} (68%)
create mode 100644
installer/k8s/templates/monitor/prometheus/prometheus-configmap.yaml
create mode 100644
installer/k8s/templates/monitor/prometheus/prometheus-deployment.yml
copy installer/k8s/templates/{external/kafka/kafka-service.yaml =>
monitor/prometheus/prometheus-pv.yml} (61%)
copy installer/k8s/templates/{external/kafka/kafka-service.yaml =>
monitor/prometheus/prometheus-pvc.yml} (64%)
rename
installer/{cli/deploy/standalone/sources-vehicle-simulator/docker-compose.yml
=> k8s/templates/monitor/prometheus/prometheus-service.yml} (67%)
rename
installer/{cli/deploy/standalone/sources-vehicle-simulator/docker-compose.dev.yml
=> k8s/templates/monitor/prometheus/token-pvc.yml} (67%)
create mode 100644
streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/management/AdapterMigrationManager.java
create mode 100644
streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/management/AdapterUpdateManagement.java
copy
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/{transform/schema/RenameTransformationRule.java
=> SupportsNestedTransformationRule.java} (51%)
copy
streampipes-logging/src/main/java/org/apache/streampipes/logging/api/Logger.java
=>
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/convert/ProvidesConversionResult.java
(69%)
create mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/convert/SchemaConverter.java
create mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/convert/ToOriginalSchemaConverter.java
create mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/convert/ToTransformedSchemaConverter.java
copy
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/elements/{AddValuePipelineElement.java
=> AdapterTransformationPipelineElement.java} (52%)
delete mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/elements/TransformSchemaAdapterPipelineElement.java
delete mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/elements/TransformStreamAdapterElement.java
delete mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/elements/TransformValueAdapterPipelineElement.java
create mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/generator/StatefulTransformationRuleGeneratorVisitor.java
create mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/generator/StatelessTransformationRuleGeneratorVisitor.java
rename
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/html/model/DataSourceDescriptionHtml.java
=>
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/generator/TransformationRuleGeneratorVisitor.java
(60%)
copy
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/transform/schema/{SchemaTransformationRule.java
=> AddValueTransformationRule.java} (57%)
delete mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/transform/schema/SchemaEventTransformer.java
delete mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/transform/stream/StreamEventTransformer.java
rename
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/transform/value/{ValueTransformationRule.java
=> AddTimestampTransformationRule.java} (71%)
rename
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/transform/value/{TimestampTranformationRule.java
=> TimestampTransformationRule.java} (53%)
delete mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/transform/value/ValueEventTransformer.java
create mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/utils/ConversionUtils.java
copy
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/{Util.java
=> utils/Utils.java} (71%)
copy
streampipes-connect-shared/src/{main/java/org/apache/streampipes/connect/shared/preprocessing/Util.java
=>
test/java/org/apache/streampipes/connect/shared/preprocessing/UtilsTest.java}
(52%)
create mode 100644
streampipes-connect-shared/src/test/java/org/apache/streampipes/connect/shared/preprocessing/convert/Helpers.java
create mode 100644
streampipes-connect-shared/src/test/java/org/apache/streampipes/connect/shared/preprocessing/convert/ToOriginalSchemaConverterTest.java
create mode 100644
streampipes-connect-shared/src/test/java/org/apache/streampipes/connect/shared/preprocessing/convert/ToTransformedSchemaConverterTest.java
create mode 100644
streampipes-connect-shared/src/test/java/org/apache/streampipes/connect/shared/preprocessing/elements/AdapterTransformationPipelineElementTest.java
create mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/influx/DataLakeMeasurementCount.java
rename
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/transform/stream/StreamTransformationRule.java
=>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/migration/DataSinkMigrator.java
(72%)
copy
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/transform/value/TimestampTranformationRuleMode.java
=>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/migration/IAdapterMigrator.java
(71%)
copy
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/{extractor/IDataProcessorParameterExtractor.java
=> migration/IDataProcessorMigrator.java} (75%)
create mode 100644
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/migration/IModelMigrator.java
rename
streampipes-model/src/main/java/org/apache/streampipes/model/connect/rules/value/TimestampTransformationRuleMode.java
=>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/migration/MigrationComparison.java
(77%)
rename {streampipes-sources/src/main/java/org/apache/streampipes/sources =>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect}/AbstractAdapterIncludedStream.java
(93%)
rename {streampipes-sources/src/main/java/org/apache/streampipes/sources =>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect}/AbstractAlreadyExistingStream.java
(93%)
create mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/SchemaUpdateManagement.java
create mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/TransformationRuleUpdateVisitor.java
rename
{streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter}/BrokerEventProcessor.java
(96%)
copy streampipes-extensions/{streampipes-pipeline-elements-shared =>
streampipes-connectors-kafka}/pom.xml (70%)
rename
streampipes-extensions/{streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream
=>
streampipes-connectors-kafka/src/main/java/org/apache/streampipes/extensions/connectors/kafka/adapter}/KafkaProtocol.java
(96%)
rename
streampipes-extensions/{streampipes-pipeline-elements-shared/src/main/java/org/apache/streampipes/pe/shared/config
=>
streampipes-connectors-kafka/src/main/java/org/apache/streampipes/extensions/connectors/kafka/shared}/kafka/KafkaConfig.java
(97%)
rename
streampipes-extensions/{streampipes-pipeline-elements-shared/src/main/java/org/apache/streampipes/pe/shared/config/kafka
=>
streampipes-connectors-kafka/src/main/java/org/apache/streampipes/extensions/connectors/kafka/shared}/kafka/KafkaConnectUtils.java
(88%)
rename
streampipes-extensions/{streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/kafka
=>
streampipes-connectors-kafka/src/main/java/org/apache/streampipes/extensions/connectors/kafka/sink}/KafkaParameters.java
(89%)
rename
streampipes-extensions/{streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/kafka
=>
streampipes-connectors-kafka/src/main/java/org/apache/streampipes/extensions/connectors/kafka/sink}/KafkaPublishSink.java
(64%)
rename streampipes-extensions/{streampipes-connect-adapters-iiot =>
streampipes-connectors-kafka}/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.kafka/documentation.md
(100%)
rename streampipes-extensions/{streampipes-connect-adapters-iiot =>
streampipes-connectors-kafka}/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.kafka/icon.png
(100%)
rename streampipes-extensions/{streampipes-connect-adapters-iiot =>
streampipes-connectors-kafka}/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.kafka/strings.en
(100%)
rename streampipes-extensions/{streampipes-sinks-brokers-jvm =>
streampipes-connectors-kafka}/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.kafka/documentation.md
(100%)
rename streampipes-extensions/{streampipes-sinks-brokers-jvm =>
streampipes-connectors-kafka}/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.kafka/icon.png
(100%)
rename streampipes-extensions/{streampipes-sinks-brokers-jvm =>
streampipes-connectors-kafka}/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.kafka/strings.en
(100%)
copy {streampipes-connect-shared =>
streampipes-extensions/streampipes-connectors-mqtt}/pom.xml (84%)
rename
streampipes-extensions/{streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream
=>
streampipes-connectors-mqtt/src/main/java/org/apache/streampipes/extensions/connectors/mqtt/adapter}/MqttProtocol.java
(92%)
rename
streampipes-extensions/{streampipes-pipeline-elements-shared/src/main/java/org/apache/streampipes/pe/shared/config/mqtt
=>
streampipes-connectors-mqtt/src/main/java/org/apache/streampipes/extensions/connectors/mqtt/shared}/MqttConfig.java
(95%)
rename
streampipes-extensions/{streampipes-pipeline-elements-shared/src/main/java/org/apache/streampipes/pe/shared/config/mqtt
=>
streampipes-connectors-mqtt/src/main/java/org/apache/streampipes/extensions/connectors/mqtt/shared}/MqttConnectUtils.java
(93%)
rename
streampipes-extensions/{streampipes-pipeline-elements-shared/src/main/java/org/apache/streampipes/pe/shared/config/mqtt
=>
streampipes-connectors-mqtt/src/main/java/org/apache/streampipes/extensions/connectors/mqtt/shared}/MqttConsumer.java
(97%)
create mode 100644
streampipes-extensions/streampipes-connectors-mqtt/src/main/java/org/apache/streampipes/extensions/connectors/mqtt/sink/MqttPublisherSink.java
rename
streampipes-extensions/{streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/mqtt
=>
streampipes-connectors-mqtt/src/main/java/org/apache/streampipes/extensions/connectors/mqtt/sink/common}/MqttClient.java
(94%)
rename
streampipes-extensions/{streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/mqtt
=>
streampipes-connectors-mqtt/src/main/java/org/apache/streampipes/extensions/connectors/mqtt/sink}/common/MqttOptions.java
(67%)
rename
streampipes-extensions/{streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/mqtt
=>
streampipes-connectors-mqtt/src/main/java/org/apache/streampipes/extensions/connectors/mqtt/sink}/common/MqttUtils.java
(97%)
rename streampipes-extensions/{streampipes-connect-adapters-iiot =>
streampipes-connectors-mqtt}/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.mqtt/documentation.md
(100%)
rename streampipes-extensions/{streampipes-connect-adapters-iiot =>
streampipes-connectors-mqtt}/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.mqtt/icon.png
(100%)
rename streampipes-extensions/{streampipes-connect-adapters-iiot =>
streampipes-connectors-mqtt}/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.mqtt/strings.en
(100%)
rename streampipes-extensions/{streampipes-sinks-brokers-jvm =>
streampipes-connectors-mqtt}/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.mqtt/documentation.md
(100%)
rename streampipes-extensions/{streampipes-sinks-brokers-jvm =>
streampipes-connectors-mqtt}/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.mqtt/icon.png
(100%)
rename streampipes-extensions/{streampipes-sinks-brokers-jvm =>
streampipes-connectors-mqtt}/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.mqtt/strings.en
(100%)
copy {streampipes-connect-shared =>
streampipes-extensions/streampipes-connectors-nats}/pom.xml (82%)
rename
streampipes-extensions/{streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream
=>
streampipes-connectors-nats/src/main/java/org/apache/streampipes/extensions/connectors/nats/adapter}/NatsProtocol.java
(81%)
rename
streampipes-extensions/{streampipes-pipeline-elements-shared/src/main/java/org/apache/streampipes/pe/shared/config/nats
=>
streampipes-connectors-nats/src/main/java/org/apache/streampipes/extensions/connectors/nats/shared}/NatsConfigUtils.java
(95%)
rename
streampipes-extensions/{streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/nats/NatsController.java
=>
streampipes-connectors-nats/src/main/java/org/apache/streampipes/extensions/connectors/nats/sink/NatsSink.java}
(74%)
rename streampipes-extensions/{streampipes-connect-adapters-iiot =>
streampipes-connectors-nats}/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.nats/documentation.md
(100%)
rename streampipes-extensions/{streampipes-connect-adapters-iiot =>
streampipes-connectors-nats}/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.nats/icon.png
(100%)
rename streampipes-extensions/{streampipes-connect-adapters-iiot =>
streampipes-connectors-nats}/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.nats/strings.en
(100%)
rename streampipes-extensions/{streampipes-sinks-brokers-jvm =>
streampipes-connectors-nats}/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.nats/documentation.md
(100%)
rename streampipes-extensions/{streampipes-sinks-brokers-jvm =>
streampipes-connectors-nats}/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.nats/icon.png
(100%)
rename streampipes-extensions/{streampipes-sinks-brokers-jvm =>
streampipes-connectors-nats}/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.nats/strings.en
(100%)
create mode 100644
streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/migration/OpcUaAdapterMigrationV1.java
copy {streampipes-connect-shared =>
streampipes-extensions/streampipes-connectors-pulsar}/pom.xml (77%)
rename
streampipes-extensions/{streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream/pulsar
=>
streampipes-connectors-pulsar/src/main/java/org/apache/streampipes/extensions/connectors/pulsar/adapter}/PulsarConfig.java
(79%)
rename
streampipes-extensions/{streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream/pulsar
=>
streampipes-connectors-pulsar/src/main/java/org/apache/streampipes/extensions/connectors/pulsar/adapter}/PulsarProtocol.java
(97%)
rename
streampipes-extensions/{streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream/pulsar
=>
streampipes-connectors-pulsar/src/main/java/org/apache/streampipes/extensions/connectors/pulsar/adapter}/PulsarUtils.java
(94%)
rename
streampipes-extensions/{streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/pulsar
=>
streampipes-connectors-pulsar/src/main/java/org/apache/streampipes/extensions/connectors/pulsar/sink}/PulsarParameters.java
(67%)
rename
streampipes-extensions/{streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/pulsar
=>
streampipes-connectors-pulsar/src/main/java/org/apache/streampipes/extensions/connectors/pulsar/sink}/PulsarPublisherSink.java
(73%)
rename streampipes-extensions/{streampipes-connect-adapters-iiot =>
streampipes-connectors-pulsar}/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.pulsar/documentation.md
(100%)
rename streampipes-extensions/{streampipes-connect-adapters-iiot =>
streampipes-connectors-pulsar}/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.pulsar/icon.png
(100%)
rename streampipes-extensions/{streampipes-connect-adapters-iiot =>
streampipes-connectors-pulsar}/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.pulsar/strings.en
(100%)
rename streampipes-extensions/{streampipes-sinks-brokers-jvm =>
streampipes-connectors-pulsar}/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.pulsar/documentation.md
(100%)
rename streampipes-extensions/{streampipes-sinks-brokers-jvm =>
streampipes-connectors-pulsar}/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.pulsar/icon.png
(100%)
rename streampipes-extensions/{streampipes-sinks-brokers-jvm =>
streampipes-connectors-pulsar}/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.pulsar/strings.en
(100%)
rename
streampipes-extensions/{streampipes-sinks-brokers-jvm/src/test/java/org/apache/streampipes/sinks/brokers/jvm
=>
streampipes-connectors-pulsar/src/test/java/org/apache/streampipes/extensions/connectors}/pulsar/TestPulsarParameters.java
(72%)
rename
streampipes-extensions/{streampipes-sinks-brokers-jvm/src/test/java/org/apache/streampipes/sinks/brokers/jvm
=>
streampipes-connectors-pulsar/src/test/java/org/apache/streampipes/extensions/connectors}/pulsar/TestPulsarPublisherSink.java
(50%)
copy {streampipes-connect-shared =>
streampipes-extensions/streampipes-connectors-rocketmq}/pom.xml (77%)
rename
streampipes-extensions/{streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream/rocketmq
=>
streampipes-connectors-rocketmq/src/main/java/org/apache/streampipes/extensions/connectors/rocketmq/adapter}/RocketMQConsumer.java
(96%)
rename
streampipes-extensions/{streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream/rocketmq
=>
streampipes-connectors-rocketmq/src/main/java/org/apache/streampipes/extensions/connectors/rocketmq/adapter}/RocketMQProtocol.java
(97%)
rename
streampipes-extensions/{streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream/rocketmq
=>
streampipes-connectors-rocketmq/src/main/java/org/apache/streampipes/extensions/connectors/rocketmq/adapter}/RocketMQUtils.java
(96%)
rename
streampipes-extensions/{streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/rocketmq
=>
streampipes-connectors-rocketmq/src/main/java/org/apache/streampipes/extensions/connectors/rocketmq/sink}/RocketMQParameters.java
(70%)
rename
streampipes-extensions/{streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/rocketmq
=>
streampipes-connectors-rocketmq/src/main/java/org/apache/streampipes/extensions/connectors/rocketmq/sink}/RocketMQPublisherSink.java
(74%)
rename streampipes-extensions/{streampipes-connect-adapters-iiot =>
streampipes-connectors-rocketmq}/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.rocketmq/documentation.md
(100%)
rename streampipes-extensions/{streampipes-connect-adapters-iiot =>
streampipes-connectors-rocketmq}/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.rocketmq/icon.png
(100%)
rename streampipes-extensions/{streampipes-connect-adapters-iiot =>
streampipes-connectors-rocketmq}/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.rocketmq/strings.en
(100%)
rename streampipes-extensions/{streampipes-sinks-brokers-jvm =>
streampipes-connectors-rocketmq}/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.rocketmq/documentation.md
(100%)
rename streampipes-extensions/{streampipes-sinks-brokers-jvm =>
streampipes-connectors-rocketmq}/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.rocketmq/icon.png
(100%)
rename streampipes-extensions/{streampipes-sinks-brokers-jvm =>
streampipes-connectors-rocketmq}/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.rocketmq/strings.en
(100%)
rename
streampipes-extensions/{streampipes-sinks-brokers-jvm/src/test/java/org/apache/streampipes/sinks/brokers/jvm
=>
streampipes-connectors-rocketmq/src/test/java/org/apache/streampipes/extensions/connectors}/rocketmq/TestRocketMQPublisherSink.java
(76%)
copy {streampipes-connect-shared =>
streampipes-extensions/streampipes-connectors-tubemq}/pom.xml (76%)
rename
streampipes-extensions/{streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream
=>
streampipes-connectors-tubemq/src/main/java/org/apache/streampipes/extensions/connectors/tubemq/adapter}/TubeMQProtocol.java
(98%)
rename
streampipes-extensions/{streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/tubemq
=>
streampipes-connectors-tubemq/src/main/java/org/apache/streampipes/extensions/connectors/tubemq/sink}/TubeMQParameters.java
(75%)
rename
streampipes-extensions/{streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/tubemq
=>
streampipes-connectors-tubemq/src/main/java/org/apache/streampipes/extensions/connectors/tubemq/sink}/TubeMQPublisherSink.java
(75%)
rename streampipes-extensions/{streampipes-connect-adapters-iiot =>
streampipes-connectors-tubemq}/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.tubemq/documentation.md
(100%)
rename streampipes-extensions/{streampipes-connect-adapters-iiot =>
streampipes-connectors-tubemq}/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.tubemq/icon.png
(100%)
rename streampipes-extensions/{streampipes-connect-adapters-iiot =>
streampipes-connectors-tubemq}/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.tubemq/strings.en
(100%)
rename streampipes-extensions/{streampipes-sinks-brokers-jvm =>
streampipes-connectors-tubemq}/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.tubemq/documentation.md
(100%)
rename streampipes-extensions/{streampipes-sinks-brokers-jvm =>
streampipes-connectors-tubemq}/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.tubemq/icon.png
(100%)
rename streampipes-extensions/{streampipes-sinks-brokers-jvm =>
streampipes-connectors-tubemq}/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.tubemq/strings.en
(100%)
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-shared/src/main/java/org/apache/streampipes/pe/shared/config/kafka/KafkaConnectUtils.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-shared/src/main/java/org/apache/streampipes/pe/shared/config/kafka/kafka/KafkaConfig.java
create mode 100644
streampipes-extensions/streampipes-processors-filters-jvm/src/test/java/org/apache/streampipes/processors/filters/jvm/processor/booleanfilter/TestBooleanFilterProcessor.java
create mode 100644
streampipes-extensions/streampipes-processors-filters-jvm/src/test/java/org/apache/streampipes/processors/filters/jvm/processor/merge/TestMergeByTimeProcessor.java
create mode 100644
streampipes-extensions/streampipes-processors-filters-jvm/src/test/java/org/apache/streampipes/processors/filters/jvm/processor/textfilter/TestTextFilterProcessor.java
delete mode 100644
streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/mqtt/MqttPublisherSink.java
delete mode 100644
streampipes-extensions/streampipes-sources-vehicle-simulator/Dockerfile
delete mode 100644
streampipes-extensions/streampipes-sources-vehicle-simulator/development/env
delete mode 100644
streampipes-extensions/streampipes-sources-vehicle-simulator/pom.xml
delete mode 100644
streampipes-extensions/streampipes-sources-vehicle-simulator/src/main/java/org/apache/streampipes/sources/vehicle/simulator/VehicleSimulatorInit.java
delete mode 100644
streampipes-extensions/streampipes-sources-vehicle-simulator/src/main/java/org/apache/streampipes/sources/vehicle/simulator/config/ConfigKeys.java
delete mode 100644
streampipes-extensions/streampipes-sources-vehicle-simulator/src/main/java/org/apache/streampipes/sources/vehicle/simulator/simulator/VehicleDataSimulator.java
delete mode 100644
streampipes-extensions/streampipes-sources-vehicle-simulator/src/main/java/org/apache/streampipes/sources/vehicle/simulator/vehicle/streams/VehicleStream.java
delete mode 100644
streampipes-extensions/streampipes-sources-vehicle-simulator/src/main/resources/streampipesDemoConfig.json
delete mode 100644
streampipes-extensions/streampipes-sources-vehicle-simulator/src/main/resources/streampipesVehicleWorkflow.json
delete mode 100644
streampipes-extensions/streampipes-sources-watertank-simulator/development/env
delete mode 100644
streampipes-extensions/streampipes-sources-watertank-simulator/pom.xml
delete mode 100644
streampipes-extensions/streampipes-sources-watertank-simulator/src/main/java/org/apache/streampipes/sources/watertank/simulator/WatertankSimulatorInit.java
delete mode 100644
streampipes-extensions/streampipes-sources-watertank-simulator/src/main/java/org/apache/streampipes/sources/watertank/simulator/utils/WatertankDataSimulator.java
delete mode 100644
streampipes-extensions/streampipes-sources-watertank-simulator/src/main/java/org/apache/streampipes/sources/watertank/simulator/vocabulary/WaterTankVocabulary.java
delete mode 100644
streampipes-extensions/streampipes-sources-watertank-simulator/src/main/java/org/apache/streampipes/sources/watertank/simulator/watertank/streams/FlowRate1Stream.java
delete mode 100644
streampipes-extensions/streampipes-sources-watertank-simulator/src/main/java/org/apache/streampipes/sources/watertank/simulator/watertank/streams/FlowRate2Stream.java
delete mode 100644
streampipes-extensions/streampipes-sources-watertank-simulator/src/main/java/org/apache/streampipes/sources/watertank/simulator/watertank/streams/PressureTankStream.java
delete mode 100644
streampipes-extensions/streampipes-sources-watertank-simulator/src/main/java/org/apache/streampipes/sources/watertank/simulator/watertank/streams/WaterLevel1Stream.java
delete mode 100644
streampipes-extensions/streampipes-sources-watertank-simulator/src/main/java/org/apache/streampipes/sources/watertank/simulator/watertank/streams/WaterLevel2Stream.java
delete mode 100644
streampipes-extensions/streampipes-sources-watertank-simulator/src/main/resources/org.apache.streampipes.sources.simulator.flowrate1/icon.png
delete mode 100644
streampipes-extensions/streampipes-sources-watertank-simulator/src/main/resources/org.apache.streampipes.sources.simulator.flowrate1/strings.en
delete mode 100644
streampipes-extensions/streampipes-sources-watertank-simulator/src/main/resources/org.apache.streampipes.sources.simulator.flowrate2/documentation.md
delete mode 100644
streampipes-extensions/streampipes-sources-watertank-simulator/src/main/resources/org.apache.streampipes.sources.simulator.flowrate2/icon.png
delete mode 100644
streampipes-extensions/streampipes-sources-watertank-simulator/src/main/resources/org.apache.streampipes.sources.simulator.flowrate2/strings.en
delete mode 100644
streampipes-extensions/streampipes-sources-watertank-simulator/src/main/resources/org.apache.streampipes.sources.simulator.pressure/documentation.md
delete mode 100644
streampipes-extensions/streampipes-sources-watertank-simulator/src/main/resources/org.apache.streampipes.sources.simulator.pressure/icon.png
delete mode 100644
streampipes-extensions/streampipes-sources-watertank-simulator/src/main/resources/org.apache.streampipes.sources.simulator.pressure/strings.en
delete mode 100644
streampipes-extensions/streampipes-sources-watertank-simulator/src/main/resources/org.apache.streampipes.sources.simulator.waterlevel1/documentation.md
delete mode 100644
streampipes-extensions/streampipes-sources-watertank-simulator/src/main/resources/org.apache.streampipes.sources.simulator.waterlevel1/icon.png
delete mode 100644
streampipes-extensions/streampipes-sources-watertank-simulator/src/main/resources/org.apache.streampipes.sources.simulator.waterlevel1/strings.en
delete mode 100644
streampipes-extensions/streampipes-sources-watertank-simulator/src/main/resources/org.apache.streampipes.sources.simulator.waterlevel2/icon.png
delete mode 100644
streampipes-extensions/streampipes-sources-watertank-simulator/src/main/resources/org.apache.streampipes.sources.simulator.waterlevel2/strings.en
delete mode 100644
streampipes-extensions/streampipes-sources-watertank-simulator/src/main/resources/streampipesDemoConfig.json
delete mode 100644
streampipes-extensions/streampipes-sources-watertank-simulator/src/main/resources/streampipesFestoFlowRateWorkflow.json
delete mode 100644
streampipes-extensions/streampipes-sources-watertank-simulator/src/main/resources/streampipesFestoLevel101Workflow.json
delete mode 100644
streampipes-extensions/streampipes-sources-watertank-simulator/src/main/resources/streampipesFestoLevel102Workflow.json
delete mode 100644
streampipes-extensions/streampipes-sources-watertank-simulator/src/main/resources/streampipesFestoPressureWorkflow.json
delete mode 100644
streampipes-extensions/streampipes-sources-watertank-simulator/src/main/resources/streampipesSiemensFlowRateWorkflow.json
delete mode 100644 streampipes-logging/pom.xml
delete mode 100644
streampipes-logging/src/main/java/org/apache/streampipes/logging/LoggerFactory.java
delete mode 100644
streampipes-logging/src/main/java/org/apache/streampipes/logging/impl/EventStatisticLogger.java
delete mode 100644
streampipes-logging/src/main/java/org/apache/streampipes/logging/impl/PeLogger.java
delete mode 100644
streampipes-logging/src/main/java/org/apache/streampipes/logging/model/Log.java
delete mode 100644
streampipes-logging/src/main/java/org/apache/streampipes/logging/model/LogRequest.java
copy
streampipes-mail/src/main/java/org/apache/streampipes/mail/template/{TestMailTemplate.java
=> CustomMailTemplate.java} (58%)
delete mode 100644
streampipes-mail/src/main/resources/mail-template-footer.html
delete mode 100644 streampipes-mail/src/main/resources/mail-template-outer.html
copy
streampipes-model/src/main/java/org/apache/streampipes/model/{connect/rules/value/AddValueTransformationRuleDescription.java
=> base/VersionedNamedStreamPipesEntity.java} (53%)
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/configuration/DefaultEmailTemplateConfiguration.java
rename
streampipes-logging/src/main/java/org/apache/streampipes/logging/api/Logger.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/configuration/EmailTemplateConfig.java
(68%)
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/PipelineUpdateInfo.java
copy
streampipes-model/src/main/java/org/apache/streampipes/model/connect/rules/{TransformationRuleDescription.java
=> ITransformationRuleVisitor.java} (62%)
copy
streampipes-model/src/main/java/org/apache/streampipes/model/{extensions/svcdiscovery/SpServiceTagPrefix.java
=> connect/rules/TransformationRulePriority.java} (62%)
copy
streampipes-extensions/streampipes-sources-watertank-simulator/src/main/java/org/apache/streampipes/sources/watertank/simulator/config/ConfigKeys.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/extensions/migration/MigrationRequest.java
(62%)
rename
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/Util.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/migration/MigrationResult.java
(54%)
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/migration/ModelMigratorConfig.java
create mode 100644
streampipes-model/src/main/resources/default-mail-template.html
create mode 100644
streampipes-model/src/test/java/org/apache/streampipes/model/migration/ModelMigratorConfigTest.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/migration/AbstractMigrationManager.java
rename
streampipes-extensions/streampipes-sources-watertank-simulator/src/main/java/org/apache/streampipes/sources/watertank/simulator/config/ConfigKeys.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/migration/IMigrationHandler.java
(67%)
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/migration/MigrationUtils.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/migration/PipelineElementMigrationManager.java
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/{DataSinkVerifier.java
=> AdapterVerifier.java} (75%)
create mode 100644
streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/migration/MigrationUtilsTest.java
copy
streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/IAdapterStorage.java
=>
streampipes-resource-management/src/main/java/org/apache/streampipes/resource/management/AdapterDescriptionResourceManager.java
(59%)
create mode 100644
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/connect/AdapterDescriptionResource.java
create mode 100644
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/migration/AdapterMigrationResource.java
create mode 100644
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/migration/DataProcessorMigrationResource.java
create mode 100644
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/migration/DataSinkMigrationResource.java
create mode 100644
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/migration/MigrateExtensionsResource.java
create mode 100644
streampipes-rest-extensions/src/test/java/org/apache/streampipes/rest/extensions/migration/MigrateExtensionsResourceTest.java
create mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/admin/MigrationResource.java
delete mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/connect/WorkerAdministrationResource.java
create mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/PostStartupTask.java
create mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093/StoreEmailTemplatesMigration.java
delete mode 100644
streampipes-service-extensions/src/main/java/org/apache/streampipes/service/extensions/connect/ConnectRestClient.java
delete mode 100644
streampipes-service-extensions/src/main/java/org/apache/streampipes/service/extensions/connect/ConnectWorkerRegistrationService.java
delete mode 100644 streampipes-sources/pom.xml
delete mode 100644
streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/IPipelineElementDescriptionStorageCache.java
create mode 100644
streampipes-test-utils/src/main/java/org/apache/streampipes/test/extensions/api/StoreEventCollector.java
create mode 100644 tools/maven/installer.xml
delete mode 100644
ui/cypress/tests/adapter/editAdapterWithPipeline.smoke.spec.ts
create mode 100644 ui/cypress/tests/assetManagement/createAsset.spec.ts
copy ui/cypress/tests/{adapter/randomDataSimulatorStream.ts =>
configuration/labels/general.spec.ts} (50%)
rename ui/cypress/tests/{adapter/randomDataSimulatorStream.ts =>
configuration/labels/labels.spec.ts} (60%)
create mode 100644
ui/src/app/configuration/email-configuration/email-template-configuration/email-template-configuration.component.html
copy
ui/src/app/{connect/dialog/adapter-started/adapter-started-dialog.component.scss
=>
configuration/email-configuration/email-template-configuration/email-template-configuration.component.scss}
(66%)
create mode 100644
ui/src/app/configuration/email-configuration/email-template-configuration/email-template-configuration.component.ts
rename
streampipes-extensions/streampipes-sources-watertank-simulator/src/main/resources/org.apache.streampipes.sources.simulator.flowrate1/documentation.md
=>
ui/src/app/connect/dialog/adapter-started/adapter-started-loading/adapter-started-loading.component.html
(68%)
rename
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/transform/schema/SchemaTransformationRule.java
=>
ui/src/app/connect/dialog/adapter-started/adapter-started-loading/adapter-started-loading.component.ts
(76%)
rename
streampipes-extensions/streampipes-sources-watertank-simulator/src/main/resources/org.apache.streampipes.sources.simulator.waterlevel2/documentation.md
=>
ui/src/app/connect/dialog/adapter-started/adapter-started-preview/adapter-started-preview.component.html
(76%)
create mode 100644
ui/src/app/connect/dialog/adapter-started/adapter-started-preview/adapter-started-preview.component.ts
create mode 100644
ui/src/app/connect/dialog/adapter-started/adapter-started-success/adapter-started-success.component.html
copy
ui/src/app/connect/dialog/adapter-started/{adapter-started-dialog.component.scss
=> adapter-started-success/adapter-started-success.component.scss} (92%)
copy
ui/src/app/{configuration/messaging-configuration/broker-config/broker-config.component.ts
=>
connect/dialog/adapter-started/adapter-started-success/adapter-started-success.component.ts}
(62%)
create mode 100644
ui/src/app/connect/dialog/adapter-started/adapter-started-update-migration/adapter-started-update-migration.component.html
rename
streampipes-extensions/streampipes-connect-adapters/src/test/java/org/apache/streampipes/connect/adapters/generic/Mock.java
=>
ui/src/app/connect/dialog/adapter-started/adapter-started-update-migration/adapter-started-update-migration.component.scss
(81%)
rename
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/elements/AddTimestampPipelineElement.java
=>
ui/src/app/connect/dialog/adapter-started/adapter-started-update-migration/adapter-started-update-migration.component.ts
(58%)
create mode 100644 ui/src/app/connect/services/event-property-utils.service.ts
rename
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/elements/AddValuePipelineElement.java
=> ui/src/app/connect/services/static-value-transform.service.ts (57%)
rename ui/src/app/{editor =>
home}/dialog/welcome-tour/welcome-tour.component.html (92%)
rename ui/src/app/{editor =>
home}/dialog/welcome-tour/welcome-tour.component.scss (100%)
rename ui/src/app/{editor =>
home}/dialog/welcome-tour/welcome-tour.component.ts (88%)
delete mode 100644 ui/src/app/services/tour/adapter-tour-2.constants.ts
delete mode 100644 ui/src/app/services/tour/adapter-tour-3.constants.ts
