This is an automated email from the ASF dual-hosted git repository. zehnder pushed a commit to branch SP-1367 in repository https://gitbox.apache.org/repos/asf/streampipes.git
commit 4c282c8d1e98b8a368ce39ec1cf604a8d0101038 Merge: 70ffa1800 de73be881 Author: Philipp Zehnder <[email protected]> AuthorDate: Tue Mar 28 18:25:23 2023 +0200 Merge branch 'dev' into SP-1367 .github/release.yml | 20 +- .github/workflows/pypi-deployment.yml | 21 +- .github/workflows/python-docs.yml | 13 +- README.md | 4 +- .../src/main/resources/archetype-resources/pom.xml | 12 +- .../archetype-resources/src/main/java/Init.java | 36 +- .../__classNamePrefix__DataProcessor.java | 39 +- .../__classNamePrefix__DataSink.java | 25 +- .../src/main/resources/archetype-resources/pom.xml | 61 +- .../archetype-resources/src/main/java/Init.java | 10 +- .../__classNamePrefix__Controller.java | 2 +- .../__classNamePrefix__Program.java | 2 +- .../src/main/resources/archetype-resources/pom.xml | 56 +- .../archetype-resources/src/main/java/Init.java | 52 +- .../src/main/java/config/Config.java | 76 - .../src/main/java/config/ConfigKeys.java | 15 +- .../__classNamePrefix__Controller.java | 11 +- .../__classNamePrefix__Program.java | 23 +- create-client-model.sh | 44 +- installer/.gitignore | 2 + installer/k8s/templates/core/ui-configmap.yaml | 2 +- pom.xml | 2 +- streampipes-client-python/.pre-commit-config.yaml | 2 +- streampipes-client-python/README.md | 49 +- .../docs/getting-started/developing.md | 18 +- .../docs/getting-started/first-steps.md | 28 +- .../docs/getting-started/quickstart.md | 59 +- .../docs/img/streampipes-python-dark.png | Bin 0 -> 116009 bytes streampipes-client-python/docs/index.md | 72 +- .../partials/integrations/analytics/matomo.html | 36 + ...introduction-to-streampipes-python-client.ipynb | 34 +- ...cting-data-from-the-streampipes-data-lake.ipynb | 17 +- ...ive-data-from-the-streampipes-data-stream.ipynb | 27 +- ...ine-learning-on-a-streampipes-data-stream.ipynb | 6 +- streampipes-client-python/mkdocs.yml | 62 +- streampipes-client-python/setup.py | 21 +- .../streampipes/client/client.py | 90 +- .../streampipes/client/config.py | 10 +- .../streampipes/client/credential_provider.py | 17 +- .../streampipes/endpoint/api/data_lake_measure.py | 102 +- .../streampipes/endpoint/api/data_stream.py | 45 +- .../streampipes/endpoint/endpoint.py | 48 +- .../streampipes/function_zoo/river_function.py | 43 +- .../streampipes/functions/broker/__init__.py | 2 + .../streampipes/functions/broker/broker.py | 21 +- .../streampipes/functions/broker/broker_handler.py | 23 +- .../broker/{nats_broker.py => kafka_broker.py} | 34 +- .../{__init__.py => kafka_message_fetcher.py} | 41 +- .../streampipes/functions/broker/nats_broker.py | 10 +- .../functions/broker/output_collector.py | 28 +- .../streampipes/functions/function_handler.py | 16 +- .../streampipes/functions/registration.py | 17 +- .../streampipes/functions/streampipes_function.py | 19 +- .../functions/utils/async_iter_handler.py | 23 +- .../functions/utils/data_stream_context.py | 4 +- .../functions/utils/data_stream_generator.py | 21 +- .../functions/utils/function_context.py | 9 +- .../streampipes/model/common.py | 27 +- .../model/container/data_lake_measures.py | 9 +- .../streampipes/model/container/data_streams.py | 9 +- .../model/container/resource_container.py | 17 +- .../model/resource/data_lake_measure.py | 14 +- .../streampipes/model/resource/data_lake_series.py | 10 +- .../streampipes/model/resource/data_stream.py | 7 +- .../model/resource/function_definition.py | 79 +- .../streampipes/model/resource/resource.py | 11 +- .../apache/streampipes/commons/constants/Envs.java | 2 + .../commons/environment/DefaultEnvironment.java | 5 + .../commons/environment/Environment.java | 2 + .../streampipes/config/backend/BackendConfig.java | 15 +- .../dataexplorer/DataLakeManagementV4.java | 51 - .../dataexplorer/query/DataExplorerQuery.java | 94 - .../query/DataExplorerQueryBuilder.java | 61 - .../dataexplorer/query/DeleteDataQuery.java | 28 +- .../query/EditRetentionPolicyQuery.java | 77 - .../query/ShowRetentionPolicyQuery.java | 58 - .../dataexplorer/v4/AutoAggregationHandler.java | 18 +- .../v4/params/WhereStatementParams.java | 5 +- .../dataexplorer/v4/template/QueryTemplatesV4.java | 26 - .../sdk/DataLakeQueryBuilderTest.java} | 30 +- .../streampipes/processors/geo/jvm/GeoJvmInit.java | 12 +- .../jvm/jts/exceptions/SpJtsGeoemtryException.java | 27 +- .../geo/jvm/jts/helper/buffer/BufferSide.java | 18 +- .../geo/jvm/jts/helper/buffer/CapStyle.java | 14 +- .../geo/jvm/jts/helper/buffer/JoinStyle.java | 21 +- .../geo/jvm/jts/helper/buffer/SpBufferBuilder.java | 124 + .../buffergeometry/BufferGeomProcessor.java | 224 ++ .../bufferpoint/BufferPointProcessor.java | 172 ++ .../jts/processor/validation/ValidationOutput.java | 18 +- .../jts/processor/validation/ValidationType.java | 18 +- .../complex/TopologyValidationProcessor.java | 143 + .../simple/GeometryValidationProcessor.java | 159 ++ .../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 | 28 +- .../documentation.md | 80 + .../icon.png | Bin 0 -> 19690 bytes .../strings.en | 22 +- .../documentation.md | 74 + .../icon.png | Bin 0 -> 16986 bytes .../strings.en | 22 +- .../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 | 6 + .../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 ++ .../apache/streampipes/ps/DataLakeResourceV4.java | 30 - streampipes-service-base/pom.xml | 4 + ui/cypress/support/utils/connect/ConnectBtns.ts | 8 + ui/cypress/support/utils/connect/ConnectUtils.ts | 9 + .../tests/adapter/allAdapterActions.smoke.spec.ts | 40 + ui/package-lock.json | 2738 +++++++++++++++----- ui/package.json | 20 +- .../existing-adapters.component.html | 28 +- .../existing-adapters.component.ts | 34 + ui/src/app/connect/connect.module.ts | 2 + .../all-adapter-actions-dialog.component.html | 81 + .../all-adapter-actions-dialog.component.scss | 17 +- .../all-adapter-actions-dialog.component.ts | 120 + .../dashboard/components/widgets/raw/raw-config.ts | 1 - .../data-explorer-dashboard-widget.component.ts | 4 +- .../base/base-data-explorer-widget.directive.ts | 6 +- .../widgets/table/table-widget.component.html | 10 +- .../widgets/table/table-widget.component.ts | 36 +- .../time-series-chart-widget.component.ts | 202 +- 165 files changed, 6899 insertions(+), 3731 deletions(-)
