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 9566748c08834e0958185da25175d8e82ae423a5 Merge: 42222da46 127806444 Author: Philipp Zehnder <[email protected]> AuthorDate: Fri Jun 16 08:44:50 2023 +0200 [release] Release 0.92.0 .github/ISSUE_TEMPLATE/bug_report.yml | 2 +- .github/release.yml | 13 +- .github/workflows/build.yml | 8 +- .github/workflows/cypress-test.yml | 7 +- .github/workflows/osv-scanner.yml | 55 + .github/workflows/pr-labeler.yml | 10 +- .github/workflows/pr-validation.yml | 56 +- .github/workflows/pypi-deployment.yml | 4 +- .github/workflows/python-docs.yml | 7 +- .github/workflows/stale-bot.yml | 39 + README.md | 9 +- RELEASE_NOTES.md | 131 + VULNERABILITY.md | 32 + .../streampipes-archetype-extensions-jvm/pom.xml | 2 +- .../src/main/resources/archetype-resources/pom.xml | 2 +- .../archetype-resources/src/main/java/Init.java | 30 +- .../__classNamePrefix__DataProcessor.java | 39 +- .../__classNamePrefix__DataSink.java | 25 +- .../pom.xml | 2 +- .../src/main/resources/archetype-resources/pom.xml | 2 +- .../streampipes-archetype-pe-sinks-flink/pom.xml | 2 +- .../src/main/resources/archetype-resources/pom.xml | 2 +- create-client-model.sh | 44 +- docker-compose.yml | 2 +- installer/.gitignore | 2 + installer/cli/.env | 6 +- installer/cli/README.md | 2 +- .../extensions-all-jvm/docker-compose.dev.yml | 4 +- .../extensions-all-jvm/docker-compose.yml | 1 - .../deploy/standalone/ui-custom-conf}/default.conf | 36 +- .../ui-custom-conf/docker-compose.dev.yml} | 14 +- .../{ui => ui-custom-conf}/docker-compose.yml | 7 +- .../cli/deploy/standalone/ui/docker-compose.yml | 2 +- installer/cli/environments/backend | 4 +- installer/cli/environments/backend-nats | 3 +- installer/cli/environments/pipeline-element | 2 - installer/cli/environments/pipeline-element-nats | 2 - installer/compose/.env | 2 +- installer/compose/README.md | 2 +- installer/compose/docker-compose.full.yml | 2 +- installer/compose/docker-compose.nats.yml | 2 +- installer/compose/docker-compose.yml | 2 +- installer/k8s/Chart.yaml | 4 +- installer/k8s/README.md | 2 +- .../k8s/templates/core/backend-deployment.yaml | 27 +- installer/k8s/templates/core/backend-pv-pvc.yaml | 42 - .../backend-pvc.yaml} | 22 +- installer/k8s/templates/core/backend-service.yaml | 8 +- installer/k8s/templates/core/ui-configmap.yaml | 51 + .../templates/core/{ui.yaml => ui-deployment.yaml} | 28 +- installer/k8s/templates/core/ui-ingress.yaml | 25 +- installer/k8s/templates/core/ui-ingressroute.yaml | 46 + installer/k8s/templates/core/ui-service.yaml | 10 +- ...nt.yaml => extensions-all-iiot-deployment.yaml} | 10 +- ...rvice.yaml => extensions-all-iiot-service.yaml} | 6 +- .../pipeline-elements-all-flink-deployment.yaml | 37 - .../external/consul/consul-deployment.yaml | 16 +- .../templates/external/consul/consul-pv-pvc.yaml | 22 +- .../templates/external/consul/consul-service.yaml | 6 +- .../external/couchdb/couchdb-deployment.yaml | 20 +- .../templates/external/couchdb/couchdb-pv-pvc.yaml | 22 +- .../external/couchdb/couchdb-service.yaml | 6 +- .../external/flink/jobmanager-deployment.yaml | 46 - .../external/flink/jobmanager-service.yaml | 34 - .../external/flink/taskmanager-deployment.yaml | 43 - .../external/influxdb/influxdb-deployment.yaml | 34 +- .../templates/external/influxdb/influxdb-pvc.yaml | 20 +- .../external/influxdb/influxdb-service.yaml | 4 +- .../templates/external/influxdb/influxdb2-pvc.yaml | 21 +- .../templates/external/nats/nats-deployment.yaml | 8 +- .../k8s/templates/external/nats/nats-service.yaml | 2 + installer/k8s/values.yaml | 96 +- pom.xml | 118 +- streampipes-client-python/Makefile | 1 + streampipes-client-python/README.md | 33 +- .../docs/getting-started/first-steps.md | 12 +- .../docs/img/interrogate_badge.svg | 55 + .../docs/img/streampipes-python-dark.png | Bin 0 -> 116009 bytes streampipes-client-python/docs/index.md | 8 +- .../docs/overrides/404.html | 26 +- ...cting-data-from-the-streampipes-data-lake.ipynb | 4 +- ...ive-data-from-the-streampipes-data-stream.ipynb | 21 +- ...ine-learning-on-a-streampipes-data-stream.ipynb | 18 +- streampipes-client-python/mkdocs.yml | 16 + streampipes-client-python/setup.py | 38 +- .../streampipes/__version__.py | 2 +- .../streampipes/client/client.py | 59 +- .../streampipes/endpoint/api/__init__.py | 2 + .../streampipes/endpoint/api/data_lake_measure.py | 14 +- .../streampipes/endpoint/api/data_stream.py | 7 +- .../streampipes/endpoint/api/version.py | 130 + .../streampipes/function_zoo/river_function.py | 8 +- .../streampipes/functions/broker/__init__.py | 19 +- .../streampipes/functions/broker/broker.py | 48 +- .../streampipes/functions/broker/broker_handler.py | 51 +- .../streampipes/functions/broker/consumer.py | 65 + .../streampipes/functions/broker/kafka/__init__.py | 4 - .../{kafka_broker.py => kafka/kafka_consumer.py} | 38 +- .../broker/{ => kafka}/kafka_message_fetcher.py | 4 +- .../{nats_broker.py => kafka/kafka_publisher.py} | 45 +- .../streampipes/functions/broker/nats/__init__.py | 4 - .../{nats_broker.py => nats/nats_consumer.py} | 31 +- .../{nats_broker.py => nats/nats_publisher.py} | 34 +- .../functions/broker/output_collector.py | 14 +- .../streampipes/functions/broker/publisher.py | 30 +- .../streampipes/functions/function_handler.py | 5 +- .../functions/utils/async_iter_handler.py | 2 +- .../functions/utils/data_stream_context.py | 8 +- .../functions/utils/data_stream_generator.py | 38 +- .../streampipes/model/container/__init__.py | 2 + .../streampipes/model/container/versions.py | 55 + .../streampipes/model/resource/__init__.py | 6 +- .../{data_lake_series.py => data_series.py} | 31 +- .../streampipes/model/resource/exceptions.py | 19 +- .../streampipes/model/resource/query_result.py | 89 + .../{container/__init__.py => resource/version.py} | 29 +- .../streampipes/py.typed | 5 +- .../tests/client/test_client.py | 42 +- .../tests/client/test_data_lake_series.py | 201 +- .../tests/client/test_endpoint.py | 82 +- .../tests/functions/test_function_handler.py | 327 +- .../tests/functions/test_river_function.py | 32 +- streampipes-client/pom.xml | 25 +- .../client/api/AbstractTypedClientApi.java | 14 +- .../org/apache/streampipes/client/api/CRUDApi.java | 3 +- .../streampipes/client/api/DataLakeMeasureApi.java | 3 +- .../streampipes/client/api/DataProcessorApi.java | 6 +- .../apache/streampipes/client/api/DataSinkApi.java | 6 +- .../streampipes/client/api/DataStreamApi.java | 6 +- .../apache/streampipes/client/api/PipelineApi.java | 10 +- .../client/api/PipelineElementTemplateApi.java | 3 +- .../streampipes/client/http/HttpRequest.java | 18 +- streampipes-commons/pom.xml | 2 +- .../apache/streampipes/commons/constants/Envs.java | 2 + .../commons/environment/DefaultEnvironment.java | 5 + .../commons/environment/Environment.java | 2 + .../commons/exceptions/SpHttpErrorStatusCode.java | 27 +- streampipes-config/pom.xml | 10 +- .../streampipes/config/backend/BackendConfig.java | 15 +- streampipes-connect-management/pom.xml | 12 +- streampipes-data-explorer-commons/pom.xml | 10 +- .../commons/configs/CouchDbConfigurations.java | 35 - .../commons/configs/CouchDbEnvKeys.java | 25 - .../configs/DataExplorerConfigurations.java | 46 - .../commons/configs/DataExplorerEnvKeys.java | 28 - .../dataexplorer/commons/influx/InfluxStore.java | 16 +- streampipes-data-explorer/pom.xml | 10 +- .../dataexplorer/DataExplorerQueryManagement.java | 142 + ...ntV3.java => DataExplorerSchemaManagement.java} | 93 +- .../dataexplorer/DataLakeManagementV4.java | 296 -- .../api/IDataExplorerQueryManagement.java | 47 + .../api/IDataExplorerSchemaManagement.java | 19 +- .../dataexplorer/api/IQueryStatement.java | 15 +- .../influx/DataExplorerInfluxQueryExecutor.java | 169 + .../influx/DataLakeInfluxQueryBuilder.java | 289 ++ ...licyQueryParams.java => DeleteQueryParams.java} | 40 +- .../param/ProvidedRestQueryParamConverter.java | 147 + .../ProvidedRestQueryParams.java} | 12 +- .../dataexplorer/param/SelectQueryParams.java | 140 + .../SupportedRestQueryParams.java} | 4 +- .../model/AggregationFunction.java} | 8 +- .../model/FillClauseParams.java} | 20 +- .../model/GroupByTagsClauseParams.java} | 24 +- .../model/GroupByTimeClauseParams.java} | 19 +- .../model/LimitClauseParams.java} | 19 +- .../model/OffsetClauseParams.java} | 19 +- .../model/OrderByClauseParams.java} | 20 +- .../model/SelectClauseParams.java} | 73 +- .../dataexplorer/param/model/SelectColumn.java | 111 + .../param/model/WhereClauseParams.java | 122 + .../{v4 => query}/AutoAggregationHandler.java | 69 +- .../dataexplorer/query/DataExplorerQuery.java | 94 - .../query/DataExplorerQueryBuilder.java | 61 - .../query/DataExplorerQueryExecutor.java | 107 + .../dataexplorer/query/DeleteDataQuery.java | 28 +- .../query/EditRetentionPolicyQuery.java | 77 - .../{v4 => }/query/QueryResultProvider.java | 28 +- .../query/ShowRetentionPolicyQuery.java | 58 - .../query/StreamedQueryResultProvider.java | 18 +- .../query/writer/ConfiguredCsvOutputWriter.java | 10 +- .../query/writer/ConfiguredJsonOutputWriter.java | 10 +- .../query/writer/ConfiguredOutputWriter.java | 8 +- .../{v4 => }/query/writer/OutputFormat.java | 2 +- .../{v4 => }/query/writer/item/CsvItemWriter.java | 2 +- .../{v4 => }/query/writer/item/ItemGenerator.java | 4 +- .../{v4 => }/query/writer/item/JsonItemWriter.java | 2 +- .../DataLakeQueryOrdering.java | 2 +- .../FilterCondition.java} | 24 +- .../querybuilder/IDataLakeQueryBuilder.java | 84 + .../dataexplorer/sdk/DataLakeQueryBuilder.java | 223 -- .../dataexplorer/template/QueryTemplates.java | 40 - .../dataexplorer/{v4 => }/utils/TimeParser.java | 2 +- .../v4/params/DeleteFromStatementParams.java | 31 - .../dataexplorer/v4/params/FillParams.java | 35 - .../dataexplorer/v4/params/SelectColumn.java | 93 - .../v4/params/WhereStatementParams.java | 119 - .../dataexplorer/v4/query/DataExplorerQueryV4.java | 248 -- .../dataexplorer/v4/query/QueryBuilder.java | 64 - .../v4/query/elements/DeleteFromStatement.java | 33 - .../v4/query/elements/FillStatement.java | 32 - .../v4/query/elements/GroupingByTime.java | 34 - .../v4/query/elements/ItemLimitation.java | 34 - .../v4/query/elements/OrderingByTime.java | 34 - .../v4/query/elements/QueryElement.java | 35 - .../v4/query/elements/SelectFromStatement.java | 51 - .../v4/query/elements/TimeBoundary.java | 40 - .../v4/query/elements/WhereStatement.java | 39 - .../dataexplorer/v4/template/QueryTemplatesV4.java | 89 - .../v4/utils/DataLakeManagementUtils.java | 163 - .../dataexplorer/param/SelectQueryParamsTest.java | 208 ++ .../param}/WhereStatementParamsTest.java | 27 +- .../writer/TestConfiguredCsvOutputWriter.java | 7 +- .../writer/TestConfiguredJsonOutputWriter.java | 7 +- .../query/writer/TestConfiguredOutputWriter.java | 2 +- .../query/writer/item/TestCsvItemWriter.java | 4 +- .../query/writer/item/TestItemWriter.java | 2 +- .../query/writer/item/TestJsonItemWriter.java | 4 +- .../sdk/DataLakeQueryBuilderTest.java} | 26 +- .../utils/ProvidedQueryParameterBuilder.java | 92 + streampipes-data-export/pom.xml | 10 +- .../export/resolver/PipelineResolver.java | 6 +- streampipes-dataformat-cbor/pom.xml | 6 +- streampipes-dataformat-fst/pom.xml | 6 +- streampipes-dataformat-json/pom.xml | 6 +- streampipes-dataformat-smile/pom.xml | 6 +- streampipes-dataformat/pom.xml | 4 +- streampipes-extensions-api/pom.xml | 6 +- streampipes-extensions-management/pom.xml | 34 +- .../adapter/format/util/JsonEventProperty.java | 35 +- .../value/CorrectionValueTransformationRule.java | 28 +- .../management/connect/adapter/TestUtils.java | 9 + .../format/json/object/JsonObjectParserTest.java | 12 + .../transform/value/CorrectionValueTest.java | 158 + streampipes-extensions/.github/workflows/build.yml | 587 --- streampipes-extensions/pom.xml | 6 +- .../streampipes-connect-adapters-iiot/pom.xml | 12 +- .../streampipes-connect-adapters/pom.xml | 10 +- .../streampipes-connectors-influx/pom.xml | 8 +- .../streampipes-extensions-all-iiot/pom.xml | 26 +- .../streampipes-extensions-all-jvm/pom.xml | 12 +- .../pom.xml | 18 +- .../streampipes-pipeline-elements-all-jvm/pom.xml | 28 +- .../pom.xml | 2 +- .../streampipes-pipeline-elements-shared/pom.xml | 10 +- .../pe/shared/config/mqtt/MqttConnectUtils.java | 6 +- .../pom.xml | 13 +- .../pom.xml | 6 +- .../streampipes-processors-enricher-flink/pom.xml | 6 +- .../streampipes-processors-enricher-jvm/pom.xml | 6 +- .../streampipes-processors-filters-jvm/pom.xml | 6 +- .../processors/filters/jvm/FiltersJvmInit.java | 4 +- .../processor/sdt/SwingingDoorTrendingFilter.java | 182 + .../sdt/SwingingDoorTrendingFilterProcessor.java | 133 + .../documentation.md | 79 + .../icon.png | Bin 0 -> 107607 bytes .../strings.en | 34 + .../streampipes-processors-filters-siddhi/pom.xml | 8 +- .../streampipes-processors-geo-flink/pom.xml | 6 +- .../streampipes-processors-geo-jvm/pom.xml | 8 +- .../streampipes/processors/geo/jvm/GeoJvmInit.java | 12 +- .../jvm/jts/exceptions/SpJtsGeoemtryException.java | 28 +- .../geo/jvm/jts/helper/buffer/BufferSide.java | 18 +- .../geo/jvm/jts/helper/buffer/CapStyle.java | 16 +- .../geo/jvm/jts/helper/buffer/JoinStyle.java | 15 +- .../geo/jvm/jts/helper/buffer/SpBufferBuilder.java | 124 + .../buffergeometry/BufferGeomProcessor.java | 224 ++ .../BufferPointProcessor.java} | 138 +- .../LatLngToJtsPointProcessor.java | 7 +- .../reprojection/ReprojectionProcessor.java | 8 +- .../trajectory/TrajectoryFromPointsProcessor.java | 16 +- .../jts/processor/validation/ValidationOutput.java | 7 +- .../jts/processor/validation/ValidationType.java | 7 +- .../complex/TopologyValidationProcessor.java} | 123 +- .../simple/GeometryValidationProcessor.java} | 131 +- .../HaversineDistanceCalculatorProcessor.java | 21 +- .../speedcalculator/SpeedCalculatorProcessor.java | 6 +- .../documentation.md | 89 + .../icon.png | Bin 0 -> 13109 bytes .../strings.en | 49 + .../documentation.md | 76 + .../icon.png | Bin 0 -> 15494 bytes .../output.png | Bin 0 -> 32372 bytes .../strings.en | 41 +- .../strings.en | 8 +- .../documentation.md | 80 + .../icon.png | Bin 0 -> 19690 bytes .../strings.en | 19 +- .../documentation.md | 74 + .../icon.png | Bin 0 -> 16986 bytes .../strings.en | 19 +- .../pom.xml | 12 +- .../jvm/ImageProcessingJvmInit.java | 16 +- .../processor/commons/ImagePropertyConstants.java | 56 + .../jvm/processor/commons/ImageTransformer.java | 35 +- .../processor/commons/PlainImageTransformer.java | 7 +- .../GenericImageClassificationController.java | 73 - .../GenericImageClassificationParameters.java | 35 - ...va => GenericImageClassificationProcessor.java} | 80 +- .../jvm/processor/imagecropper/ImageCropper.java | 76 - .../imagecropper/ImageCropperController.java | 67 - .../imagecropper/ImageCropperParameters.java | 29 - .../imagecropper/ImageCropperProcessor.java | 116 + .../imageenrichment/ImageEnrichmentController.java | 66 - .../imageenrichment/ImageEnrichmentParameters.java | 101 - ...Enricher.java => ImageEnrichmentProcessor.java} | 71 +- .../jvm/processor/qrreader/QrCodeReader.java | 98 - .../processor/qrreader/QrCodeReaderController.java | 77 - .../processor/qrreader/QrCodeReaderParameters.java | 48 - .../processor/qrreader/QrCodeReaderProcessor.java | 133 + .../pom.xml | 13 +- .../pom.xml | 6 +- .../pom.xml | 8 +- .../streampipes-processors-text-mining-jvm/pom.xml | 8 +- .../pom.xml | 10 +- .../pom.xml | 14 +- .../transformation/jvm/TransformationJvmInit.java | 20 +- .../booloperator/counter/BooleanCounter.java | 92 - .../counter/BooleanCounterController.java | 88 - .../counter/BooleanCounterParameters.java | 48 - .../counter/BooleanCounterProcessor.java | 140 + .../booloperator/inverter/BooleanInverter.java | 54 - .../inverter/BooleanInverterParameters.java | 35 - ...ntroller.java => BooleanInverterProcessor.java} | 40 +- .../stringoperator/counter/StringCounter.java | 79 - .../counter/StringCounterParameters.java | 36 - ...Controller.java => StringCounterProcessor.java} | 201 +- .../stringoperator/state/StringToState.java | 59 - .../state/StringToStateParameters.java | 42 - ...Controller.java => StringToStateProcessor.java} | 172 +- .../stringoperator/timer/StringTimer.java | 79 - .../timer/StringTimerParameters.java | 48 - ...erController.java => StringTimerProcessor.java} | 252 +- .../counter/TestBooleanCounterProcessor.java | 177 + .../inverter/TestBooleanInverterProcessor.java | 159 + .../counter/TestStringCounterProcessor.java | 182 + .../state/TestStringToStateProcessor.java | 207 ++ .../timer/TestStringTimerProcessor.java | 213 ++ .../streampipes-sinks-brokers-jvm/pom.xml | 12 +- .../sinks/brokers/jvm/BrokersJvmInit.java | 4 +- .../sinks/brokers/jvm/kafka/KafkaController.java | 91 - .../sinks/brokers/jvm/kafka/KafkaParameters.java | 56 +- .../sinks/brokers/jvm/kafka/KafkaPublishSink.java | 118 + .../sinks/brokers/jvm/kafka/KafkaPublisher.java | 86 - .../sinks/brokers/jvm/mqtt/MqttClient.java | 4 +- .../streampipes-sinks-databases-flink/pom.xml | 6 +- .../streampipes-sinks-databases-jvm/pom.xml | 6 +- .../streampipes-sinks-internal-jvm/pom.xml | 10 +- .../sinks/internal/jvm/SinksInternalJvmInit.java | 4 - .../streampipes-sinks-notifications-jvm/pom.xml | 8 +- .../streampipes-sources-vehicle-simulator/pom.xml | 10 +- .../pom.xml | 10 +- streampipes-integration-tests/pom.xml | 20 +- .../integration/adapters/AdapterTesterBase.java | 3 +- .../integration/adapters/AdaptersTest.java | 7 + .../integration/adapters/MqttAdapterTester.java | 129 + .../integration/containers/MosquittoContainer.java | 54 + .../containers/MosquittoDevContainer.java | 16 +- .../src/test/resources/mosquitto.conf | 7 +- streampipes-logging/pom.xml | 2 +- streampipes-mail/pom.xml | 6 +- .../template/AccountActiviationMailTemplate.java | 6 - .../streampipes/mail/template/part/LogoPart.java | 2 +- streampipes-maven-plugin/pom.xml | 15 +- streampipes-measurement-units/pom.xml | 4 +- streampipes-messaging-jms/pom.xml | 4 +- streampipes-messaging-kafka/pom.xml | 6 +- .../messaging/kafka/SpKafkaProducer.java | 4 +- streampipes-messaging-mqtt/pom.xml | 4 +- streampipes-messaging-nats/pom.xml | 4 +- streampipes-messaging/pom.xml | 4 +- streampipes-model-client/pom.xml | 6 +- streampipes-model-shared/pom.xml | 2 +- streampipes-model/pom.xml | 10 +- .../streampipes/model/datalake/DataSeries.java | 15 + .../{DataSeries.java => DataSeriesBuilder.java} | 52 +- .../streampipes/model/datalake/PageResult.java | 1 + .../model/datalake/SpQueryResultBuilder.java | 73 + .../model/datalake/DataSeriesBuilderTest.java | 90 + .../model/datalake/SpQueryResultBuilderTest.java | 116 + streampipes-pipeline-management/pom.xml | 42 +- streampipes-platform-services/pom.xml | 12 +- .../streampipes/ps/DataLakeMeasureResourceV3.java | 57 - .../streampipes/ps/DataLakeMeasureResourceV4.java | 23 +- .../apache/streampipes/ps/DataLakeResourceV4.java | 100 +- streampipes-resource-management/pom.xml | 8 +- .../AbstractPipelineElementResourceManager.java | 9 +- streampipes-rest-core-base/pom.xml | 10 +- streampipes-rest-extensions/pom.xml | 8 +- streampipes-rest-shared/pom.xml | 6 +- .../shared/impl/AbstractSharedRestInterface.java | 7 +- streampipes-rest/pom.xml | 53 +- .../apache/streampipes/rest/ResetManagement.java | 14 +- .../streampipes/rest/impl/PipelineResource.java | 134 +- .../org/apache/streampipes/rest/impl/Setup.java | 3 + .../apache/streampipes/rest/impl/UserResource.java | 32 +- .../org/apache/streampipes/rest/impl/Version.java | 3 + .../rest/impl/pe/DataProcessorResource.java | 12 +- .../streampipes/rest/impl/pe/DataSinkResource.java | 12 +- .../rest/impl/pe/DataStreamResource.java | 31 +- streampipes-sdk-bundle/pom.xml | 22 +- streampipes-sdk/pom.xml | 8 +- ...AbstractConfigurablePipelineElementBuilder.java | 18 + .../streampipes/sdk/helpers/EpProperties.java | 3 +- streampipes-security-jwt/pom.xml | 4 +- streampipes-serializers-json/pom.xml | 8 +- streampipes-service-base/pom.xml | 6 +- streampipes-service-core/pom.xml | 15 +- .../service/core/StreamPipesResourceConfig.java | 2 - .../src/main/resources/openapi.yaml | 2 +- streampipes-service-discovery-api/pom.xml | 2 +- streampipes-service-discovery-consul/pom.xml | 8 +- streampipes-service-discovery/pom.xml | 6 +- streampipes-service-extensions/pom.xml | 6 +- streampipes-sources/pom.xml | 4 +- streampipes-storage-api/pom.xml | 6 +- streampipes-storage-couchdb/pom.xml | 12 +- .../couchdb/impl/ConnectionStorageImpl.java | 3 +- streampipes-storage-management/pom.xml | 6 +- streampipes-test-utils/pom.xml | 4 +- streampipes-user-management/pom.xml | 10 +- streampipes-vocabulary/pom.xml | 2 +- streampipes-wrapper-distributed/pom.xml | 10 +- streampipes-wrapper-flink/pom.xml | 4 +- streampipes-wrapper-kafka-streams/pom.xml | 4 +- streampipes-wrapper-python/README.md | 91 +- streampipes-wrapper-python/pom.xml | 2 +- streampipes-wrapper-python/requirements.txt | 4 +- streampipes-wrapper-python/setup.py | 3 +- streampipes-wrapper-python/streampipes/api/rest.py | 2 + streampipes-wrapper-python/streampipes/core.py | 3 + streampipes-wrapper-python/streampipes/declarer.py | 4 +- .../streampipes/instances.py | 7 +- streampipes-wrapper-python/streampipes/manager.py | 2 + .../model/base/abstract_streampipes_entity.py | 3 + .../model/base/consumable_streampipes_entity.py | 3 + .../model/base/named_streampipes_entity.py | 3 + .../model/base/unnamed_streampipes_entity.py | 4 + .../streampipes/model/config_item.py | 2 + .../model/graph/data_processor_description.py | 2 + .../streampipes/model/pipeline_element_config.py | 2 + .../staticproperty/free_text_StaticProperty.py | 5 +- .../model/staticproperty/static_property.py | 3 + .../streampipes/submitter.py | 3 +- .../streampipes/utils/register.py | 2 + streampipes-wrapper-siddhi/pom.xml | 4 +- streampipes-wrapper-standalone/pom.xml | 4 +- .../function/FunctionContextGenerator.java | 5 +- streampipes-wrapper/pom.xml | 14 +- tools/maven/checkstyle.xml | 2 +- ui/Dockerfile | 12 +- ui/README.md | 13 +- .../booleanCounter1/expected.csv | 10 +- .../booleanCounter2/expected.csv | 14 +- ui/cypress/support/utils/DashboardUtils.ts | 9 + ui/cypress/support/utils/PrepareTestDataUtils.ts | 8 +- ui/cypress/support/utils/connect/ConnectBtns.ts | 8 + ui/cypress/support/utils/connect/ConnectUtils.ts | 9 + ui/cypress/support/utils/datalake/DataLakeUtils.ts | 40 +- .../tests/adapter/allAdapterActions.smoke.spec.ts | 40 + .../dashboard/standaloneDashboardTest.spec.ts | 46 + .../tests/datalake/configuration.smoke.spec.ts | 7 +- ui/cypress/tests/datalake/widgets/table.ts | 2 +- ui/nginx_config/default.conf | 23 +- ui/nginx_config/ssl.conf | 2 +- ui/package-lock.json | 3734 ++++++++++++++++---- ui/package.json | 30 +- .../streampipes/platform-services/package.json | 2 +- .../src/lib/apis/labels.service.ts | 64 + .../src/lib/apis/pipeline-element.service.ts | 6 +- .../src/lib/apis/pipeline.service.ts | 12 +- .../src/lib/model/labels/labels.model.ts | 11 +- .../platform-services/src/public-api.ts | 2 + .../basic-view/basic-view.component.scss | 2 +- .../components/sp-label/sp-label.component.html} | 21 +- .../components/sp-label/sp-label.component.scss | 14 +- .../lib/components/sp-label/sp-label.component.ts | 54 + .../split-section/split-section.component.html | 0 .../split-section/split-section.component.scss | 0 .../split-section/split-section.component.ts | 0 .../shared-ui/src/lib/shared-ui.module.ts | 6 + .../streampipes/shared-ui/src/public-api.ts | 2 + .../assets/dialog/base-asset-links.directive.ts | 2 +- ui/src/app/configuration/configuration-tabs.ts | 15 +- ui/src/app/configuration/configuration.module.ts | 10 + .../edit-label/edit-label.component.html | 66 + .../edit-label/edit-label.component.scss | 11 +- .../edit-label/edit-label.component.ts | 47 +- .../label-configuration.component.html | 94 + .../label-configuration.component.scss | 9 +- .../label-configuration.component.ts | 72 + .../event-property-row.component.ts | 26 +- .../existing-adapters.component.html | 28 +- .../existing-adapters.component.ts | 34 + ui/src/app/connect/connect.module.ts | 2 + .../edit-schema-transformation.component.html | 3 +- .../edit-correction-value.component.ts | 3 +- .../edit-event-property.component.ts | 2 +- .../all-adapter-actions-dialog.component.html | 81 + .../all-adapter-actions-dialog.component.scss | 6 +- .../all-adapter-actions-dialog.component.ts | 120 + ui/src/app/connect/services/rest.service.ts | 5 +- ui/src/app/core-ui/core-ui.module.ts | 3 - .../standalone/standalone-dashboard.component.html | 1 + .../standalone/standalone-dashboard.component.ts | 25 +- .../dashboard/components/widgets/raw/raw-config.ts | 1 - .../data-explorer-dashboard-widget.component.ts | 4 +- .../base/base-data-explorer-widget.directive.ts | 6 +- .../components/widgets/base/base-widget-config.ts | 2 +- .../widgets/table/table-widget.component.html | 11 +- .../widgets/table/table-widget.component.ts | 36 +- .../time-series-chart-widget.component.ts | 202 +- .../data-explorer-field-provider-service.ts | 5 +- ui/src/app/editor/services/editor.service.ts | 5 +- ui/src/app/home/components/status.component.ts | 2 +- ui/src/app/info/about/about.component.html | 23 + ui/src/app/login/services/login.service.ts | 5 +- .../app/notifications/notifications.component.ts | 2 +- .../notifications/service/notifications.service.ts | 5 +- ui/src/app/pipelines/pipelines.component.ts | 2 +- .../token/token-management-settings.component.html | 23 +- .../token/token-management-settings.component.scss | 4 + .../token/token-management-settings.component.ts | 8 + ui/src/app/profile/profile.module.ts | 2 + ui/src/app/services/rest-api.service.ts | 7 +- ui/webpack.partial.base.js | 11 + 525 files changed, 13250 insertions(+), 8540 deletions(-)
