This is an automated email from the ASF dual-hosted git repository. zehnder pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/streampipes.git
commit e04f69e3cc8388a9efc90255bc6616e9beae2a84 Merge: 55bf6153a6 ba27eac14c Author: Philipp Zehnder <[email protected]> AuthorDate: Mon Dec 15 12:49:33 2025 +0100 Merge commit 'ba27eac14c' .asf.yaml | 22 +- .github/ISSUE_TEMPLATE/bug_report.yml | 2 +- .github/workflows/build.yml | 18 +- .github/workflows/cypress-test.yml | 35 +- .github/workflows/extensions-docs.yml | 12 +- .github/workflows/go-client-e2e-test.yml | 6 +- .github/workflows/go-client.yml | 2 +- .github/workflows/go-docs.yml | 6 +- .github/workflows/osv-scanner.yml | 54 - .github/workflows/pr-labeler.yml | 2 +- .github/workflows/pr-validation.yml | 77 +- .github/workflows/pypi-deployment.yml | 7 +- .github/workflows/python-docs.yml | 6 +- .github/workflows/stale-bot.yml | 2 +- .gitignore | 6 +- .mvn/develocity.xml | 47 + .mvn/extensions.xml | 34 + NOTICE | 2 +- RELEASE_NOTES.md | 336 +- VULNERABILITY.md | 11 - .../streampipes-archetype-extensions-jvm/pom.xml | 2 +- .../src/main/resources/archetype-resources/pom.xml | 2 +- .../pom.xml | 2 +- .../src/main/resources/archetype-resources/pom.xml | 4 +- .../streampipes-archetype-pe-sinks-flink/pom.xml | 2 +- .../src/main/resources/archetype-resources/pom.xml | 4 +- docker-compose.yml | 50 +- installer/cli/.env | 3 +- installer/cli/README.md | 2 +- installer/cli/bin/commands/up | 3 +- .../app-container/docker-compose.dev.yml | 1 - .../standalone/app-container/docker-compose.yml | 1 - .../standalone/backend/docker-compose.dev.yml | 1 - .../deploy/standalone/backend/docker-compose.yml | 3 - .../standalone/chronograf/docker-compose.dev.yml | 1 - .../standalone/chronograf/docker-compose.yml | 1 - .../connect-adapters-iiot/docker-compose.dev.yml | 1 - .../connect-adapters-iiot/docker-compose.yml | 1 - .../connect-adapters/docker-compose.dev.yml | 1 - .../standalone/connect-adapters/docker-compose.yml | 1 - .../standalone/couchdb/docker-compose.dev.yml | 1 - .../deploy/standalone/couchdb/docker-compose.yml | 1 - .../deploy/standalone/crate/docker-compose.dev.yml | 1 - .../cli/deploy/standalone/crate/docker-compose.yml | 1 - .../elasticsearch/docker-compose.dev.yml | 1 - .../standalone/elasticsearch/docker-compose.yml | 1 - .../deploy/standalone/epsg/docker-compose.dev.yml | 1 - .../cli/deploy/standalone/epsg/docker-compose.yml | 1 - .../extensions-all-jvm/docker-compose.dev.yml | 1 - .../extensions-all-jvm/docker-compose.yml | 6 - .../standalone/filebeat/docker-compose.dev.yml | 1 - .../deploy/standalone/filebeat/docker-compose.yml | 1 - .../standalone/grafana/docker-compose.dev.yml | 1 - .../deploy/standalone/grafana/docker-compose.yml | 1 - .../standalone/influxdb/docker-compose.dev.yml | 1 - .../deploy/standalone/influxdb/docker-compose.yml | 1 - .../deploy/standalone/iotdb/docker-compose.dev.yml | 1 - .../cli/deploy/standalone/iotdb/docker-compose.yml | 1 - .../standalone/jobmanager/docker-compose.dev.yml | 1 - .../standalone/jobmanager/docker-compose.yml | 1 - .../deploy/standalone/kafka/docker-compose.dev.yml | 29 +- .../cli/deploy/standalone/kafka/docker-compose.yml | 35 +- .../standalone/kibana/docker-compose.dev.yml | 1 - .../deploy/standalone/kibana/docker-compose.yml | 1 - .../standalone/logstash/docker-compose.dev.yml | 1 - .../deploy/standalone/logstash/docker-compose.yml | 1 - .../standalone/mariadb/docker-compose.dev.yml | 1 - .../deploy/standalone/mariadb/docker-compose.yml | 1 - .../standalone/mosquitto/docker-compose.dev.yml | 1 - .../deploy/standalone/mosquitto/docker-compose.yml | 1 - .../deploy/standalone/mysql/docker-compose.dev.yml | 1 - .../cli/deploy/standalone/mysql/docker-compose.yml | 1 - .../deploy/standalone/nats/docker-compose.dev.yml | 1 - .../cli/deploy/standalone/nats/docker-compose.yml | 1 - .../deploy/standalone/opcua/docker-compose.dev.yml | 1 - .../cli/deploy/standalone/opcua/docker-compose.yml | 3 +- .../standalone/pgadmin/docker-compose.dev.yml | 1 - .../deploy/standalone/pgadmin/docker-compose.yml | 1 - .../standalone/pgrouting/docker-compose.dev.yml | 1 - .../deploy/standalone/pgrouting/docker-compose.yml | 1 - .../standalone/phpmyadmin/docker-compose.dev.yml | 1 - .../standalone/phpmyadmin/docker-compose.yml | 1 - .../docker-compose.dev.yml | 1 - .../pipeline-elements-all-flink/docker-compose.yml | 1 - .../docker-compose.dev.yml | 1 - .../pipeline-elements-all-jvm/docker-compose.yml | 6 - .../standalone/postgis/docker-compose.dev.yml | 1 - .../deploy/standalone/postgis/docker-compose.yml | 1 - .../standalone/postgres/docker-compose.dev.yml | 1 - .../deploy/standalone/postgres/docker-compose.yml | 1 - .../prometheus-alertmanager/docker-compose.dev.yml | 1 - .../prometheus-alertmanager/docker-compose.yml | 1 - .../standalone/prometheus/docker-compose.dev.yml | 1 - .../standalone/prometheus/docker-compose.yml | 1 - .../standalone/pulsar/docker-compose.dev.yml | 1 - .../deploy/standalone/pulsar/docker-compose.yml | 1 - .../standalone/rabbitmq/docker-compose.dev.yml | 1 - .../deploy/standalone/rabbitmq/docker-compose.yml | 1 - .../deploy/standalone/rdf4j/docker-compose.dev.yml | 1 - .../cli/deploy/standalone/rdf4j/docker-compose.yml | 1 - .../deploy/standalone/redis/docker-compose.dev.yml | 1 - .../cli/deploy/standalone/redis/docker-compose.yml | 1 - .../standalone/rocketmq/docker-compose.dev.yml | 1 - .../deploy/standalone/rocketmq/docker-compose.yml | 2 - .../sinks-internal-jvm/docker-compose.dev.yml | 1 - .../sinks-internal-jvm/docker-compose.yml | 6 - .../standalone/swagger-ui/docker-compose.dev.yml | 20 - .../standalone/swagger-ui/docker-compose.yml | 32 - .../standalone/taskmanager/docker-compose.dev.yml | 1 - .../standalone/taskmanager/docker-compose.yml | 1 - .../docker-compose.dev.yml | 1 - .../docker-compose.yml | 1 - .../standalone/timescaledb/docker-compose.dev.yml | 1 - .../standalone/timescaledb/docker-compose.yml | 1 - .../standalone/tubemq/docker-compose.dev.yml | 1 - .../deploy/standalone/tubemq/docker-compose.yml | 1 - .../ui-custom-conf/docker-compose.dev.yml | 1 - .../standalone/ui-custom-conf/docker-compose.yml | 1 - .../deploy/standalone/ui/docker-compose.dev.yml | 1 - .../cli/deploy/standalone/ui/docker-compose.yml | 1 - .../standalone/zookeeper/docker-compose.dev.yml | 20 - .../deploy/standalone/zookeeper/docker-compose.yml | 35 - installer/cli/environments/adapter | 1 - installer/cli/environments/backend | 1 - installer/cli/environments/basic | 1 - installer/cli/environments/full | 1 - installer/cli/environments/full-monitoring | 1 - installer/cli/environments/lite | 1 - installer/cli/environments/lite-monitoring | 1 - installer/cli/environments/pipeline-element | 1 - installer/cli/environments/ui | 1 - installer/compose/.env | 3 +- installer/compose/README.md | 50 +- installer/compose/docker-compose.full.yml | 174 - ...r-compose.nats.yml => docker-compose.kafka.yml} | 51 +- installer/compose/docker-compose.minimal.yml | 5 - installer/compose/docker-compose.pulsar.yml | 113 - installer/compose/docker-compose.quickstart.yml | 158 - installer/compose/docker-compose.yml | 60 +- installer/compose/quickstart/upload.sh | 101 - ...set - Smart Factory Monitoring and Analysis.zip | Bin 78596 -> 0 bytes installer/k8s/Chart.yaml | 4 +- installer/k8s/README.md | 20 +- .../k8s/templates/core/backend-deployment.yaml | 4 - .../templates/external/kafka/kafka-deployment.yaml | 44 +- .../external/zookeeper/zookeeper-deployment.yaml | 74 - .../external/zookeeper/zookeeper-pvc.yaml | 44 - .../external/zookeeper/zookeeper-service.yaml | 29 - installer/k8s/values.yaml | 14 +- installer/upgrade_versions.sh | 6 +- package-lock.json | 6 + pom.xml | 336 +- streampipes-client-api/pom.xml | 8 +- .../apache/streampipes/client/api/IAdapterApi.java | 54 + .../streampipes/client/api/ICustomRequestApi.java | 3 + .../streampipes/client/api/IStreamPipesClient.java | 6 +- streampipes-client-e2e/docker-compose.yml | 43 +- ...ine-learning-on-a-streampipes-data-stream.ipynb | 49 +- streampipes-client-python/poetry.lock | 3969 ++-- streampipes-client-python/pyproject.toml | 27 +- .../streampipes/client/client.py | 9 +- .../streampipes/client/credential_provider.py | 36 + .../streampipes/endpoint/api/data_lake_measure.py | 64 +- .../streampipes/endpoint/api/version.py | 2 +- .../streampipes/function_zoo/river_function.py | 9 +- .../functions/utils/data_stream_generator.py | 10 +- .../streampipes/model/resource/query_result.py | 49 + .../tests/client/test_credential_provider.py | 52 +- streampipes-client/pom.xml | 19 +- .../streampipes/client/StreamPipesClient.java | 19 +- .../streampipes/client/api/AbstractClientApi.java | 7 + .../apache/streampipes/client/api/AdapterApi.java | 88 + .../streampipes/client/api/CustomRequestApi.java | 8 + streampipes-commons/pom.xml | 4 +- .../apache/streampipes/commons/constants/Envs.java | 25 +- .../commons/environment/DefaultEnvironment.java | 49 + .../commons/environment/Environment.java | 14 + .../environment/model/OAuthConfiguration.java | 21 +- .../parser/OAuthConfigurationParser.java | 22 +- .../prometheus/StreamPipesCollectorRegistry.java | 14 + .../prometheus/service/ElementServiceMetrics.java | 72 + .../prometheus/service/ElementServiceStats.java | 134 + streampipes-connect-management/pom.xml | 12 +- .../management/health/AdapterHealthCheck.java | 19 +- .../management/AdapterMasterManagement.java | 56 +- .../management/AdapterUpdateManagement.java | 2 +- .../management/management/GuessManagement.java | 2 +- .../management/management/WorkerRestClient.java | 4 +- streampipes-connect-shared/pom.xml | 10 +- .../convert/ToOriginalSchemaConverter.java | 6 - .../convert/ToTransformedSchemaConverter.java | 14 +- ...StatefulTransformationRuleGeneratorVisitor.java | 6 - ...tatelessTransformationRuleGeneratorVisitor.java | 8 - .../schema/CreateNestedTransformationRule.java | 49 - .../stream/EventRateTransformationRule.java | 5 - .../schema/CreateNestedTransformationRuleTest.java | 71 - .../schema/SchemaEventTransformerTest.java | 7 +- streampipes-data-explorer-api/pom.xml | 8 +- .../api/IDataExplorerSchemaManagement.java | 3 + streampipes-data-explorer-export/pom.xml | 84 +- .../export/ConfiguredCsvOutputWriter.java | 13 +- .../export/ConfiguredExcelOutputWriter.java | 124 + .../export/ConfiguredJsonOutputWriter.java | 6 +- .../export/ConfiguredOutputWriter.java | 40 +- .../export/{OutputFormat.java => ExportUtils.java} | 21 +- .../export/ObjectStorge/ExportProviderFactory.java | 47 +- .../export/ObjectStorge/IObjectStorage.java | 21 +- .../export/ObjectStorge/LocalFolder.java | 53 + .../dataexplorer/export/ObjectStorge/S3.java | 86 + .../dataexplorer/export/OutputFormat.java | 14 +- .../dataexplorer/export/item/CsvItemGenerator.java | 4 +- .../export/TestConfiguredCsvOutputWriter.java | 2 +- .../export/TestConfiguredJsonOutputWriter.java | 2 +- streampipes-data-explorer-influx/pom.xml | 22 +- .../influx/DataExplorerInfluxQueryExecutor.java | 2 +- streampipes-data-explorer-iotdb/pom.xml | 16 +- .../iotdb/DataLakeMeasurementCounterIotDb.java | 2 +- streampipes-data-explorer-management/pom.xml | 10 +- streampipes-data-explorer/pom.xml | 10 +- .../dataexplorer/DataExplorerSchemaManagement.java | 58 +- .../dataexplorer/StreamedQueryResultProvider.java | 5 +- .../param/model/WhereClauseParams.java | 50 +- streampipes-data-export/pom.xml | 15 +- .../streampipes/export/AssetLinkResolver.java | 10 +- .../export/constants/ResolvableAssetLinks.java | 2 +- .../export/dataimport/ImportGenerator.java | 44 +- .../export/dataimport/PerformImportGenerator.java | 96 +- .../export/dataimport/PreviewImportGenerator.java | 33 +- .../export/generator/ExportPackageGenerator.java | 68 +- .../export/resolver/AbstractResolver.java | 21 +- .../export/resolver/AdapterResolver.java | 44 +- ...aViewWidgetResolver.java => ChartResolver.java} | 21 +- .../export/resolver/DashboardResolver.java | 19 +- .../export/resolver/DashboardWidgetResolver.java | 59 - .../export/resolver/DataSourceResolver.java | 18 +- .../export/resolver/DataViewResolver.java | 75 - .../export/resolver/DocumentResolver.java | 40 +- .../streampipes/export/resolver/FileResolver.java | 12 +- .../resolver/GenericStorageDocumentResolver.java | 100 + .../export/resolver/MeasurementResolver.java | 12 +- .../export/resolver/PipelineResolver.java | 33 +- .../export/utils/ImportAdapterMigrationUtils.java | 55 - streampipes-dataformat/pom.xml | 4 +- streampipes-extensions-api/pom.xml | 8 +- .../api/extractor/IParameterExtractor.java | 8 - streampipes-extensions-management/pom.xml | 28 +- .../connect/AdapterWorkerManagement.java | 2 +- .../management/connect/GuessManagement.java | 4 +- .../management/connect/PullAdapterScheduler.java | 50 +- .../connect/TransformationRuleUpdateVisitor.java | 6 - .../connect/adapter/model/EventCollector.java | 18 +- .../model/SpServiceDefinitionBuilder.java | 18 - .../management/monitoring/ExtensionsLogger.java | 10 + .../monitoring/ServiceLoadDataReportGenerator.java | 330 + .../adapter/parser/json/GeoJsonParserTest.java | 4 +- streampipes-extensions/docker-compose.yml | 80 - streampipes-extensions/pom.xml | 5 +- .../streampipes-connect-adapters-iiot/pom.xml | 10 +- .../iiot/adapters/iolink/IfmAlMqttAdapter.java | 1 + .../connect/iiot/adapters/oi4/Oi4Adapter.java | 6 + .../machine/MachineDataSimulatorUtils.java | 22 +- .../connect/iiot/utils/FileProtocolUtils.java | 8 +- .../streampipes-connect-adapters/pom.xml | 10 +- .../connect/adapters/netio/NetioMQTTAdapter.java | 1 + .../connect/adapters/netio/NetioRestAdapter.java | 1 + .../connect/adapters/netio/NetioUtils.java | 1 + .../streampipes-connectors-influx/pom.xml | 8 +- .../connectors/influx/adapter/InfluxDbClient.java | 4 +- .../streampipes-connectors-kafka/pom.xml | 14 +- .../connectors/kafka/adapter/KafkaProtocol.java | 69 +- .../documentation.md | 52 +- .../documentation.md | 74 +- .../streampipes-connectors-mqtt/pom.xml | 8 +- .../documentation.md | 57 +- .../documentation.md | 81 +- .../streampipes-connectors-nats/pom.xml | 10 +- .../streampipes-connectors-opcua/pom.xml | 14 +- .../opcua/OpcUaConnectorsModuleExport.java | 8 +- .../connectors/opcua/adapter/OpcUaAdapter.java | 66 +- .../connectors/opcua/adapter/OpcUaNodeBrowser.java | 56 +- .../opcua/adapter/OpcUaNodeProvider.java | 35 +- .../opcua/adapter/OpcUaSchemaProvider.java | 131 + .../opcua/client/ConnectedOpcUaClient.java | 8 +- .../connectors/opcua/client/SpOpcUaClient.java | 25 +- .../opcua/config/OpcUaAdapterConfig.java | 11 + .../opcua/config/SharedUserConfiguration.java | 25 +- .../opcua/config/SpOpcUaConfigExtractor.java | 51 +- .../opcua/config/identity/X509IdentityConfig.java | 114 + .../security/CompositeCertificateValidator.java | 158 + .../opcua/config/security/SecurityConfig.java | 51 +- .../opcua/migration/OpcUaAdapterMigrationV5.java | 49 + .../opcua/migration/OpcUaAdapterMigrationV6.java | 75 + .../opcua/migration/OpcUaSinkMigrationV2.java | 48 + .../extensions/connectors/opcua/model/OpcNode.java | 129 - .../connectors/opcua/model/OpcUaNodeFactory.java | 39 + .../opcua/model/node/BasicVariableNodeInfo.java | 58 + .../opcua/model/node/ExtensionObjectOpcUaNode.java | 119 + .../connectors/opcua/model/node/OpcUaNode.java | 48 + .../opcua/model/node/PrimitiveOpcUaNode.java | 108 + .../model/nodename/NamingStrategyResolver.java | 16 +- .../opcua/model/nodename/ParsedNodeIdResolver.java | 22 +- .../opcua/model/nodename/SimpleNameResolver.java | 20 +- .../connectors/opcua/sink/OpcUaSink.java | 8 +- .../connectors/opcua/utils/OpcUaLabels.java | 1 + .../opcua/utils/OpcUaNamingStrategy.java | 53 + .../connectors/opcua/utils/OpcUaTypes.java | 33 + .../utils/{OpcUaUtil.java => OpcUaUtils.java} | 188 +- .../strings.en | 12 + .../strings.en | 9 + .../connectors/opcua/utils/OpcUaUtilTest.java | 6 +- .../streampipes-connectors-plc/pom.xml | 14 +- .../connectors/plc/PlcConnectorsModuleExport.java | 9 +- .../plc/adapter/GenericAdapterGenerator.java | 3 +- .../connection/ContinuousPlcRequestReader.java | 90 +- .../generic/connection/PlcEventGenerator.java | 7 +- .../generic/model/Plc4xConnectionExtractor.java | 11 +- .../connectors/plc/adapter/s7/Plc4xS7Adapter.java | 2 +- .../plc/adapter/s7/config/ConfigurationParser.java | 24 +- .../plc/cache/SpCachedPlcConnectionManager.java | 178 + .../plc/cache/SpConnectionContainer.java | 235 + .../plc/cache/SpLeasedPlcConnection.java | 575 + .../plc/adapter/ConnectionContainerReproTest.java | 167 + .../adapter/s7/config/ConfigurationParserTest.java | 47 +- .../streampipes-connectors-pulsar/pom.xml | 8 +- .../streampipes-connectors-rocketmq/pom.xml | 8 +- .../streampipes-connectors-ros/pom.xml | 10 +- .../streampipes-connectors-tubemq/pom.xml | 8 +- .../streampipes-extensions-all-iiot/pom.xml | 53 +- .../extensions/all/iiot/AllExtensionsIIoTInit.java | 5 +- .../streampipes-extensions-all-jvm/pom.xml | 67 +- .../extensions/all/jvm/AllExtensionsInit.java | 4 +- .../streampipes-extensions-iiot-minimal/pom.xml | 40 +- .../pom.xml | 6 +- .../streampipes-pipeline-elements-shared/pom.xml | 4 +- .../pom.xml | 6 +- .../jvm/welford/WelfordChangeDetection.java | 72 +- .../streampipes-processors-enricher-jvm/pom.xml | 10 +- .../jvm/processor/jseval/JSEvalProcessor.java | 55 +- .../QualityControlLimitsEnrichmentProcessor.java | 91 +- .../jvm/processor/math/MathOpProcessor.java | 115 +- .../math/staticmathop/StaticMathOpProcessor.java | 75 +- .../sizemeasure/SizeMeasureProcessor.java | 75 +- .../trigonometry/TrigonometryProcessor.java | 76 +- .../valuechange/ValueChangeProcessor.java | 77 +- .../documentation.de.md | 137 + .../documentation.md | 100 +- .../strings.de} | 9 +- .../documentation.de.md | 114 + .../documentation.md | 85 +- .../strings.de} | 15 +- .../documentation.de.md | 107 + .../strings.de | 40 + .../documentation.de.md | 98 + .../strings.de | 32 + .../documentation.de.md | 113 + .../documentation.md | 85 +- .../strings.de} | 15 +- .../documentation.de.md | 117 + .../documentation.md | 83 +- .../strings.de} | 13 +- .../documentation.de.md | 104 + .../documentation.md | 76 +- .../strings.de} | 12 +- .../documentation.de.md | 104 + .../documentation.md | 73 +- .../strings.de} | 9 +- .../documentation.de.md | 120 + .../documentation.md | 83 +- .../strings.de} | 17 +- .../streampipes-processors-filters-jvm/pom.xml | 8 +- .../booleanfilter/BooleanFilterProcessor.java | 50 +- .../jvm/processor/compose/ComposeProcessor.java | 52 +- .../processor/enrich/MergeByEnrichProcessor.java | 76 +- .../jvm/processor/limit/RateLimitProcessor.java | 80 +- .../jvm/processor/merge/MergeByTimeProcessor.java | 64 +- .../movingaverage/MovingAverageProcessor.java | 62 +- .../NumericalTextFilterProcessor.java | 125 +- .../processor/projection/ProjectionProcessor.java | 45 +- .../processor/schema/MergeBySchemaProcessor.java | 66 +- .../sdt/SwingingDoorTrendingFilterProcessor.java | 53 +- .../processor/textfilter/TextFilterProcessor.java | 58 +- .../threshold/ThresholdDetectionProcessor.java | 81 +- .../throughputmon/ThroughputMonitorProcessor.java | 82 +- .../documentation.de.md | 117 + .../documentation.md | 85 +- .../strings.de | 9 +- .../documentation.de.md | 118 + .../documentation.md | 91 +- .../strings.de} | 9 +- .../documentation.de.md | 139 + .../documentation.md | 119 +- .../strings.de | 50 + .../documentation.de.md | 116 + .../documentation.md | 89 +- .../strings.de} | 15 +- .../documentation.de.md | 123 + .../documentation.md | 99 +- .../strings.de} | 15 +- .../documentation.de.md | 151 + .../documentation.md | 119 +- .../strings.de} | 15 +- .../documentation.de.md | 120 + .../documentation.md | 107 +- .../strings.de | 38 + .../documentation.de.md | 114 + .../documentation.md | 78 +- .../strings.de} | 12 +- .../documentation.de.md | 102 + .../documentation.md | 72 +- .../strings.de | 10 +- .../documentation.de.md | 116 + .../documentation.md | 96 +- .../strings.de | 12 +- .../documentation.de.md | 79 + .../strings.de | 34 + .../documentation.de.md | 106 + .../documentation.md | 73 +- .../strings.de} | 15 +- .../documentation.de.md | 113 + .../documentation.md | 81 +- .../strings.de} | 14 +- .../documentation.de.md | 118 + .../documentation.md | 90 +- .../strings.de} | 26 +- .../projection/TestProjectionProcessor.java | 66 + .../threshold/TestThresholdDetectionProcessor.java | 150 + .../streampipes-processors-filters-siddhi/pom.xml | 8 +- .../documentation.de.md | 111 + .../documentation.md | 89 +- .../strings.de} | 18 +- .../documentation.de.md | 99 + .../documentation.md | 80 +- .../strings.de} | 12 +- .../documentation.de.md | 106 + .../documentation.md | 88 +- .../strings.de} | 15 +- .../documentation.de.md | 119 + .../documentation.md | 96 +- .../strings.de | 32 + .../documentation.de.md | 102 + .../documentation.md | 75 +- .../strings.de} | 12 +- .../documentation.de.md | 96 + .../documentation.md | 67 +- .../strings.de} | 12 +- .../documentation.de.md | 83 + .../strings.de} | 15 +- .../documentation.de.md} | 9 +- .../documentation.md | 2 +- .../strings.de} | 9 +- .../documentation.de.md | 98 + .../documentation.md | 70 +- .../strings.de} | 12 +- .../documentation.de.md | 141 + .../documentation.md | 112 +- .../strings.de} | 21 +- .../streampipes-processors-geo-jvm/pom.xml | 6 +- .../buffergeometry/BufferGeomProcessor.java | 195 +- .../bufferpoint/BufferPointProcessor.java | 145 +- .../geo/jvm/jts/processor/epsg/EpsgProcessor.java | 56 +- .../LatLngToJtsPointProcessor.java | 101 +- .../reprojection/ReprojectionProcessor.java | 90 +- .../trajectory/TrajectoryFromPointsProcessor.java | 148 +- .../complex/TopologyValidationProcessor.java | 116 +- .../simple/GeometryValidationProcessor.java | 115 +- .../HaversineDistanceCalculatorProcessor.java | 114 +- ...HaversineStaticDistanceCalculatorProcessor.java | 103 +- .../googlemaps/GoogleMapsGeocoderProcessor.java | 77 +- .../GoogleMapsStaticGeocoderProcessor.java | 77 +- .../geocityname/GeoCityNameRevdecodeProcessor.java | 86 +- .../speedcalculator/SpeedCalculatorProcessor.java | 102 +- .../documentation.de.md | 55 + .../strings.de} | 17 +- .../documentation.de.md} | 40 +- .../strings.de} | 17 +- .../documentation.de.md} | 41 +- .../strings.de} | 11 +- .../documentation.de.md} | 24 +- .../strings.de | 32 + .../pom.xml | 6 +- .../jvm/processor/commons/RequiredBoxStream.java | 6 +- .../GenericImageClassificationProcessor.java | 62 +- .../imagecropper/ImageCropperProcessor.java | 45 +- .../imageenrichment/ImageEnrichmentProcessor.java | 45 +- .../processor/qrreader/QrCodeReaderProcessor.java | 53 +- .../pom.xml | 53 +- .../llm/jvm/LlmExtensionModuleExport.java} | 24 +- .../multimodel/MultiModelPromptProcessor.java | 263 + .../processor/multimodel/context/ChatContext.java | 63 + .../multimodel/context/FullHistoryChatContext.java | 62 + .../multimodel/context/StatelessChatContext.java | 51 + .../multimodel/context/WindowedChatContext.java | 70 + .../documentation.md | 106 + .../icon.png | Bin 0 -> 21478 bytes .../strings.en | 61 + .../multimodel/TestMultiModelPromptProcessor.java | 81 + .../streampipes-processors-text-mining-jvm/pom.xml | 6 +- .../jvm/processor/chunker/ChunkerProcessor.java | 117 +- .../language/LanguageDetectionProcessor.java | 91 +- .../processor/namefinder/NameFinderProcessor.java | 83 +- .../partofspeech/PartOfSpeechProcessor.java | 90 +- .../SentenceDetectionProcessor.java | 70 +- .../processor/tokenizer/TokenizerProcessor.java | 77 +- .../pom.xml | 11 +- .../jvm/TransformationExtensionModuleExport.java | 11 +- ...aticMetadataEnrichmentProcessorMigrationV2.java | 85 + .../processor/array/count/CountArrayProcessor.java | 54 +- .../processor/array/split/SplitArrayProcessor.java | 109 +- .../edge/SignalEdgeFilterProcessor.java | 63 +- .../inverter/BooleanInverterProcessor.java | 57 +- .../logical/BooleanOperatorProcessor.java | 78 +- .../state/BooleanToStateProcessor.java | 62 +- .../timekeeping/BooleanTimekeepingProcessor.java | 88 +- .../booloperator/timer/BooleanTimerProcessor.java | 72 +- .../CsvMetadataEnrichmentProcessor.java | 136 +- .../datetime/DateTimeFromStringProcessor.java | 78 +- .../fieldrename/FiledRenameProcessor.java | 67 +- .../jvm/processor/hasher/FieldHasherProcessor.java | 71 +- .../jvm/processor/mapper/FieldMapperProcessor.java | 92 +- .../MeasurementUnitConverterProcessor.java | 62 +- .../jvm/processor/round/RoundProcessor.java | 55 +- .../jvm/processor/state/StateUtils.java | 12 +- .../state/buffer/StateBufferProcessor.java | 88 +- .../jvm/processor/state/labeler/LabelerUtils.java | 2 +- .../buffer/StateBufferLabelerProcessor.java | 102 +- .../labeler/number/NumberLabelerProcessor.java | 84 +- .../StaticMetaDataConfiguration.java | 4 +- .../StaticMetaDataEnrichmentProcessor.java | 105 +- .../counter/StringCounterProcessor.java | 83 +- .../state/StringToStateProcessor.java | 58 +- .../stringoperator/timer/StringTimerProcessor.java | 81 +- .../AbstractSwitchOperatorProcessor.java | 149 + .../IStreamPipesSwitchProcessor.java} | 16 +- .../processor/switchoperator/LogicalOperator.java | 103 + .../NumericalSwitchCaseEntry.java} | 20 +- .../jvm/processor/switchoperator/README.md | 119 + .../SwitchCaseEntry.java} | 25 +- .../SwitchOperatorBooleanInputProcessor.java | 123 + .../SwitchOperatorNumericalInputProcessor.java | 139 + .../SwitchOperatorStringInputProcessor.java | 120 + .../jvm/processor/task/TaskDurationProcessor.java | 65 +- .../TimestampExtractorProcessor.java | 104 +- .../TransformToBooleanProcessor.java | 84 +- .../change/ChangedValueDetectionProcessor.java | 59 +- .../value/duration/CalculateDurationProcessor.java | 64 +- .../documentation.md | 155 +- .../documentation.de.md | 129 + .../documentation.md | 96 +- .../strings.de} | 8 +- .../documentation.md | 155 +- .../documentation.md | 121 +- .../documentation.de.md | 156 + .../documentation.md | 126 +- .../strings.de} | 11 +- .../documentation.md | 91 +- .../documentation.md | 68 +- .../documentation.md | 129 +- .../documentation.de.md | 112 + .../documentation.md | 98 +- .../strings.de} | 11 +- .../documentation.de.md | 121 + .../documentation.md | 88 +- .../strings.de} | 14 +- .../documentation.de.md | 118 + .../documentation.md | 94 +- .../strings.de} | 11 +- .../documentation.de.md | 97 + .../documentation.md | 62 +- .../strings.de} | 11 +- .../documentation.de.md | 112 + .../documentation.md | 87 +- .../strings.de} | 11 +- .../documentation.de.md | 139 + .../documentation.md | 102 +- .../strings.de} | 11 +- .../documentation.de.md | 180 + .../documentation.md | 152 +- .../strings.de} | 17 +- .../documentation.de.md | 158 + .../documentation.md | 131 +- .../strings.de | 35 + .../documentation.de.md | 119 + .../documentation.md | 85 +- .../strings.de} | 22 +- .../documentation.de.md | 139 + .../documentation.md | 110 +- .../strings.de | 49 + .../documentation.de.md | 120 + .../documentation.md | 88 +- .../strings.de | 49 + .../documentation.de.md | 137 + .../documentation.md | 123 +- .../strings.de | 37 + .../strings.en | 5 + .../documentation.de.md | 106 + .../documentation.md | 75 +- .../strings.de} | 14 +- .../documentation.de.md | 152 + .../documentation.md | 112 +- .../strings.de} | 11 +- .../documentation.de.md | 139 + .../documentation.md | 107 +- .../strings.de} | 14 +- .../documentation.de.md | 142 + .../documentation.md | 108 +- .../strings.de} | 11 +- .../documentation.de.md | 131 + .../documentation.md | 107 +- .../strings.de} | 17 +- .../documentation.de.md | 122 + .../documentation.md | 93 +- .../strings.de} | 20 +- .../documentation.md | 78 + .../icon.png | Bin 0 -> 214427 bytes .../strings.en | 40 + .../documentation.md | 84 + .../icon.png | Bin 0 -> 214427 bytes .../strings.en | 43 + .../documentation.md | 78 + .../icon.png | Bin 0 -> 214427 bytes .../strings.en | 40 + .../documentation.de.md | 140 + .../documentation.md | 110 +- .../strings.de} | 21 +- .../documentation.de.md | 108 + .../documentation.md | 71 +- .../strings.de} | 8 +- .../StaticMetaDataEnrichmentProcessorTest.java | 5 +- .../TestSwitchOperatorBooleanInputProcessor.java | 330 + .../TestSwitchOperatorNumericalInputProcessor.java | 333 + .../TestSwitchOperatorStringInputProcessor.java | 295 + .../change/TestChangedValueDetectionProcessor.java | 89 +- .../streampipes-sinks-brokers-jvm/pom.xml | 10 +- .../jvm/BrokerSinksExtensionModuleExport.java | 5 +- .../jvm/migrations/RestSinkMigrationV1.java | 149 + .../brokers/jvm/rest/RestHeaderConfiguration.java | 13 +- .../sinks/brokers/jvm/rest/RestSink.java | 184 +- .../strings.en | 18 + .../streampipes-sinks-databases-jvm/pom.xml | 56 +- .../jvm/DatabaseSinksExtensionModuleExport.java | 11 +- .../sinks/databases/jvm/milvus/MilvusSink.java | 394 + .../sinks/databases/jvm/parquet/ParquetSink.java | 314 + .../sinks/databases/jvm/qdrant/QdrantSink.java | 331 + .../databases/jvm/qdrant/QdrantValueFactory.java | 112 + .../sinks/databases/jvm/tsfile/TsFileSink.java | 348 + .../documentation.md | 39 +- .../icon.png | Bin 0 -> 9319 bytes .../strings.en | 52 + .../documentation.md | 29 +- .../icon.png | Bin 0 -> 11416 bytes .../strings.en | 40 + .../documentation.md | 88 + .../icon.png | Bin 0 -> 3443 bytes .../strings.en | 43 + .../documentation.md | 29 +- .../icon.png | Bin 0 -> 10760 bytes .../strings.en | 40 + .../streampipes-sinks-internal-jvm/pom.xml | 12 +- .../sinks/internal/jvm/datalake/DataLakeSink.java | 130 +- .../streampipes-sinks-notifications-jvm/pom.xml | 8 +- streampipes-integration-tests/pom.xml | 26 +- .../integration/adapters/KafkaAdapterTester.java | 8 +- .../integration/containers/KafkaDevContainer.java | 2 +- .../integration/containers/PulsarContainer.java | 2 +- ...fkaContainer.java => SpKafkaTestContainer.java} | 29 +- streampipes-mail/pom.xml | 4 +- streampipes-maven-plugin/pom.xml | 8 +- .../src/main/resources/docker-compose.yml | 1 - .../smp/generator/TestMarkdownTitleRemover.java | 3 +- streampipes-measurement-units/pom.xml | 4 +- .../org/apache/streampipes/units/UnitProvider.java | 6 + streampipes-messaging-jms/pom.xml | 4 +- streampipes-messaging-kafka/pom.xml | 6 +- .../messaging/kafka/SpKafkaConsumer.java | 111 +- .../kafka/config/ConsumerConfigFactory.java | 1 + streampipes-messaging-mqtt/pom.xml | 4 +- streampipes-messaging-nats/pom.xml | 4 +- streampipes-messaging-pulsar/pom.xml | 4 +- streampipes-messaging/pom.xml | 4 +- streampipes-model-client/pom.xml | 6 +- .../streampipes/model/client/user/Group.java | 9 + .../streampipes/model/client/user/Permission.java | 9 + .../apache/streampipes/model/client/user/Role.java | 12 + .../streampipes/model/client/user/UserAccount.java | 47 + streampipes-model-shared/pom.xml | 2 +- streampipes-model/pom.xml | 8 +- .../apache/streampipes/model/ResourceMetadata.java | 24 +- .../org/apache/streampipes/model/UserInfo.java | 18 + .../apache/streampipes/model/api/SpResource.java | 15 +- .../configuration/DefaultExportProviderConfig.java | 19 +- .../configuration/DefaultMessagingSettings.java | 2 - .../configuration/DefaultSpCoreConfiguration.java | 5 +- .../configuration/ExportProviderSettings.java | 115 + .../model/configuration/GeneralConfig.java | 9 + .../model/configuration/MessagingSettings.java | 19 - .../model/configuration/ProviderType.java | 8 +- .../model/configuration/SpCoreConfiguration.java | 12 + .../model/configuration/UserAcknowledgment.java | 7 +- .../connect/rules/ITransformationRuleVisitor.java | 3 - .../rules/TransformationRuleDescription.java | 2 - .../rules/schema/CreateNestedRuleDescription.java | 64 - .../model/dashboard/CompositeDashboardModel.java | 25 +- .../model/dashboard/DashboardEntity.java | 12 +- .../model/dashboard/DashboardModel.java | 16 +- .../model/dashboard/DashboardWidgetModel.java | 78 - .../model/dashboard/DashboardWidgetSettings.java | 93 - .../model/dashboard/VisualizablePipeline.java | 76 - .../model/datalake/AggregationFunction.java | 5 +- .../model/datalake/DataExplorerWidgetModel.java | 22 +- .../model/datalake/DataLakeMeasure.java | 26 +- .../model/datalake/DataRetentionConfig.java | 11 +- .../streampipes/model/datalake/ExportConfig.java | 16 +- .../model/datalake/RetentionAction.java | 10 +- .../model/datalake/RetentionExportConfig.java | 29 +- .../model/datalake/RetentionInterval.java | 11 +- .../model/datalake/RetentionTimeConfig.java | 52 + .../datalake/param/SupportedRestQueryParams.java | 10 +- .../model/export/AssetExportConfiguration.java | 23 + .../export/StreamPipesApplicationPackage.java | 14 + .../model/grounding/KafkaTransportProtocol.java | 40 - .../model/loadbalancer/LoadBalancerConstants.java | 48 +- .../model/loadbalancer/ServiceLoadDataReport.java | 188 + .../streampipes/model/loadbalancer/Usage.java | 201 + .../streampipes/model/opcua/Certificate.java | 217 + .../model/opcua/CertificateBuilder.java | 247 + .../streampipes/model/opcua/CertificateState.java | 7 +- .../connect/adapter/AdapterDescriptionTest.java | 19 +- streampipes-pipeline-management/pom.xml | 26 +- .../manager/matching/ProtocolSelector.java | 4 +- .../CustomTransformOutputSchemaGenerator.java | 3 +- .../monitoring/pipeline/ExtensionsLogProvider.java | 3 + .../manager/pipeline/PipelineManager.java | 29 +- .../manager/preview/PipelinePreview.java | 71 +- .../manager/runtime/ClientDisconnectCallback.java | 12 +- .../runtime/RateLimitedRuntimeInfoProvider.java | 7 +- .../manager/setup/CouchDbInstallationStep.java | 7 +- .../manager/setup/StreamPipesEnvChecker.java | 31 +- .../setup/tasks/AddDataLakeMeasureViewTask.java | 49 + .../tasks/ApplyDefaultRolesAndPrivilegesTask.java | 16 +- .../setup/tasks/CreateAssetLinkTypeTask.java | 12 +- .../template/PipelineElementTemplateVisitor.java | 115 +- .../manager/matching/v2/ListPropertyMatchTest.java | 2 +- .../matching/v2/TestPrimitivePropertyMatch.java | 2 +- .../manager/matching/v2/TestSchemaMatch.java | 4 +- .../streampipes/manager/matching/v2/TestUtils.java | 2 +- .../manager/selector/TestSelectorUtils.java | 4 +- streampipes-platform-services/pom.xml | 81 - streampipes-resource-management/pom.xml | 8 +- .../management/DashboardResourceManager.java | 28 - .../management/DataExplorerResourceManager.java | 31 + .../DataExplorerWidgetResourceManager.java | 2 +- .../management/PermissionResourceManager.java | 8 + .../resource/management/SpResourceManager.java | 4 - .../resource/management/UserResourceManager.java | 8 +- streampipes-rest-core-base/pom.xml | 10 +- streampipes-rest-extensions/pom.xml | 13 +- .../connect/RuntimeResolvableResource.java | 2 +- .../monitoring/ServiceMonitorResource.java | 32 +- streampipes-rest-shared/pom.xml | 6 +- streampipes-rest/pom.xml | 26 +- .../apache/streampipes/rest/ResetManagement.java | 19 - .../rest/impl/AdapterMonitoringResource.java | 62 +- .../rest/impl/AssetManagementResource.java | 14 +- .../streampipes/rest/impl/Authentication.java | 9 + ...{PipelineElementFile.java => FileResource.java} | 4 +- .../rest/impl/MeasurementUnitResource.java | 12 +- .../streampipes/rest/impl/PipelineMonitoring.java | 4 +- .../streampipes/rest/impl/PipelineResource.java | 12 +- .../apache/streampipes/rest/impl/UserResource.java | 136 +- .../rest/impl/admin/CertificateResource.java | 101 + .../admin/ExportProviderConfigurationResource.java | 105 + .../rest/impl/connect/AdapterResource.java | 217 +- .../rest/impl/connect/CompactAdapterResource.java | 2 +- .../rest/impl/dashboard/DashboardWidget.java | 83 - ...esource.java => DataLakeDashboardResource.java} | 72 +- .../dashboard/VisualizablePipelineResource.java | 86 - .../impl/datalake/DataLakeDashboardResource.java | 48 - .../rest/impl/datalake/DataLakeDataWriter.java | 136 + .../rest/impl/datalake}/DataLakeImageResource.java | 2 +- .../impl/datalake/DataLakeMeasureResource.java | 48 +- .../rest/impl/datalake/DataLakeResource.java | 98 +- .../rest/impl/datalake/DataLakeWidgetResource.java | 2 +- .../datalake/KioskDashboardDataLakeResource.java | 130 + .../impl/pe}/PipelineElementTemplateResource.java | 3 +- .../PipelinePreviewResource.java} | 23 +- .../StreamPreviewResource.java} | 9 +- .../rest/security/SpPermissionEvaluator.java | 122 +- streampipes-sdk-bundle/pom.xml | 18 +- streampipes-sdk/pom.xml | 10 +- .../builder/AbstractProcessingElementBuilder.java | 31 - .../sdk/builder/PrimitivePropertyBuilder.java | 14 - .../sdk/extractor/AbstractParameterExtractor.java | 55 - .../streampipes/sdk/helpers/EpProperties.java | 293 +- .../streampipes/sdk/helpers/EpRequirements.java | 43 +- .../apache/streampipes/sdk/helpers/Protocols.java | 2 +- .../streampipes/sdk/helpers/SupportedFormats.java | 78 - streampipes-security-jwt/pom.xml | 4 +- streampipes-serializers-json/pom.xml | 8 +- streampipes-service-base/pom.xml | 12 +- .../service/base/ServiceBaseConfig.java | 18 +- .../service/base}/StreamPipesPrometheusConfig.java | 2 +- .../base/logging/LogbackRollingFileConfig.java | 101 + .../src/main/resources/META-INF/spring.factories | 9 +- streampipes-service-core-minimal/pom.xml | 6 +- .../minimal/StreamPipesCoreApplicationMinimal.java | 3 +- streampipes-service-core/pom.xml | 25 +- .../service/core/OpenApiConfiguration.java | 4 +- .../service/core/StreamPipesCoreApplication.java | 7 +- .../service/core/UnauthenticatedInterfaces.java | 5 +- .../service/core/WebSecurityConfig.java | 71 +- .../core/migrations/AvailableMigrations.java | 12 +- .../v0980/AddDataLakeMeasureViewMigration.java | 61 + .../v0980/AddDefaultExportProviderMigration.java | 62 + .../v0980/FixImportedPermissionsMigration.java | 116 + .../v0980/ModifyAssetLinkTypesMigration.java | 69 + .../v0980/ModifyAssetLinksMigration.java | 98 + .../service/core/oauth2/UserService.java | 116 +- .../service/core/scheduler/DataLakeScheduler.java | 209 + streampipes-service-discovery-api/pom.xml | 4 +- streampipes-service-discovery/pom.xml | 8 +- streampipes-service-extensions/pom.xml | 6 +- .../StreamPipesExtensionsServiceBase.java | 7 +- streampipes-storage-api/pom.xml | 8 +- .../streampipes/storage/api/CRUDStorage.java | 5 +- .../storage/api/IDataLakeMeasureStorage.java | 17 +- .../streampipes/storage/api/IGenericStorage.java | 4 + .../streampipes/storage/api/INoSqlStorage.java | 11 +- streampipes-storage-couchdb/pom.xml | 16 +- .../storage/couchdb/CouchDbStorageManager.java | 34 +- .../couchdb/impl/DataLakeMeasureStorage.java | 60 + .../storage/couchdb/impl/DefaultCrudStorage.java | 13 +- .../storage/couchdb/impl/GenericStorageImpl.java | 48 + .../impl/PipelineCanvasMetadataStorageImpl.java | 2 +- .../storage/couchdb/impl/UserStorage.java | 2 +- .../storage/couchdb/serializer/GsonSerializer.java | 2 - .../streampipes/storage/couchdb/utils/Utils.java | 5 +- streampipes-storage-management/pom.xml | 6 +- streampipes-test-utils-executors/pom.xml | 6 +- .../executors/ProcessingElementTestExecutor.java | 47 +- .../test/executors/TestConfiguration.java | 18 +- .../test/executors/TestConfigurationBuilder.java | 30 +- streampipes-test-utils/pom.xml | 8 +- streampipes-user-management/pom.xml | 8 +- .../user/management/service/UserService.java | 44 - .../management/util/GrantedPermissionsBuilder.java | 2 +- .../user/management/util/UserInfoUtil.java | 2 + streampipes-vocabulary/pom.xml | 2 +- .../apache/streampipes/vocabulary/StreamPipes.java | 3 - streampipes-wrapper-distributed/pom.xml | 6 +- streampipes-wrapper-flink/pom.xml | 8 +- streampipes-wrapper-kafka-streams/pom.xml | 6 +- streampipes-wrapper-siddhi/pom.xml | 8 +- streampipes-wrapper-standalone/pom.xml | 6 +- .../standalone/StreamPipesDataProcessor.java | 2 +- .../wrapper/standalone/StreamPipesDataSink.java | 1 + .../standalone/manager/ProtocolManager.java | 15 +- streampipes-wrapper/pom.xml | 14 +- tools/maven/checkstyle.xml | 71 +- tools/maven/streampipes-code-formatter.xml | 359 + ui/.eslintrc.json | 3 +- ui/.gitignore | 3 +- ui/Dockerfile | 8 - ui/angular.json | 38 +- ui/cypress.config.ts | 29 +- .../connect/addNumericalStaticValue/expected.json | 17 + .../connect/addNumericalStaticValue/input.csv | 4 + .../datalake/filterNumericalStringProperties.csv | 3 + ui/cypress/support/builder/AdapterBuilder.ts | 12 + ui/cypress/support/e2e.ts | 2 - ui/cypress/support/model/AdapterInput.ts | 3 + ui/cypress/support/model/DataExplorerWidget.ts | 6 +- .../support/model/DataTypeString.ts} | 11 +- ui/cypress/support/model/EventPropertyInput.ts | 4 +- .../support/model/PropertyDataTypeChange.ts} | 10 +- .../support/utils/DataDownloadDialogUtils.ts | 16 +- ui/cypress/support/utils/DataSetUtils.ts | 54 +- ui/cypress/support/utils/FileManagementUtils.ts | 10 +- ui/cypress/support/utils/GeneralUtils.ts | 18 +- .../support/utils/ProcessingElementTestUtils.ts | 4 +- ui/cypress/support/utils/UserUtils.ts | 25 +- ui/cypress/support/utils/asset/AssetBtns.ts | 77 + ui/cypress/support/utils/asset/AssetUtils.ts | 110 + .../ConfigurationBtns.ts} | 34 +- .../utils/configuration/ConfigurationUtils.ts | 24 + ui/cypress/support/utils/connect/ConnectBtns.ts | 26 +- .../utils/connect/ConnectEventSchemaUtils.ts | 52 +- ui/cypress/support/utils/connect/ConnectUtils.ts | 120 +- ui/cypress/support/utils/connect/OpcUaUtils.ts | 21 +- .../DataExplorerBtns.ts} | 35 +- .../DataExplorerUtils.ts} | 300 +- .../DataExplorerWidgetTableUtils.ts} | 14 +- .../support/utils/navigation/NavigationUtils.ts | 59 + ui/cypress/support/utils/pipeline/PipelineBtns.ts | 12 + ui/cypress/support/utils/pipeline/PipelineUtils.ts | 82 +- ui/cypress/support/utils/user/PermissionUtils.ts | 12 +- .../{datalake/DataLakeBtns.ts => user/UserBtns.ts} | 22 +- .../apiDocumentation.smoke.spec.ts | 4 +- .../tests/assetManagement/createAsset.spec.ts | 62 - .../generalAssetTest.smoke.spec.ts} | 35 +- .../tests/configuration/labels/general.spec.ts | 37 +- .../tests/configuration/labels/labels.spec.ts | 20 +- ui/cypress/tests/connect/adapterWithAssets.spec.ts | 106 + .../compactAdapterWithTransformation.spec.ts | 4 +- .../tests/connect/compact/uiConfiguration.spec.ts | 3 +- .../connect/createAdapterWithoutStarting.spec.ts | 5 +- ui/cypress/tests/connect/editAdapter.smoke.spec.ts | 36 +- ...> editAdapterSettingsAndPipeline.smoke.spec.ts} | 33 +- .../editAdapterTransformationRulesAreKept.spec.ts | 1 + .../connect/editAdapterValuesAndFields.spec.ts | 6 +- ui/cypress/tests/connect/fileStream.spec.ts | 4 +- .../connect/machineDataSimulator.smoke.spec.ts | 2 +- ...ec.ts => startAndEditOpcAdapters.smoke.spec.ts} | 6 +- .../connect/rules/addNumericalStaticValue.spec.ts | 87 + .../tests/dashboard/dashboardTest.smoke.spec.ts | 40 - .../tests/dashboard/dashboardWidgets.spec.ts | 81 - .../tests/dashboard/editDashboardTest.spec.ts | 71 - .../dataDownloadDialogTest.smoke.spec.ts | 19 +- .../dataExplorer/addAssetToDashboard.smoke.spec.ts | 81 + .../dataExplorer/addAssetsToDataView.smoke.spec.ts | 67 + .../charts}/heatmap.spec.ts | 9 +- .../charts}/histogram.spec.ts | 12 +- .../charts}/indicator.spec.ts | 12 +- .../widgets => dataExplorer/charts}/map.spec.ts | 10 +- .../charts}/scatter.smoke.spec.ts | 10 +- .../widgets => dataExplorer/charts}/table.spec.ts | 16 +- .../charts}/timeSeriesSave.spec.ts | 16 +- .../configuration.smoke.spec.ts | 12 +- .../dataExplorer/deleteViewAndDashboard.spec.ts | 76 + .../filterNumericalStringProperties.spec.ts | 91 + .../missingDataInDataLake.spec.ts | 12 +- .../timeOrderDataView.spec.ts | 39 +- .../timeRangeSelectors.spec.ts | 14 +- .../widgetDataConfiguration.smoke.spec.ts | 119 + .../tests/datalake/deleteViewAndDashboard.spec.ts | 70 - ui/cypress/tests/datalake/deleteWidget.ts | 60 - .../datalake/widgetDataConfiguration.smoke.spec.ts | 99 - .../restartStreamPipes/restartStreamPipes2.ts | 4 +- .../tests/experimental/testJvmArchetype/.env | 1 - .../experimental/testJvmArchetype/backend/.env | 1 - .../testJvmArchetype/backend/docker-compose.yml | 5 - .../testJvmArchetype/docker-compose.yml | 6 - ui/cypress/tests/login/login.smoke.spec.ts | 2 +- ui/cypress/tests/pipeline/pipelineAsset.spec.ts | 97 + .../tests/pipeline/pipelineTest.smoke.spec.ts | 2 +- ...st.smoke.spec.ts => renamePipelineTest.spec.ts} | 33 +- .../pipeline/updatePipelineTest.smoke.spec.ts | 15 +- .../userManagement/testGroupManagement.spec.ts | 35 +- .../tests/userManagement/testUserRoleAsset.spec.ts | 139 + .../userManagement/testUserRoleConnect.spec.ts | 30 +- .../userManagement/testUserRolePipeline.spec.ts | 15 +- .../testVariousUserRoles.smoke.spec.ts | 35 +- ui/deployment/app-routing.module.mst | 10 +- ui/deployment/app.module.mst | 24 +- ui/deployment/base-navigation.component.mst | 19 +- ui/deployment/dev/config.yml | 1 + ui/deployment/home.service.mst | 5 +- ui/deployment/i18n-translate.js | 83 + ui/deployment/i18n/de.json | 940 + ui/deployment/i18n/en.json | 940 + ui/deployment/modules.yml | 23 +- ui/deployment/prebuild.js | 51 +- ui/deployment/theme/_custom-variables.scss | 49 + ui/deployment/theme/_theme-colors.scss | 250 + ui/develocity.config.js | 118 + ui/docker-entrypoint.sh | 17 +- ui/package-lock.json | 19854 ++++++++++--------- ui/package.json | 98 +- .../streampipes/platform-services/package.json | 10 +- .../src/lib/apis/abstract-monitoring.service.ts | 7 +- .../src/lib/apis/adapter-monitoring.service.ts | 9 - .../src/lib/apis/adapter.service.ts | 23 +- .../src/lib/apis/asset-management.service.ts | 8 +- ...rmissions.service.ts => certificate.service.ts} | 41 +- ...w-data-explorer.service.ts => chart.service.ts} | 110 +- .../src/lib/apis/commons.service.ts | 2 - .../src/lib/apis/compact-pipeline.service.ts | 8 +- .../src/lib/apis/dashboard-kiosk.service.ts | 52 + .../src/lib/apis/dashboard.service.ts | 136 +- .../src/lib/apis/datalake-rest.service.ts | 62 +- .../src/lib/apis/export-provider.service.ts | 66 + .../src/lib/apis/extension-installation.service.ts | 18 +- .../src/lib/apis/files.service.ts | 8 +- .../src/lib/apis/functions.service.ts | 8 +- .../src/lib/apis/general-config.service.ts | 8 +- .../src/lib/apis/generic-storage.service.ts | 8 +- .../src/lib/apis/labels.service.ts | 4 +- .../src/lib/apis/location-config.service.ts | 8 +- .../src/lib/apis/mail-config.service.ts | 8 +- .../src/lib/apis/measurement-units.service.ts | 38 +- .../src/lib/apis/permissions.service.ts | 8 +- .../lib/apis/pipeline-canvas-metadata.service.ts | 8 +- ...ervice.ts => pipeline-element-asset.service.ts} | 20 +- ...ts => pipeline-element-runtime-info.service.ts} | 41 +- .../lib/apis/pipeline-element-template.service.ts | 8 +- .../src/lib/apis/pipeline-element.service.ts | 8 +- .../src/lib/apis/pipeline-monitoring.service.ts | 28 +- .../src/lib/apis/pipeline-template.service.ts | 4 +- .../src/lib/apis/pipeline.service.spec.ts | 65 - .../src/lib/apis/pipeline.service.ts | 8 +- .../src/lib/apis/privilege.service.ts | 8 +- .../platform-services/src/lib/apis/role.service.ts | 8 +- .../src/lib/apis/semantic-types-rest.service.ts | 8 +- .../src/lib/apis/service-tags.service.ts | 8 +- .../src/lib/apis/shared-dashboard.service.ts | 4 +- .../src/lib/apis/user-admin.service.ts | 8 +- .../src/lib/apis/user-group.service.ts | 8 +- .../platform-services/src/lib/apis/user.service.ts | 8 +- .../src/lib/model/assets/asset.model.ts | 17 + .../src/lib/model/config/general-config.model.ts | 7 + .../src/lib/model/dashboard/dashboard.model.ts | 15 + .../model/datalake/data-lake-query-config.model.ts | 1 + .../src/lib/model/gen/streampipes-model-client.ts | 23 +- .../src/lib/model/gen/streampipes-model.ts | 391 +- .../src/lib/model/types/data-type.ts | 11 + .../lib/query/data-view-query-generator.service.ts | 38 +- .../src/lib}/services/live-preview.service.ts | 0 .../pipeline-element-icon-text.service.ts} | 2 +- .../platform-services/src/public-api.ts | 11 +- ui/projects/streampipes/shared-ui/package.json | 16 +- .../asset-browser-hierarchy.component.html | 21 +- .../asset-browser-hierarchy.component.scss | 10 + .../asset-browser-hierarchy.component.ts | 30 +- .../asset-browser-node-info.component.ts | 1 + .../asset-browser-node.component.html | 1 + .../asset-browser-node.component.scss | 2 +- .../asset-browser-node.component.ts | 1 + .../asset-browser-filter-labels.component.html | 5 +- .../asset-browser-filter-labels.component.ts | 1 + .../asset-browser-filter-outer.component.html | 8 +- .../asset-browser-filter-outer.component.ts | 1 + .../asset-browser-filter-sites.component.html | 2 +- .../asset-browser-filter-sites.component.ts | 1 + .../asset-browser-filter-type.component.html | 2 +- .../asset-browser-filter-type.component.ts | 1 + .../asset-browser-filter.component.html | 14 +- .../asset-browser-filter.component.scss | 4 +- .../asset-browser-filter.component.ts | 1 + .../asset-browser-toolbar.component.html | 4 +- .../asset-browser-toolbar.component.ts | 1 + .../asset-browser/asset-browser.component.html | 13 +- .../asset-browser/asset-browser.component.ts | 10 +- .../asset-link-configuration.component.html | 72 + .../asset-link-configuration.component.scss} | 74 +- .../asset-link-configuration.component.ts | 206 + .../basic-field-description.component.ts | 1 + .../basic-header-title/header-title.component.scss | 18 +- .../basic-header-title/header-title.component.ts | 1 + .../basic-inner-panel.component.html | 10 +- .../basic-inner-panel.component.scss | 31 +- .../basic-inner-panel.component.ts | 4 + .../basic-nav-tabs/basic-nav-tabs.component.html | 3 +- .../basic-nav-tabs/basic-nav-tabs.component.scss | 6 + .../basic-nav-tabs/basic-nav-tabs.component.ts | 1 + .../basic-view/basic-view.component.html | 3 +- .../basic-view/basic-view.component.scss | 3 + .../components/basic-view/basic-view.component.ts | 1 + .../configuration-box.component.html | 0 .../configuration-box.component.scss | 0 .../configuration-box.component.ts | 1 + .../date-input/date-input.component.html | 0 .../date-input/date-input.component.scss | 0 .../components}/date-input/date-input.component.ts | 3 +- .../input-schema-panel.component.html | 15 +- .../input-schema-panel.component.scss | 10 + .../input-schema-panel.component.ts | 8 +- .../input-schema-property.component.html | 0 .../input-schema-property.component.ts | 3 +- .../pipeline-element-documentation.component.html | 2 +- .../pipeline-element-documentation.component.scss | 0 .../pipeline-element-documentation.component.ts | 1 + .../live-preview-error.component.html | 2 +- .../live-preview-error.component.scss | 0 .../live-preview-error.component.ts | 1 + .../live-preview-loading.component.html | 2 +- .../live-preview-loading.component.scss | 0 .../live-preview-loading.component.ts | 1 + .../live-preview-table.component.html | 18 +- .../live-preview-table.component.scss | 0 .../live-preview-table.component.ts | 7 +- .../pipeline-element-runtime-info.component.html | 0 .../pipeline-element-runtime-info.component.scss | 0 .../pipeline-element-runtime-info.component.ts | 14 +- .../pipeline-element-runtime-info.model.ts | 0 .../pipeline-element.component.html | 7 +- .../pipeline-element.component.scss | 4 + .../pipeline-element/pipeline-element.component.ts | 43 +- .../sidebar-resize/sidebar-resize.component.html} | 31 +- .../sidebar-resize/sidebar-resize.component.scss} | 70 +- .../sidebar-resize/sidebar-resize.component.ts | 71 + .../exception-details-dialog.component.html | 16 +- .../exception-details-dialog.component.ts | 11 +- .../exception-details.component.html | 12 +- .../exception-details.component.scss | 2 +- .../exception-details.component.ts | 1 + .../sp-exception-message.component.html | 10 +- .../sp-exception-message.component.ts | 8 +- .../components/sp-label/sp-label.component.scss | 1 - .../lib/components/sp-label/sp-label.component.ts | 7 +- .../sp-table/sp-table-actions.directive.ts} | 4 +- .../components/sp-table/sp-table.component.html | 49 +- .../components/sp-table/sp-table.component.scss | 11 +- .../lib/components/sp-table/sp-table.component.ts | 32 + .../split-section/split-section.component.html | 2 +- .../split-section/split-section.component.ts | 1 + .../refresh-interval-settings.component.html | 4 +- .../refresh-interval-settings.component.ts | 1 + .../time-range-selector.component.html | 2 +- .../time-range-selector.component.scss | 5 +- .../time-selector/time-range-selector.component.ts | 1 + .../custom-time-range-selection.component.html | 4 +- .../custom-time-range-selection.component.ts | 1 + .../time-selector-menu.component.scss | 2 +- .../time-selector-menu.component.ts | 1 + .../warning-box/warning-box.component.ts | 1 + .../confirm-dialog/confirm-dialog.component.html | 2 +- .../confirm-dialog/confirm-dialog.component.scss | 2 - .../confirm-dialog/confirm-dialog.component.ts | 1 + .../components/download/download.component.html | 8 +- .../components/download/download.component.scss | 0 .../components/download/download.component.ts | 1 + .../select-data-missing-values.component.html} | 42 +- .../select-data-missing-values.component.scss | 0 .../select-data-missing-values.component.ts | 1 + .../select-data-range.component.html | 65 + .../select-data-range.component.scss | 0 .../select-data-range.component.ts | 1 + .../select-data/select-data.component.html | 0 .../select-data/select-data.component.scss | 2 - .../select-data/select-data.component.ts | 3 +- .../select-format/select-format.component.html | 140 + .../select-format/select-format.component.scss | 0 .../select-format/select-format.component.ts | 26 +- .../data-download-dialog.component.html | 20 +- .../data-download-dialog.component.scss | 2 - .../data-download-dialog.component.ts | 10 +- .../model/data-download-dialog.model.ts | 0 .../model/data-export-config.model.ts | 0 .../model/download-progress.model.ts | 0 .../model/export-config.model.ts | 0 .../model/format-export-config.model.ts | 18 +- .../services/data-export.service.ts | 13 +- .../services/file-name.service.spec.ts | 6 +- .../services/file-name.service.ts | 2 +- .../panel-dialog/panel-dialog.component.html | 2 +- .../panel-dialog/panel-dialog.component.scss | 4 +- .../dialog/panel-dialog/panel-dialog.component.ts | 1 + .../pipeline-element-help.component.html} | 9 +- .../pipeline-element-help.component.scss} | 2 - .../pipeline-element-help.component.ts} | 35 +- .../standard-dialog/standard-dialog.component.html | 2 +- .../standard-dialog/standard-dialog.component.scss | 4 +- .../standard-dialog/standard-dialog.component.ts | 1 + .../src/lib}/pipes/sort-by-runtime-name.pipe.ts | 1 + .../lib/services/asset-configuration.service.ts | 337 + .../src/lib/services/colorization.service.ts | 107 +- .../src/lib/services/date-format.service.ts} | 23 +- .../services}/pipeline-element-schema.service.ts | 19 +- .../src/lib/services/time-selection.service.ts | 55 +- .../shared-ui/src/lib/shared-ui.module.ts | 77 +- .../streampipes/shared-ui/src/public-api.ts | 14 + .../_guards/auth.can-activate-children.guard.ts | 3 +- .../auth.can-activate.guard.ts} | 34 +- .../_guards/base-configured.can-activate.guard.ts | 3 +- .../_guards/terms.can-activate-children.guard.ts | 62 + ui/src/app/apidocs/apidocs.component.ts | 1 + .../app/app-overview/app-overview.component.html | 2 +- ui/src/app/app.component.ts | 17 +- ui/src/app/assets/assets.module.ts | 4 + .../asset-details-basics.component.html | 24 +- .../asset-details-basics.component.ts | 1 + .../asset-details-labels.component.html | 6 +- .../asset-details-labels.component.ts | 59 +- .../asset-details-site.component.html | 2 +- .../asset-details-site.component.ts | 1 + .../asset-location/asset-location.component.ts | 1 + .../asset-details-links.component.html | 11 +- .../asset-details-links.component.ts | 5 +- .../asset-link-item/asset-link-item.component.scss | 2 +- .../asset-link-item/asset-link-item.component.ts | 6 +- .../asset-link-section.component.ts | 1 + .../edit-asset/asset-details.component.html | 6 +- .../edit-asset/asset-details.component.ts | 1 + .../asset-selection-panel.component.ts | 3 +- .../view-assset-basics.component.ts | 1 + .../view-asset-labels.component.ts | 1 + .../asset-link-card/asset-link-card.component.ts | 1 + .../view-asset-links/view-asset-links.component.ts | 1 + .../view-asset/view-asset.component.ts | 1 + .../asset-overview/asset-overview.component.html | 76 +- .../asset-overview/asset-overview.component.ts | 3 +- .../assets/dialog/base-asset-links.directive.ts | 19 +- .../create-asset-dialog.component.html | 6 +- .../create-asset/create-asset-dialog.component.ts | 3 +- .../edit-asset-link-dialog.component.html | 24 +- .../edit-asset-link-dialog.component.scss | 11 +- .../edit-asset-link-dialog.component.ts | 11 +- .../manage-asset-links-dialog.component.html | 128 +- .../manage-asset-links-dialog.component.scss | 2 - .../manage-asset-links-dialog.component.ts | 12 +- ui/src/app/assets/pipes/asset-type-filter.pipe.ts | 1 + .../configuration/configuration-tabs.service.ts | 26 +- ui/src/app/configuration/configuration.module.ts | 42 +- .../datalake-configuration-entry.ts | 5 + .../datalake-configuration.component.html | 311 +- .../datalake-configuration.component.ts | 158 +- .../certificate-details-dialog.component.html | 61 + .../certificate-details-dialog.component.ts} | 24 +- .../select-export/select-format.component.html | 147 + .../select-export/select-format.component.scss} | 25 +- .../select-export/select-format.component.ts | 121 + .../select-data-retention.component.html} | 37 +- .../select-data-retention.component.scss} | 0 .../select-data-retention.component.ts} | 27 +- .../select-retention/select-data.component.html} | 26 +- .../select-retention}/select-data.component.scss | 2 - .../select-retention/select-data.component.ts} | 23 +- .../select-retention-action.component.html | 48 + .../select-retention-action.component.scss} | 0 .../select-retention-action.component.ts} | 24 +- .../data-retention-dialog.component.html | 77 + .../data-retention-dialog.component.scss} | 73 +- .../data-retention-dialog.component.ts | 141 + .../model/data-retention-config.model.ts} | 8 +- .../model/data-retention-dialog.model.ts} | 8 +- .../model/data-retention-provider.model.ts} | 8 +- .../model/retention-config.model.ts} | 7 +- .../model/retention-export-config.model.ts} | 29 +- .../delete-datalake-index-dialog.component.html | 30 +- .../delete-datalake-index-dialog.component.scss | 19 - .../delete-datalake-index-dialog.component.ts | 14 +- .../delete-export-provider-dialog.component.html} | 38 +- .../delete-export-provider-dialog.component.ts} | 43 +- .../export-provider-dialog.component.html | 116 + .../export-provider-dialog.component.ts | 135 + .../extensions-installation.component.html | 33 +- .../extensions-installation.component.scss | 19 - .../extensions-installation.component.ts | 10 +- ...xtensions-service-details-dialog.component.html | 17 +- ...xtensions-service-details-dialog.component.scss | 2 - .../extensions-service-details-dialog.component.ts | 1 + .../file-rename/file-rename-dialog.component.html | 22 +- .../file-rename/file-rename-dialog.component.ts | 1 + .../file-upload/file-upload-dialog.component.html | 23 +- .../file-upload/file-upload-dialog.component.ts | 7 +- .../edit-location-area.component.html | 24 +- .../edit-location-area.component.scss | 11 + .../edit-location-area.component.ts | 29 +- .../edit-location/edit-location.component.html | 27 +- .../edit-location/edit-location.component.ts | 17 +- .../manage-site/manage-site-dialog.component.html | 10 +- .../manage-site/manage-site-dialog.component.ts | 14 +- .../email-configuration.component.html | 77 +- .../email-configuration.component.ts | 13 +- .../email-template-configuration.component.html | 20 +- .../email-template-configuration.component.scss | 2 +- .../email-template-configuration.component.ts | 29 +- .../export/data-export-import.component.html | 30 +- .../export/data-export-import.component.ts | 7 +- .../data-export-dialog.component.html | 39 +- .../data-export-dialog.component.scss | 19 - .../export-dialog/data-export-dialog.component.ts | 2 +- .../data-export-item/data-export-item.component.ts | 1 + .../generic-storage-item.component.html} | 27 +- .../generic-storage-item.component.ts} | 20 +- .../generic-storage-items.component.html | 54 + .../generic-storage-items.component.ts} | 33 +- .../data-import-dialog.component.html | 90 +- .../data-import-dialog.component.scss | 5 +- .../import-dialog/data-import-dialog.component.ts | 37 +- .../endpoint-item/endpoint-item.component.html | 35 +- .../endpoint-item/endpoint-item.component.ts | 20 +- .../extensions-installation.component.html | 45 +- .../extensions-installation.component.ts | 5 +- .../filter/order-by.pipe.ts | 5 +- .../pipeline-element-installation-status.pipe.ts | 1 + .../filter/pipeline-element-name.pipe.ts | 1 + .../filter/pipeline-element-type.pipe.ts | 1 + .../certificate-configuration.component.html | 134 + .../certificate-configuration.component.ts | 82 + ...extensions-service-configuration.component.html | 10 +- .../extensions-service-configuration.component.ts | 1 + .../service-configs-boolean.component.ts | 1 + .../service-configs-item.component.ts | 1 + .../service-configs-number.component.ts | 1 + .../service-configs-password.component.spec.ts | 16 +- .../service-configs-password.component.ts | 1 + .../service-configs-text.component.ts | 1 + .../service-configs/service-configs.component.html | 4 +- .../service-configs/service-configs.component.ts | 1 + .../extensions-service-management.component.html | 23 +- .../extensions-service-management.component.ts | 1 + .../registered-extensions-services.component.html | 22 +- .../registered-extensions-services.component.ts | 5 +- .../file-overview/file-overview.component.html | 10 +- .../files/file-overview/file-overview.component.ts | 7 +- .../app/configuration/files/files.component.html | 11 +- ui/src/app/configuration/files/files.component.ts | 5 +- .../general-configuration.component.html | 70 +- .../general-configuration.component.scss | 5 +- .../general-configuration.component.ts | 86 +- .../link-settings/link-settings.component.html | 28 +- .../link-settings/link-settings.component.ts | 1 + .../user-acknowledgment.component.html} | 46 +- .../user-acknowledgment.component.ts} | 17 +- .../edit-label/edit-label.component.html | 14 +- .../edit-label/edit-label.component.ts | 22 +- .../label-configuration.component.html | 21 +- .../label-configuration.component.ts | 1 + .../broker-config/broker-config.component.html | 4 +- .../broker-config/broker-config.component.ts | 1 + .../messaging-configuration.component.html | 39 +- .../messaging-configuration.component.ts | 1 + .../abstract-security-principal-config.ts | 37 +- .../alternate-id-configuration.component.html} | 43 +- .../alternate-id-configuration.component.ts} | 24 +- .../authentication-configuration.component.html | 4 +- .../authentication-configuration.component.ts | 1 + .../edit-group-dialog.component.html | 31 +- .../edit-group-dialog.component.scss | 2 - .../edit-group-dialog.component.ts | 1 + .../edit-role-dialog.component.html | 55 +- .../edit-role-dialog.component.scss | 1 - .../edit-role-dialog/edit-role-dialog.component.ts | 20 +- .../edit-user-dialog.component.html | 366 +- .../edit-user-dialog.component.scss | 2 - .../edit-user-dialog/edit-user-dialog.component.ts | 379 +- .../role-configuration.component.html | 31 +- .../role-configuration.component.ts | 21 +- .../security-configuration.component.html | 42 +- .../security-configuration.component.ts | 1 + .../security-service-config.component.html | 26 +- .../security-service-config.component.ts | 1 + .../security-user-config.component.html | 69 +- .../security-user-config.component.ts | 19 +- .../user-group-configuration.component.html | 37 +- .../user-group-configuration.component.ts | 23 +- .../shared/configuration.service.spec.ts | 16 +- .../configuration/shared/configuration.service.ts | 4 +- .../location-features-configuration.component.html | 23 +- .../location-features-configuration.component.ts | 15 +- .../site-area-configuration.component.html | 18 +- .../site-area-configuration.component.ts | 5 +- .../sites-configuration.component.ts | 1 + .../adapter-code-panel.component.ts | 1 + .../adapter-configuration.component.html | 24 +- .../adapter-configuration.component.ts | 13 +- .../adapter-deployment-settings.component.html | 6 +- .../adapter-deployment-settings.component.ts | 1 + .../adapter-settings.component.html | 16 +- .../adapter-settings/adapter-settings.component.ts | 1 + .../error-message/error-message.component.html | 6 +- .../error-message/error-message.component.ts | 1 + .../event-property-row.component.html | 24 +- .../event-property-row.component.scss | 4 +- .../event-property-row.component.ts | 1 + .../event-schema-error-hints.component.ts | 1 + .../event-schema-preview.component.html | 9 +- .../event-schema-preview.component.ts | 1 + .../event-schema/event-schema.component.html | 36 +- .../event-schema/event-schema.component.ts | 41 +- .../loading-message/loading-message.component.html | 8 +- .../loading-message/loading-message.component.ts | 6 +- .../schema-editor-header.component.html | 6 +- .../schema-editor-header.component.ts | 2 + .../adapter-options-panel.component.scss | 9 +- .../adapter-options-panel.component.ts | 1 + .../start-adapter-configuration.component.html | 185 +- .../start-adapter-configuration.component.ts | 63 +- .../abstract-adapter-details.directive.ts | 22 +- .../adapter-details-code.component.html | 26 +- .../adapter-details-code.component.ts | 1 + .../adapter-details-data.component.html | 55 +- .../adapter-details-data.component.ts | 1 + .../adapter-details-logs.component.html | 24 +- .../adapter-details-logs.component.ts | 1 + .../adapter-details-metrics.component.html | 28 +- .../adapter-details-metrics.component.ts | 1 + .../configuration-group.component.html | 2 +- .../configuration-group.component.ts | 1 + .../adapter-description.component.html | 51 +- .../adapter-description.component.scss | 28 +- .../adapter-description.component.ts | 17 +- .../data-marketplace.component.html | 5 +- .../data-marketplace.component.scss | 4 +- .../data-marketplace/data-marketplace.component.ts | 1 + .../edit-adapter/edit-adapter.component.ts | 1 + .../adapter-status-light.component.ts | 2 +- .../existing-adapters.component.html | 270 +- .../existing-adapters.component.scss | 11 +- .../existing-adapters.component.ts | 97 +- .../filter-toolbar/filter-toolbar.component.html | 2 +- .../filter-toolbar/filter-toolbar.component.ts | 1 + .../new-adapter/new-adapter.component.ts | 1 + ui/src/app/connect/connect.module.ts | 8 +- .../adapter-documentation-dialog.component.html | 2 +- .../adapter-documentation-dialog.component.ts | 1 + .../adapter-started-dialog.component.html | 6 +- .../adapter-started-dialog.component.scss | 19 - .../adapter-started-dialog.component.ts | 217 +- .../adapter-started-loading.component.ts | 1 + .../adapter-started-preview.component.ts | 1 + .../adapter-started-success.component.html | 44 + .../adapter-started-success.component.ts | 7 + ...adapter-started-update-migration.component.html | 40 +- .../adapter-started-update-migration.component.ts | 1 + .../adapter-template-dialog.component.html | 4 +- .../adapter-template-dialog.component.scss | 19 - .../adapter-template-dialog.component.ts | 2 +- .../can-not-edit-adapter-dialog.component.html | 2 +- .../can-not-edit-adapter-dialog.component.scss | 19 - .../can-not-edit-adapter-dialog.component.ts | 2 +- .../delete-adapter-dialog.component.html | 91 +- .../delete-adapter-dialog.component.scss | 4 +- .../delete-adapter-dialog.component.ts | 1 + .../edit-regex-transformation.component.ts | 1 + .../edit-data-type/edit-data-type.component.ts | 1 + .../edit-schema-transformation.component.scss | 19 - .../edit-schema-transformation.component.ts | 3 +- .../edit-unit-transformation.component.ts | 1 + .../edit-correction-value.component.scss | 19 - .../edit-correction-value.component.ts | 3 +- .../edit-timestamp-property.component.ts | 1 + .../edit-value-transformation.component.ts | 6 +- .../ep-settings-section.component.ts | 1 + .../edit-event-property.component.html | 4 +- .../edit-event-property.component.scss | 2 - .../edit-event-property.component.ts | 1 + .../all-adapter-actions-dialog.component.html | 43 +- .../all-adapter-actions-dialog.component.scss | 19 - .../all-adapter-actions-dialog.component.ts | 16 +- ui/src/app/connect/filter/adapter-filter.pipe.ts | 5 +- ui/src/app/connect/filter/timestamp.pipe.ts | 1 + .../adapter-asset-configuration.service.ts | 337 + .../services/event-property-utils.service.ts | 7 - ui/src/app/connect/services/rest.service.ts | 19 +- .../services/static-value-transform.service.ts | 42 +- .../services/transformation-rule.service.ts | 131 +- .../id-generator/id-generator.service.ts | 4 + .../template/PipelineInvocationBuilder.ts | 96 - .../configuration-code-panel.component.html | 4 +- .../configuration-code-panel.component.ts | 1 + ui/src/app/core-ui/core-ui.module.ts | 46 +- .../select-data-range.component.html | 64 - .../echarts-transform/histogram.transform.ts | 2 +- .../app/core-ui/error-hint/error-hint.component.ts | 1 + .../loading-indicator.component.ts | 8 +- .../simple-logs/simple-logs.component.html | 4 +- .../simple-logs/simple-logs.component.ts | 1 + .../simple-metrics/simple-metrics.component.html | 27 +- .../simple-metrics/simple-metrics.component.ts | 1 + .../multi-step-status-indicator.component.scss | 2 +- .../multi-step-status-indicator.component.ts | 1 + .../object-permission-dialog.component.html | 318 +- .../object-permission-dialog.component.scss | 11 +- .../object-permission-dialog.component.ts | 45 +- ...ine-element-template-config-item.component.html | 2 +- ...eline-element-template-config-item.component.ts | 1 + ...pipeline-element-template-config.component.html | 18 +- ...pipeline-element-template-config.component.scss | 2 - .../pipeline-element-template-config.component.ts | 1 + .../pipeline-element-template.pipe.ts | 5 +- .../pipeline-operation-status.component.ts | 1 + .../pipeline-started-status.component.html | 20 +- .../pipeline-started-status.component.ts | 1 + ui/src/app/core-ui/pipes/json-pretty-print.pipe.ts | 1 + ui/src/app/core-ui/pipes/yaml-pretty-print.pipe.ts | 1 + .../single-marker-map.component.ts | 48 +- .../base/abstract-validated-static-property.ts | 6 +- .../filter/display-recommended.pipe.ts | 5 +- .../core-ui/static-properties/input.validator.ts | 45 +- .../static-alternatives.component.scss | 4 - .../static-alternatives.component.ts | 1 + .../static-any-input/static-any-input.component.ts | 1 + .../static-code-input.component.html | 8 +- .../static-code-input.component.ts | 11 +- .../add-to-collection.component.html | 8 +- .../add-to-collection.component.ts | 32 +- .../static-collection.component.ts | 1 + .../static-color-picker.component.ts | 1 + .../static-file-input.component.html | 20 +- .../static-file-input.component.scss | 4 +- .../static-file-input.component.ts | 8 +- .../static-free-input.component.html | 45 +- .../static-free-input.component.scss | 2 +- .../static-free-input.component.ts | 21 +- .../static-group/static-group.component.ts | 1 + .../static-mapping-nary.component.html | 8 +- .../static-mapping-nary.component.scss | 2 - .../static-mapping-nary.component.ts | 1 + .../static-mapping-unary.component.ts | 1 + .../static-one-of-input.component.html | 1 - .../static-one-of-input.component.ts | 1 + .../static-property-util.service.ts | 16 +- .../static-property.component.html | 7 +- .../static-property.component.scss | 4 - .../static-properties/static-property.component.ts | 1 + ...tic-runtime-resolvable-any-input.component.html | 16 +- ...tatic-runtime-resolvable-any-input.component.ts | 1 + .../static-runtime-resolvable-group.component.html | 4 +- .../static-runtime-resolvable-group.component.ts | 1 + ...c-runtime-resolvable-oneof-input.component.html | 6 +- ...tic-runtime-resolvable-oneof-input.component.ts | 1 + ...ic-runtime-resolvable-tree-input.component.scss | 4 +- ...atic-runtime-resolvable-tree-input.component.ts | 3 +- .../static-tree-input-browse-nodes.component.html | 36 +- .../static-tree-input-browse-nodes.component.ts | 13 +- .../static-tree-input-button-menu.component.html | 27 +- .../static-tree-input-button-menu.component.ts | 1 + .../static-tree-input-node-details.component.html | 2 +- .../static-tree-input-node-details.component.ts | 1 + ...static-tree-input-selected-nodes.component.html | 2 +- .../static-tree-input-selected-nodes.component.ts | 1 + .../static-tree-input-text-editor.component.ts | 19 +- .../static-secret-input.component.ts | 1 + .../static-slide-toggle.component.ts | 1 + .../status-indicator.component.scss | 2 +- .../status-indicator/status-indicator.component.ts | 8 +- .../core-ui/status/status-widget.component.html | 25 +- .../core-ui/status/status-widget.component.scss | 20 + .../app/core-ui/status/status-widget.component.ts | 34 +- ui/src/app/core-ui/topics/topics.component.html | 28 +- ui/src/app/core-ui/topics/topics.component.scss | 2 - ui/src/app/core-ui/topics/topics.component.ts | 11 +- .../components/bars.scss} | 22 +- .../breadcrumb/breadcrumb.component.scss | 4 +- .../components/breadcrumb/breadcrumb.component.ts | 1 + .../core/components/iconbar/iconbar.component.html | 57 +- .../core/components/iconbar/iconbar.component.ts | 16 +- .../streampipes/streampipes.component.scss | 2 - .../streampipes/streampipes.component.ts | 11 +- .../core/components/toolbar/toolbar.component.html | 15 +- .../core/components/toolbar/toolbar.component.scss | 9 + .../core/components/toolbar/toolbar.component.ts | 27 +- ui/src/app/core/pipes/shorten.pipe.ts | 1 + .../kiosk/dashboard-kiosk.component.html | 73 + .../kiosk/dashboard-kiosk.component.scss} | 31 +- .../components/kiosk/dashboard-kiosk.component.ts | 141 + .../app/dashboard-kiosk/dashboard-kiosk.module.ts | 63 + .../chart-view/abstract-chart-view.directive.ts} | 65 +- .../grid-view/dashboard-grid-view.component.html | 62 + .../grid-view/dashboard-grid-view.component.scss} | 21 +- .../grid-view/dashboard-grid-view.component.ts} | 53 +- .../dashboard-slide-view.component.html} | 5 +- .../dashboard-slide-view.component.scss} | 7 +- .../slide-view/dashboard-slide-view.component.ts} | 45 +- .../dashboard-shared.module.ts} | 90 +- .../dashboard-shared/services/dashboard.service.ts | 49 + .../components/grid/dashboard-grid.component.html | 43 - .../components/grid/dashboard-grid.component.scss | 31 - .../components/grid/dashboard-grid.component.ts | 172 - .../dashboard-overview-table.component.html | 148 + .../dashboard-overview-table.component.ts | 187 + .../overview/dashboard-overview.component.html | 141 +- .../overview/dashboard-overview.component.scss | 36 - .../overview/dashboard-overview.component.ts | 154 +- .../chart-selection-panel.component.html} | 13 +- .../chart-selection-panel.component.scss} | 0 .../chart-selection-panel.component.ts} | 13 +- .../chart-preview/chart-preview.component.html} | 8 +- .../chart-preview/chart-preview.component.scss} | 4 + .../chart-preview/chart-preview.component.ts} | 21 +- .../chart-selection.component.html} | 22 +- .../chart-selection.component.scss} | 0 .../chart-selection/chart-selection.component.ts} | 23 +- .../panel/dashboard-panel.component.html | 160 +- .../panel/dashboard-panel.component.scss | 23 +- .../components/panel/dashboard-panel.component.ts | 418 +- .../dashboard-toolbar.component.html | 137 + .../dashboard-toolbar.component.scss | 0 .../dashboard-toolbar.component.ts | 5 +- .../standalone/standalone-dashboard.component.html | 26 - .../standalone/standalone-dashboard.component.scss | 31 - .../standalone/standalone-dashboard.component.ts | 59 - .../widget/dashboard-widget.component.html | 314 - .../widget/dashboard-widget.component.ts | 207 - .../widgets/area/area-widget.component.html | 52 - .../widgets/area/area-widget.component.scss | 24 - .../widgets/area/area-widget.component.ts | 47 - .../components/widgets/bar-race/bar-race-config.ts | 60 - .../bar-race/bar-race-widget.component.html | 42 - .../bar-race/bar-race-widget.component.scss | 53 - .../widgets/bar-race/bar-race-widget.component.ts | 190 - .../components/widgets/base/base-config.ts | 31 - .../components/widgets/base/base-echarts-widget.ts | 54 - .../widgets/base/base-ngx-charts-widget.ts | 61 - .../widgets/base/base-ngx-line-charts-widget.ts | 98 - .../widgets/base/base-ngx-line-config.ts | 69 - .../components/widgets/base/base-widget.ts | 299 - .../components/widgets/gauge/gauge-config.ts | 65 - .../widgets/gauge/gauge-widget.component.html | 46 - .../widgets/gauge/gauge-widget.component.scss | 32 - .../widgets/gauge/gauge-widget.component.ts | 83 - .../components/widgets/html/html-config.ts | 50 - .../widgets/html/html-widget.component.html | 34 - .../widgets/html/html-widget.component.scss | 32 - .../widgets/html/html-widget.component.ts | 79 - .../components/widgets/image/image-config.ts | 50 - .../widgets/image/image-widget.component.html | 26 - .../widgets/image/image-widget.component.scss | 31 - .../widgets/image/image-widget.component.ts | 86 - .../components/widgets/line/line-config.ts | 37 - .../widgets/line/line-widget.component.html | 52 - .../widgets/line/line-widget.component.scss | 32 - .../widgets/line/line-widget.component.ts | 47 - .../dashboard/components/widgets/map/map-config.ts | 87 - .../widgets/map/map-widget.component.html | 42 - .../widgets/map/map-widget.component.scss | 31 - .../components/widgets/map/map-widget.component.ts | 207 - .../components/widgets/number/number-config.ts | 50 - .../widgets/number/number-widget.component.html | 38 - .../widgets/number/number-widget.component.ts | 98 - .../dashboard/components/widgets/raw/raw-config.ts | 41 - .../widgets/raw/raw-widget.component.html | 39 - .../widgets/raw/raw-widget.component.scss | 36 - .../components/widgets/raw/raw-widget.component.ts | 74 - .../stacked-line-chart-config.ts | 54 - .../stacked-line-chart-widget.component.html | 42 - .../stacked-line-chart-widget.component.scss | 53 - .../stacked-line-chart-widget.component.ts | 154 - .../components/widgets/status/status-config.ts | 46 - .../widgets/status/status-widget.component.html | 42 - .../widgets/status/status-widget.component.ts | 89 - .../components/widgets/table/table-config.ts | 53 - .../widgets/table/table-widget.component.html | 62 - .../widgets/table/table-widget.component.scss | 33 - .../widgets/table/table-widget.component.ts | 109 - .../widgets/trafficlight/traffic-light-config.ts | 74 - .../traffic-light-widget.component.html | 65 - .../traffic-light-widget.component.scss | 56 - .../trafficlight/traffic-light-widget.component.ts | 155 - .../widgets/wordcloud/wordcloud-config.ts | 65 - .../wordcloud/wordcloud-widget.component.html | 39 - .../wordcloud/wordcloud-widget.component.scss | 45 - .../wordcloud/wordcloud-widget.component.ts | 171 - ui/src/app/dashboard/dashboard.module.ts | 88 +- .../add-visualization-dialog.component.html | 138 - .../add-visualization-dialog.component.ts | 293 - .../clone-dashboard-dialog.component.html | 158 + .../clone-dashboard-dialog.component.scss} | 4 + .../clone-dashboard-dialog.component.ts | 130 + .../edit-dashboard-dialog.component.html | 141 +- .../edit-dashboard-dialog.component.scss | 13 +- .../edit-dashboard-dialog.component.ts | 127 +- ui/src/app/dashboard/models/multi-series.model.ts | 27 - .../dashboard/registry/widget-config-builder.ts | 276 - ui/src/app/dashboard/registry/widget-registry.ts | 80 - .../dashboard/sdk/collected-schema-requirements.ts | 42 - ui/src/app/dashboard/sdk/ep-requirements.ts | 118 - .../sdk/extractor/static-property-extractor.ts | 109 - .../app/dashboard/sdk/matching/datatype-match.ts | 48 - .../sdk/matching/domain-property-match.ts | 34 - .../dashboard/sdk/matching/list-property-match.ts | 32 - .../sdk/matching/mapping-property-generator.ts | 46 - .../sdk/matching/primitive-property-match.ts | 40 - .../app/dashboard/sdk/matching/property-match.ts | 41 - ui/src/app/dashboard/sdk/matching/schema-match.ts | 29 - .../dashboard/sdk/schema-requirements-builder.ts | 102 - .../services/refresh-dashboard.service.ts | 29 - .../color-mapping-options-config.component.html | 154 + .../color-mapping-options-config.component.ts | 152 + .../data-zoom-config.component.html | 14 +- .../data-zoom-config/data-zoom-config.component.ts | 3 +- ...echarts-widget-appearance-config.component.html | 8 +- .../echarts-widget-appearance-config.component.ts | 7 +- .../select-axis-options-config.component.html} | 6 +- .../select-axis-options-config.component.scss} | 0 .../select-axis-options-config.component.ts} | 11 +- .../select-color-properties-config.component.html} | 10 +- .../select-color-properties-config.component.scss} | 0 .../select-color-properties-config.component.ts} | 15 +- .../time-series-item-config.component.html | 32 +- .../time-series-item-config.component.scss | 0 .../time-series-item-config.component.ts | 5 +- ...lect-multiple-properties-config.component.html} | 8 +- ...lect-multiple-properties-config.component.scss} | 2 +- ...select-multiple-properties-config.component.ts} | 23 +- .../select-single-property-config.component.html} | 0 .../select-single-property-config.component.ts} | 9 +- .../visualization-config-outer.component.html | 7 +- .../visualization-config-outer.component.ts | 1 + .../components/chart-container/chart.directive.ts} | 3 +- .../data-explorer-chart-container.component.html | 173 + .../data-explorer-chart-container.component.scss} | 17 +- .../data-explorer-chart-container.component.ts} | 53 +- .../base/base-data-explorer-widget.directive.ts | 51 +- .../components/charts}/base/base-widget-config.ts | 4 +- .../charts}/base/echarts-widget.component.html | 0 .../charts}/base/echarts-widget.component.scss | 0 .../charts}/base/echarts-widget.component.ts | 42 +- .../invalid-configuration.component.html | 8 +- .../invalid-configuration.component.ts | 1 + .../no-data/no-data-in-date-range.component.html | 4 +- .../no-data/no-data-in-date-range.component.scss | 0 .../no-data/no-data-in-date-range.component.ts | 1 + .../too-much-data/too-much-data.component.html | 13 +- .../too-much-data/too-much-data.component.scss | 0 .../base}/too-much-data/too-much-data.component.ts | 1 + .../correlation-chart-widget-config.component.html | 50 +- .../correlation-chart-widget-config.component.ts | 1 + .../model/correlation-chart-widget.model.ts | 2 + .../charts}/density/density-renderer.service.ts | 28 +- .../config/gauge-widget-config.component.html | 27 +- .../gauge/config/gauge-widget-config.component.ts | 5 +- .../charts}/gauge/gauge-renderer.service.ts | 2 +- .../charts}/gauge/model/gauge-widget.model.ts | 6 +- .../config/heatmap-widget-config.component.html} | 55 +- .../config/heatmap-widget-config.component.ts | 24 +- .../charts}/heatmap/heatmap-renderer.service.ts | 18 +- .../charts}/heatmap/model/heatmap-widget.model.ts | 2 + .../histogram-chart-widget-config.component.html | 24 +- .../histogram-chart-widget-config.component.ts | 2 +- .../histogram/histogram-renderer.service.ts | 0 .../model/histogram-chart-widget.model.ts | 0 .../config/image-widget-config.component.html | 6 +- .../config/image-widget-config.component.scss | 0 .../image/config/image-widget-config.component.ts | 2 +- .../image-bar-preview.component.html | 0 .../image-bar-preview.component.scss | 0 .../image-bar-preview.component.ts | 1 + .../image/image-bar/image-bar.component.html | 0 .../image/image-bar/image-bar.component.scss | 0 .../charts}/image/image-bar/image-bar.component.ts | 1 + .../image-container/image-container.component.html | 0 .../image-container/image-container.component.scss | 0 .../image-container/image-container.component.ts | 1 + .../image/image-viewer/image-viewer.component.html | 0 .../image/image-viewer/image-viewer.component.scss | 0 .../image/image-viewer/image-viewer.component.ts | 1 + .../charts}/image/image-widget.component.html | 0 .../charts}/image/image-widget.component.scss | 0 .../charts}/image/image-widget.component.ts | 9 +- .../charts}/image/model/image-widget.model.ts | 0 .../indicator-chart-widget-config.component.html | 10 +- .../indicator-chart-widget-config.component.ts | 1 + .../indicator/indicator-renderer.service.ts | 0 .../model/indicator-chart-widget.model.ts | 0 .../map/config/map-widget-config.component.html | 53 +- .../map/config/map-widget-config.component.ts | 14 +- .../charts}/map/map-widget.component.html | 0 .../charts}/map/map-widget.component.scss | 0 .../components/charts}/map/map-widget.component.ts | 53 +- .../charts}/map/model/map-widget.model.ts | 0 .../config/pie-chart-widget-config.component.html | 109 + .../config/pie-chart-widget-config.component.ts | 64 +- .../charts}/pie/model/pie-chart-widget.model.ts | 5 +- .../components/charts}/pie/pie-renderer.service.ts | 56 +- .../charts}/scatter/scatter-renderer.service.ts | 16 + .../status-heatmap-widget-config.component.html} | 36 +- .../status-heatmap-widget-config.component.ts} | 37 +- .../model/status-heatmap-widget.model.ts} | 17 +- .../status-heatmap-renderer.service.ts | 204 + .../config/status-widget-config.component.html | 47 +- .../config/status-widget-config.component.scss | 0 .../config/status-widget-config.component.ts | 7 +- .../charts}/status/model/status-widget.model.ts | 2 +- .../charts}/status/status-widget.component.html | 4 +- .../charts}/status/status-widget.component.scss | 0 .../charts}/status/status-widget.component.ts | 3 +- .../config/table-widget-config.component.html | 10 +- .../config/table-widget-config.component.scss | 0 .../table/config/table-widget-config.component.ts | 5 +- .../charts}/table/model/table-widget.model.ts | 0 .../charts}/table/table-widget.component.html | 4 +- .../charts}/table/table-widget.component.scss | 2 - .../charts}/table/table-widget.component.ts | 6 +- .../time-series-appearance-config.component.html | 0 .../time-series-appearance-config.component.ts | 5 +- .../time-series-chart-widget-config.component.html | 22 +- .../time-series-chart-widget-config.component.ts | 5 +- .../model/time-series-chart-widget.model.ts | 0 .../sp-timeseries-renderer.service.ts | 0 .../traffic-light-widget-config.component.html | 30 +- .../traffic-light-widget-config.component.scss | 0 .../traffic-light-widget-config.component.ts | 21 +- .../model/traffic-light-widget.model.ts | 2 +- .../traffic-light-widget.component.html | 0 .../traffic-light-widget.component.scss | 0 .../traffic-light-widget.component.ts | 1 + ...alue-heatmap-chart-widget-config.component.html | 12 +- .../value-heatmap-chart-widget-config.component.ts | 1 + .../model/value-heatmap-chart-widget.model.ts | 0 .../value-heatmap-renderer.service.ts | 7 +- .../data-explorer-shared.module.ts | 195 + .../echarts-renderer/base-echarts-renderer.ts | 0 .../base-single-field-echarts-renderer.ts | 16 +- .../echarts-axis-generator.service.ts | 0 .../echarts-basic-options-generator.service.ts | 0 .../echarts-dataset-generator.service.ts | 0 .../echarts-dataset-utils.service.ts | 0 .../echarts-grid-generator.service.ts | 0 .../echarts-renderer/echarts-utils.service.ts | 0 .../models/dataset.model.ts | 0 .../models/dataview-dashboard.model.ts | 23 +- .../models/field-update.model.ts | 0 .../models/gridster-info.model.ts | 6 - .../registry/data-explorer-chart-registry.ts | 299 + .../services/chart-configuration.service.ts} | 2 +- .../services/chart-type.service.ts} | 12 +- .../services/color-mapping.service.ts | 41 +- .../services/data-explorer-colorization.service.ts | 0 .../data-explorer-field-provider-service.ts | 3 + .../data-explorer-panel.can-deactivate.guard.ts | 2 +- .../services/data-explorer-routing.service.ts | 24 +- .../services/data-explorer-shared.service.ts | 121 + .../services/field-update.service.ts | 0 .../services/resize-echarts.service.ts} | 10 +- .../services/resize.service.ts | 2 +- .../data-explorer-chart-view.component.html | 100 + .../data-explorer-chart-view.component.scss} | 5 +- .../data-explorer-chart-view.component.ts | 367 + ...lorer-widget-appearance-settings.component.html | 104 + ...orer-widget-appearance-settings.component.scss} | 7 +- ...xplorer-widget-appearance-settings.component.ts | 61 +- .../data-explorer-designer-panel.component.html | 21 +- .../data-explorer-designer-panel.component.scss | 2 - .../data-explorer-designer-panel.component.ts | 1 + .../aggregate-configuration.component.html | 4 +- .../aggregate-configuration.component.scss | 0 .../aggregate-configuration.component.ts | 22 +- ...ta-explorer-widget-data-settings.component.html | 110 +- ...ta-explorer-widget-data-settings.component.scss | 6 +- ...data-explorer-widget-data-settings.component.ts | 19 +- .../field-selection-panel.component.html | 26 +- .../field-selection-panel.component.scss | 0 .../field-selection-panel.component.ts | 7 +- .../field-selection/field-selection.component.html | 31 +- .../field-selection/field-selection.component.scss | 0 .../field-selection/field-selection.component.ts | 5 +- .../escape-number-filter.service.ts | 62 + .../filter-selection-panel-row.component.html | 58 + .../filter-selection-panel-row.component.ts} | 29 +- ...on-panel-row-operation-selection.component.html | 46 + ...ion-panel-row-operation-selection.component.ts} | 22 +- ...on-panel-row-property-selection.component.html} | 26 +- ...tion-panel-row-property-selection.component.ts} | 29 +- ...on-panel-row-value-autocomplete.component.html} | 45 +- ...tion-panel-row-value-autocomplete.component.ts} | 46 +- ...selection-panel-row-value-input.component.html} | 20 +- ...er-selection-panel-row-value-input.component.ts | 56 + .../filter-selection-panel.component.html} | 51 +- .../filter-selection-panel.component.ts | 16 +- .../group-selection-panel.component.html | 10 +- .../group-selection-panel.component.ts | 7 +- .../order-selection-panel.component.html | 6 +- .../order-selection-panel.component.scss | 0 .../order-selection-panel.component.ts | 5 +- ...-explorer-visualisation-settings.component.html | 10 +- ...explorer-visualisation-settings.component.scss} | 7 +- ...ta-explorer-visualisation-settings.component.ts | 15 +- ...ata-explorer-chart-view-toolbar.component.html} | 33 +- .../data-explorer-chart-view-toolbar.component.ts} | 34 +- .../dashboard-toolbar.component.html | 136 - .../data-explorer-dashboard-panel.component.html | 97 - .../data-explorer-dashboard-panel.component.ts | 317 - .../data-explorer-data-view.component.html | 84 - .../data-view/data-explorer-data-view.component.ts | 215 - ...lorer-widget-appearance-settings.component.html | 70 - ...lorer-widget-appearance-settings.component.scss | 17 - .../filter-selection-panel.component.html | 164 - ...-explorer-visualisation-settings.component.scss | 17 - ...data-explorer-dashboard-overview.component.html | 120 - .../data-explorer-dashboard-overview.component.ts | 142 - ...data-explorer-data-view-overview.component.html | 114 - .../data-explorer-data-view-overview.component.ts | 115 - .../data-explorer-overview-table.component.html | 125 + .../data-explorer-overview-table.component.ts | 148 + .../overview/data-explorer-overview.component.html | 27 +- .../overview/data-explorer-overview.component.ts | 58 +- .../overview/data-explorer-overview.directive.ts | 14 +- .../data-explorer-dashboard-grid.component.html | 49 - .../data-explorer-dashboard-widget.component.html | 168 - .../config/pie-chart-widget-config.component.html | 184 - .../components/widgets/utils/color-utils.ts | 41 - .../group-configuration.component.html | 56 - .../group-configuration.component.scss | 17 - .../group-configuration.component.ts | 66 - .../load-data-spinner.component.html | 22 - .../load-data-spinner.component.scss | 17 - .../load-data-spinner.component.ts | 28 - .../select-property/select-property.component.scss | 17 - ui/src/app/data-explorer/data-explorer.module.ts | 181 +- .../dialog/asset-dialog.component.html | 69 + .../data-explorer/dialog/asset-dialog.component.ts | 71 + ...a-explorer-edit-dashboard-dialog.component.html | 99 - ...a-explorer-edit-dashboard-dialog.component.scss | 43 - ...ata-explorer-edit-dashboard-dialog.component.ts | 69 - .../registry/data-explorer-widget-registry.ts | 226 - .../services/data-explorer-dashboard.service.ts | 81 - .../app/data-explorer/services/resize.service.ts | 30 - .../custom-output-strategy.component.html | 20 +- .../custom-output-strategy.component.ts | 1 + .../output-strategy/output-strategy.component.html | 2 +- .../output-strategy/output-strategy.component.ts | 1 + .../property-selection.component.ts | 1 + .../user-defined-output.component.html | 12 +- .../user-defined-output.component.ts | 1 + ...e-assembly-drawing-area-pan-zoom.component.scss | 2 +- ...ine-assembly-drawing-area-pan-zoom.component.ts | 9 +- .../pipeline-assembly-drawing-area.component.ts | 51 +- ...-assembly-options-pipeline-cache.component.html | 18 +- ...-assembly-options-pipeline-cache.component.scss | 4 + ...ne-assembly-options-pipeline-cache.component.ts | 1 + .../pipeline-assembly-options.component.html | 47 +- .../pipeline-assembly-options.component.ts | 2 +- .../pipeline-assembly.component.html | 5 +- .../pipeline-assembly.component.scss | 4 +- .../pipeline-assembly.component.ts | 28 +- .../pipeline-element-icon-stand-row.component.html | 2 +- .../pipeline-element-icon-stand-row.component.ts | 1 + .../pipeline-element-icon-stand.component.html | 10 +- .../pipeline-element-icon-stand.component.scss | 12 +- .../pipeline-element-icon-stand.component.ts | 1 + .../pipeline-element-options.component.html | 10 +- .../pipeline-element-options.component.scss | 6 +- .../pipeline-element-options.component.ts | 3 +- .../pipeline-element-preview.component.html | 4 +- .../pipeline-element-preview.component.ts | 7 +- ...ipeline-element-statistics-badge.component.scss | 4 +- .../pipeline-element-statistics-badge.component.ts | 1 + .../pipeline-element-statistics.component.ts | 1 + .../dropped-pipeline-element.component.ts | 1 + .../components/pipeline/pipeline.component.html | 2 +- .../components/pipeline/pipeline.component.scss | 4 +- .../components/pipeline/pipeline.component.ts | 1 + .../add-template-dialog.component.html | 11 +- .../add-template-dialog.component.ts | 1 + .../template-selection.component.ts | 1 + .../compatible-elements.component.html | 4 +- .../compatible-elements.component.scss | 2 - .../compatible-elements.component.ts | 9 +- .../dialog/customize/customize.component.html | 31 +- .../dialog/customize/customize.component.scss | 2 - .../editor/dialog/customize/customize.component.ts | 1 + .../matching-error/matching-error.component.html | 25 +- .../matching-error/matching-error.component.scss | 19 - .../matching-error/matching-error.component.ts | 2 +- .../missing-elements-for-tutorial.component.html | 21 +- .../missing-elements-for-tutorial.component.scss | 19 - .../missing-elements-for-tutorial.component.ts | 2 +- .../pipeline-element-discovery.component.html | 2 +- .../pipeline-element-discovery.component.scss | 2 - .../pipeline-element-discovery.component.ts | 9 +- .../save-pipeline-settings.component.html | 118 +- .../save-pipeline-settings.component.ts | 62 +- .../save-pipeline/save-pipeline.component.html | 20 +- .../save-pipeline/save-pipeline.component.scss | 2 - .../save-pipeline/save-pipeline.component.ts | 99 +- ui/src/app/editor/editor.component.html | 2 +- ui/src/app/editor/editor.component.scss | 4 +- ui/src/app/editor/editor.component.ts | 11 +- ui/src/app/editor/editor.module.ts | 16 +- .../filter/enabled-pipeline-element.filter.ts | 1 + ui/src/app/editor/services/editor.service.ts | 17 +- .../app/editor/services/object-provider.service.ts | 16 +- .../services/pipeline-element-group-filter.pipe.ts | 5 +- .../services/pipeline-element-name-filter.pipe.ts | 5 +- .../services/pipeline-element-type-filter.pipe.ts | 5 +- ui/src/app/editor/utils/style-sanitizer.ts | 5 +- ui/src/app/home/components/status.component.scss | 13 +- ui/src/app/home/components/status.component.ts | 1 + .../welcome-tour/welcome-tour.component.html | 6 +- .../welcome-tour/welcome-tour.component.scss | 2 - .../dialog/welcome-tour/welcome-tour.component.ts | 1 + ui/src/app/home/home.component.html | 6 +- ui/src/app/home/home.component.scss | 14 +- ui/src/app/home/home.component.ts | 1 + ui/src/app/home/home.module.ts | 12 + ui/src/app/info/info.component.ts | 1 + ui/src/app/info/versions/versions.component.ts | 1 + .../activate-account/activate-account.component.ts | 15 +- .../components/auth-box/auth-box.component.html | 4 +- .../components/auth-box/auth-box.component.scss | 2 +- .../components/auth-box/auth-box.component.ts | 1 + .../login/components/base-login-page.directive.ts | 6 +- .../login/components/login/login.component.html | 197 +- .../app/login/components/login/login.component.ts | 34 +- ui/src/app/login/components/login/login.model.ts | 3 + .../components/register/register.component.html | 24 +- .../components/register/register.component.ts | 11 +- .../restore-password.component.html | 28 +- .../restore-password/restore-password.component.ts | 11 +- .../set-new-password.component.html | 2 +- .../set-new-password/set-new-password.component.ts | 17 +- .../login/components/setup/setup.component.html | 4 +- .../app/login/components/setup/setup.component.ts | 20 +- .../components/startup/startup.component.scss | 4 +- .../login/components/startup/startup.component.ts | 1 + .../login/components/terms/terms.component.html | 46 + .../components/terms/terms.component.scss} | 42 +- .../app/login/components/terms/terms.component.ts | 102 + ui/src/app/login/login.module.ts | 4 + ui/src/app/login/services/login.service.ts | 16 +- .../components/notification-item.component.html | 2 +- .../components/notification-item.component.scss | 4 +- .../components/notification-item.component.ts | 1 + .../app/notifications/notifications.component.html | 10 +- .../app/notifications/notifications.component.scss | 10 +- .../app/notifications/notifications.component.ts | 5 +- ui/src/app/notifications/notifications.module.ts | 2 + .../actions/pipeline-actions.component.html | 16 +- .../actions/pipeline-actions.component.ts | 1 + ...pipeline-details-expansion-panel.component.html | 6 +- .../pipeline-details-expansion-panel.component.ts | 1 + .../elements/pipeline-elements-row.component.ts | 1 + .../pipeline-element-details-row.component.html | 2 +- .../pipeline-element-details-row.component.ts | 1 + .../status/pipeline-status.component.html | 2 +- .../status/pipeline-status.component.scss | 2 +- .../status/pipeline-status.component.ts | 1 + .../pipeline-details-toolbar.component.html | 18 +- .../pipeline-details-toolbar.component.ts | 1 + .../preview/pipeline-preview.component.ts | 1 + .../pipeline-code-dialog.component.html | 9 +- .../pipeline-code-dialog.component.ts | 1 + .../pipeline-logs-dialog.component.html | 13 +- .../pipeline-logs-dialog.component.ts | 1 + .../pipeline-details.component.html | 6 + .../pipeline-details/pipeline-details.component.ts | 36 +- .../pipeline-details/pipeline-details.module.ts | 2 + .../functions-logs/functions-logs.component.ts | 1 + .../functions-metrics.component.ts | 1 + .../functions-overview.component.ts | 1 + .../pipeline-overview.component.html | 220 +- .../pipeline-overview.component.ts | 8 +- .../delete-pipeline-dialog.component.html | 24 +- .../delete-pipeline-dialog.component.scss | 19 - .../delete-pipeline-dialog.component.ts | 22 +- .../pipeline-notifications.component.html | 9 +- .../pipeline-notifications.component.scss | 3 - .../pipeline-notifications.component.ts | 1 + .../pipeline-status-dialog.component.html | 36 +- .../pipeline-status-dialog.component.scss | 3 - .../pipeline-status-dialog.component.ts | 17 +- .../start-all-pipelines-dialog.component.html | 49 +- .../start-all-pipelines-dialog.component.scss | 19 - .../start-all-pipelines-dialog.component.ts | 41 +- ui/src/app/pipelines/pipelines.component.html | 24 +- ui/src/app/pipelines/pipelines.component.ts | 11 +- ui/src/app/pipelines/pipelines.module.ts | 4 + .../profile/components/basic-profile-settings.ts | 12 +- .../general-profile-settings.component.html | 51 +- .../general/general-profile-settings.component.ts | 8 + .../token/token-management-settings.component.html | 57 +- .../token/token-management-settings.component.ts | 1 + .../change-email-dialog.component.html | 6 +- .../change-email-dialog.component.scss | 2 - .../change-email/change-email-dialog.component.ts | 1 + .../change-password-dialog.component.html | 6 +- .../change-password-dialog.component.scss | 2 - .../change-password-dialog.component.ts | 1 + ui/src/app/profile/profile.component.html | 16 +- ui/src/app/profile/profile.component.ts | 1 + ui/src/app/profile/profile.module.ts | 4 + ui/src/app/services/rest-api.service.ts | 53 - ui/src/app/services/secure.pipe.ts | 1 + ui/src/assets/federation.manifest.json | 1 - ui/src/assets/img/car.png | Bin 0 -> 7166 bytes ui/src/federation.config.js | 57 - ui/src/main.ts | 8 +- ui/src/scss/custom-theme/.gitkeep | 0 ui/src/scss/main.scss | 87 +- ui/{deployment => src/scss/sp}/_variables.scss | 99 +- ui/src/scss/sp/buttons-mat3.scss | 96 + ui/src/scss/sp/buttons.ng1.scss | 162 - ui/src/scss/sp/buttons.scss | 151 - ui/src/scss/sp/colors.scss | 16 +- ui/src/scss/sp/dialog.ng5.scss | 22 - ui/src/scss/sp/dialog.scss | 9 +- ui/src/scss/sp/documentation.ng1.scss | 4 +- ui/src/scss/sp/feedback.ng1.scss | 59 - .../scss/sp/forms-mat3.scss} | 32 +- ui/src/scss/sp/layout.scss | 10 +- ui/src/scss/sp/main.scss | 61 +- ui/src/scss/sp/pipeline-element-options.scss | 12 +- ui/src/scss/sp/pipeline-validation.scss | 2 - ui/src/scss/sp/progress-bar.scss | 23 - ui/src/scss/sp/shepherd-new.scss | 9 +- ui/src/scss/sp/sp-theme.scss | 289 +- ui/src/scss/sp/spinner.scss | 4 +- ui/src/scss/sp/widgets.scss | 2 +- ui/tsconfig.json | 5 +- 2081 files changed, 65273 insertions(+), 38792 deletions(-)
