You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ri...@apache.org on 2023/03/29 20:30:36 UTC
[streampipes] branch 1335-replace-angularflex-layout-dependency-with-ngbracketngx-layout-dependency updated (5db0ac317 -> 6f7e26ebc)
This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch 1335-replace-angularflex-layout-dependency-with-ngbracketngx-layout-dependency
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 5db0ac317 Start to migrate Angular Material components to MDC components (#1335)
add 72c5b6b9c Update all version to 0.92.0-SNAPSHOT (#1338)
add b8b33370b [#1336] Add a builder to create SpQueryResult objects
add d5789f74e Bump cypress from 12.5.1 to 12.6.0 in /ui
add 5653e5e60 chore(python-docs): improve getting started section (#1310)
add d70630c2d feat: Add input validation for API token name (#793)
add 53e19f439 Support backend-only development mode (#1327) (#1339)
add a5ebee83e [#1291] Can't aggregate calculation results of the Math processing element (#1340)
add 921e27600 Bump pre-commit from 3.0.0 to 3.1.0 in /streampipes-client-python (#1345)
add 0811e9967 Bump @typescript-eslint/eslint-plugin from 5.52.0 to 5.53.0 in /ui (#1347)
add 8a013b590 chore(ci): improve caching for dependencies in pr-validation workflow (#1311)
add f06b3e422 [hotfix] Extract interface from data explorer query builder
add 21bef02d4 [hotfix] Fix failing e2e tests
add 81b1a4a2e [hotfix] Add echarts to shared modules
add f71bd9629 [#1254]: extend data lake measure endpoints get method to process query parameters (#1349)
add d3ca321f5 1207 improve helm charts (#1344)
add 44017e066 [hotfix] Use try-with-resource way to fix the potential InfluxDB connection leak in DataExplorerQueryV4 (#1350)
add e70e2462a Bump snakeyaml from 1.32 to 2.0
add 1abb75708 [hotfix] Set `PageResult` as deprecated
add 73874ee0b [hotfix] Fix example in python client README
add 181c78f25 [hotfix] Modify README of python client so that commands can be copied
add f8bb8f744 Bump @braintree/sanitize-url and swagger-ui in /ui
add 5c4118e61 chore: reify project url in package metadata (#1356)
add 729742f16 Bump eslint from 8.34.0 to 8.35.0 in /ui (#1365)
add 433fe9190 Refactor Image Processors (#1331)
add 7bf158d1e Fix UI container cannot get the backend DNS correctly
add db0e3b89f Ignore install/defaul.conf
add a304daebd #1272 add buffer geometry
add 500410b70 #1272 misc changes of buffer geometry
add 0beea321d #1272 add buffer point processor
add 930356a59 [#1272] improve icons
add b142fb93f [#1272] check dependencies for SIS DB
add 11f3a443a [#1272] add missing license header
add 834c947dd [#1272] fix checkstyle error and rewrite text
add 24b0d7ff7 [#1272] Improve documentation
add 95bed0766 Merge branch 'dev' into 1272-buffer-processor
add 4f521bec5 [#1272] Add Output Image to Documentation and register in Processor
add ddb62403d Merge pull request #1303 from apache/1272-buffer-processor
add bc616d472 Bump @cypress/webpack-preprocessor from 5.16.0 to 5.17.0 in /ui (#1370)
add 9cbeed0a4 [hotfix] Set `PageResult` as deprecated
add a60bae140 [hotfix] Automatically add licence headers to generated model classes
add cd34cdd4d Merge branch 'dev' of github.com:apache/streampipes into dev
add a1698440b chore: fix example code & add disclaimer for doc versioning (#1364)
add 85565b8fd [#1307] Add geometry validation processor first implementation
add 2a89675ca [#1307] misc validation fixes manual tests
add 562dbb34a [#1307] add resources
add 4e8de865e Merge branch 'dev' into 1307-geometry-validation-processor
add 502d05efc [#1307] Split processor in two types, extend documentation
add 49cd5231d Merge branch 'dev' into 1307-geometry-validation-processor
add 5938bc96f [#1307] catch non selection with better info output from https://github.com/apache/streampipes/issues/1351
add 3b7c207fd Merge pull request #1320 from apache/1307-geometry-validation-processor
add ae234aed7 Add environment variable for manually specifying file storage in backend (#1383) (#1384)
add 29b8ea921 Migrate boolean counter #1366 (#1382)
add 90b62ba0d Migrate boolean inverter (#1388)
add ec51de356 Bump @typescript-eslint/parser from 5.52.0 to 5.54.0 in /ui (#1393)
add cf85c2aa6 Remove obsolete features from data explorer module (#1385) (#1386)
add 67d727919 Bump swagger-ui from 4.16.1 to 4.17.1 in /ui (#1396)
add c830543a2 Bump mypy from 1.0.0 to 1.1.1 in /streampipes-client-python (#1395)
add ea5e9acbf Bump swagger-ui from 4.17.1 to 4.18.0 in /ui
add f50510727 1391 data explorer filter doesnt work for boolean and false value (#1399)
add c530d55bb [#1375] add versioning to python docs (#1397)
add 25bf66f6a #1261 Modified release.yml file to include Python changes to release notes (#1404)
add 7fe524e47 Add support for the Kafka broker in Python (#1363)
add 5b6529efc docs: add matomo tracking to python docs (#1409)
add 1e5fb25b5 [hotfix] refine changelog structure
add 60d3f8153 [hotfix] always set alias for python docs
add bd3e014ab [hotfix] overwrite alias for python docs
add 73819a0cf [hotfix] provide latest as default in python docs
add 420336fb0 miscellaneous improvements for Python docs (#1410)
add 1521545f5 Search For Python DOC (#1408)
add 74a816d23 Bump mkdocs-jupyter from 0.22.0 to 0.23.0 in /streampipes-client-python (#1413)
add ee51abb2e [doc](readme)Enhancement in some Hyperlinks. (#1415)
add 3ee724c9d Bump mkdocs-material from 9.0.8 to 9.1.3 in /streampipes-client-python (#1416)
add 157417eee Bump webpack from 5.75.0 to 5.76.0 in /ui (#1418)
add 622261a44 Bump cypress from 12.6.0 to 12.8.1 in /ui (#1420)
add ad8c8de2f Bump @typescript-eslint/eslint-plugin from 5.53.0 to 5.55.0 in /ui (#1421)
add 25f40ce89 Bump mkdocs-jupyter from 0.23.0 to 0.24.0 in /streampipes-client-python (#1429)
add ed5b074e0 Bump pre-commit from 3.1.0 to 3.2.0 in /streampipes-client-python (#1431)
add 67727505f Bump lint-staged from 13.1.0 to 13.2.0 in /ui (#1430)
add 09327f56b docs: spring cleaning for Python docs (#1419)
add f9c0c67da Maintain the same directory structure for source and test (#1428)
add c7c1a301b Migrate StringCounter processing elements (#1427)
add d8583b155 1423 update archetypes (#1425)
add 7a0650810 Bump @angular-eslint/builder from 15.1.0 to 15.2.1 in /ui (#1432)
add a42fe29c7 update archetypes template (#1433)
add 94716b87e Bump eslint-config-prettier from 8.6.0 to 8.8.0 in /ui (#1437)
add cd38a4bde fix repeated past data (#1440)
add 586666ca4 Bump eslint from 8.35.0 to 8.36.0 in /ui
add d9dea34bc Bump json-smart from 2.4.8 to 2.4.9
add 7cc4e0209 Improve Log info in Processor Test (#1445)
add 83b50d6b0 Migrate StringToState processing elements (#1444)
add a99f0cd44 Migrate StringTimer processing elements (#1453)
add 435171490 Python docs with dark mode (#1454)
add ce1d95f6e [#1113] Added buttons to start and stop all adapters (#1441)
add de73be881 [hotfix] Add test for DataLakeQueryBuilder (#1459)
add 5000139e0 Bump error_prone_annotations from 2.2.0 to 2.18.0 (#1403)
add 3ca5f9b21 Bump @typescript-eslint/parser from 5.54.0 to 5.56.0 in /ui
add 792f2d108 Bump eslint from 8.36.0 to 8.37.0 in /ui
add c8fd621db Bump kafka.version from 3.3.1 to 3.4.0
add 45b27818e Bump black from 23.1.0 to 23.3.0 in /streampipes-client-python
add 004422938 Bump boofcv-core from 0.33 to 0.42
add 4f74f9428 [hotfix] Remove duplicate declaration of snakeyaml dependency version
add 9efbb536e Merge branch 'dev' into 1335-replace-angularflex-layout-dependency-with-ngbracketngx-layout-dependency
add 6f7e26ebc Refactore more Angular Material MDC components (#1335)
No new revisions were added by this update.
Summary of changes:
.github/release.yml | 20 +-
.github/workflows/build.yml | 8 +-
.github/workflows/cypress-test.yml | 7 +-
.github/workflows/pr-validation.yml | 56 +-
.github/workflows/pypi-deployment.yml | 25 +-
.github/workflows/python-docs.yml | 23 +-
README.md | 4 +-
.../src/main/resources/archetype-resources/pom.xml | 14 +-
.../archetype-resources/src/main/java/Init.java | 36 +-
.../__classNamePrefix__DataProcessor.java | 39 +-
.../__classNamePrefix__DataSink.java | 25 +-
.../src/main/resources/archetype-resources/pom.xml | 63 +-
.../archetype-resources/src/main/java/Init.java | 10 +-
.../__classNamePrefix__Controller.java | 2 +-
.../__classNamePrefix__Program.java | 2 +-
.../src/main/resources/archetype-resources/pom.xml | 58 +-
.../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 +-
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} | 13 +-
.../{ui => ui-custom-conf}/docker-compose.yml | 7 +-
.../cli/deploy/standalone/ui/docker-compose.yml | 2 +-
installer/cli/environments/backend | 3 +-
installer/cli/environments/backend-nats | 3 +-
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 | 15 +-
streampipes-client-python/.pre-commit-config.yaml | 2 +-
streampipes-client-python/README.md | 51 +-
...cting-data-from-the-streampipes-data-lake.ipynb | 392 --
.../docs/getting-started/developing.md | 106 +
.../docs/getting-started/first-steps.md | 80 +
.../docs/getting-started/installation.md | 43 -
.../docs/getting-started/quickstart.md | 59 +-
.../docs/img/streampipes-python-dark.png | Bin 0 -> 116009 bytes
.../docs/img/tutorial-preparation.gif | Bin 0 -> 2569748 bytes
streampipes-client-python/docs/index.md | 72 +-
.../partials/integrations/analytics/matomo.html | 39 +-
...introduction-to-streampipes-python-client.ipynb | 112 +-
...cting-data-from-the-streampipes-data-lake.ipynb | 534 ++
...ive-data-from-the-streampipes-data-stream.ipynb | 39 +-
...ine-learning-on-a-streampipes-data-stream.ipynb | 19 +-
streampipes-client-python/mkdocs.yml | 61 +-
streampipes-client-python/setup.py | 23 +-
.../streampipes/client/client.py | 90 +-
.../streampipes/client/config.py | 10 +-
.../streampipes/client/credential_provider.py | 17 +-
.../streampipes/endpoint/api/data_lake_measure.py | 288 +-
.../streampipes/endpoint/api/data_stream.py | 45 +-
.../streampipes/endpoint/endpoint.py | 50 +-
.../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 +-
.../tests/client/test_data_lake_series.py | 2 +-
.../{streampipes => tests/endpoint}/__init__.py | 0
.../tests/endpoint/test_data_lake_measure.py | 138 +
.../apache/streampipes/commons/constants/Envs.java | 2 +
.../commons/environment/DefaultEnvironment.java | 5 +
.../commons/environment/Environment.java | 2 +
.../streampipes/config/backend/BackendConfig.java | 15 +-
.../dataexplorer/commons/influx/InfluxStore.java | 16 +-
.../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/sdk/DataLakeQueryBuilder.java | 42 +-
.../dataexplorer/sdk/IDataLakeQueryBuilder.java | 74 +
.../dataexplorer/v4/AutoAggregationHandler.java | 18 +-
.../v4/params/WhereStatementParams.java | 5 +-
.../dataexplorer/v4/query/DataExplorerQueryV4.java | 66 +-
.../dataexplorer/v4/template/QueryTemplatesV4.java | 26 -
.../sdk/DataLakeQueryBuilderTest.java} | 30 +-
.../streampipes-connect-adapters-iiot/pom.xml | 4 -
.../streampipes-connect-adapters/pom.xml | 4 -
.../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 +
.../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 +
.../apache/streampipes/ps/DataLakeResourceV4.java | 30 -
.../streampipes/sdk/helpers/EpProperties.java | 3 +-
streampipes-service-base/pom.xml | 4 +
ui/Dockerfile | 12 +-
.../booleanCounter1/expected.csv | 10 +-
.../booleanCounter2/expected.csv | 14 +-
ui/cypress/support/utils/connect/ConnectBtns.ts | 8 +
ui/cypress/support/utils/connect/ConnectUtils.ts | 9 +
.../tests/adapter/allAdapterActions.smoke.spec.ts | 40 +
ui/deployment/appng5.module.mst | 2 +-
ui/deployment/sp-theme.scss | 2 +-
ui/nginx_config/default.conf | 23 +-
ui/nginx_config/ssl.conf | 2 +-
ui/package-lock.json | 5297 +++++++++++++++-----
ui/package.json | 22 +-
.../basic-nav-tabs/basic-nav-tabs.component.html | 4 +-
.../basic-view/basic-view.component.html | 1 -
.../basic-view/basic-view.component.scss | 2 +-
.../confirm-dialog/confirm-dialog.component.html | 42 +-
.../shared-ui/src/lib/shared-ui.module.ts | 2 +
ui/src/app/add/add.component.html | 80 +-
.../create-asset/create-asset.component.html | 6 +-
.../add-pipeline-dialog.component.html | 10 +-
.../app/app-overview/app-overview.component.html | 2 +-
.../general-configuration.component.html | 8 +-
.../event-property-row.component.html | 1 +
.../existing-adapters.component.html | 28 +-
.../existing-adapters.component.ts | 34 +
.../filter-toolbar/filter-toolbar.component.html | 11 +-
ui/src/app/connect/connect.module.ts | 2 +
.../all-adapter-actions-dialog.component.html | 81 +
.../all-adapter-actions-dialog.component.scss} | 0
.../all-adapter-actions-dialog.component.ts | 120 +
.../static-color-picker.component.html | 28 +-
.../dashboard/components/widgets/raw/raw-config.ts | 1 -
.../add-visualization-dialog.component.html | 20 +-
...ta-explorer-widget-data-settings.component.html | 143 +-
.../time-selector/timeRangeSelector.component.html | 6 +-
.../time-selector/timeRangeSelector.component.scss | 4 +-
.../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 | 10 +-
.../widgets/table/table-widget.component.ts | 36 +-
.../time-series-chart-widget.component.ts | 202 +-
...a-explorer-edit-data-view-dialog.component.html | 4 +-
.../data-explorer-field-provider-service.ts | 5 +-
.../pipeline-element-icon-stand.component.html | 6 +-
ui/src/app/home/home.component.html | 8 +-
.../login/components/login/login.component.html | 2 +-
.../pipeline-overview.component.html | 85 +-
.../token/token-management-settings.component.html | 23 +-
.../token/token-management-settings.component.scss | 4 +
.../token/token-management-settings.component.ts | 8 +
ui/src/scss/sp/forms.scss | 8 +-
ui/src/scss/sp/layout.scss | 14 +-
ui/src/scss/sp/widgets.scss | 6 +-
ui/webpack.partial.base.js | 11 +
270 files changed, 11175 insertions(+), 5614 deletions(-)
delete mode 100644 archetypes/streampipes-archetype-pe-sinks-flink/src/main/resources/archetype-resources/src/main/java/config/Config.java
copy {ui/nginx_config => installer/cli/deploy/standalone/ui-custom-conf}/default.conf (60%)
copy installer/cli/{environments/backend => deploy/standalone/ui-custom-conf/docker-compose.dev.yml} (85%)
copy installer/cli/deploy/standalone/{ui => ui-custom-conf}/docker-compose.yml (92%)
delete mode 100644 installer/k8s/templates/core/backend-pv-pvc.yaml
rename installer/k8s/templates/{extensions/pipeline-elements/pipeline-elements-all-flink-service.yaml => core/backend-pvc.yaml} (71%)
create mode 100644 installer/k8s/templates/core/ui-configmap.yaml
rename installer/k8s/templates/core/{ui.yaml => ui-deployment.yaml} (68%)
create mode 100644 installer/k8s/templates/core/ui-ingressroute.yaml
rename installer/k8s/templates/extensions/pipeline-elements/{extensions-all-jvm-deployment.yaml => extensions-all-iiot-deployment.yaml} (86%)
rename installer/k8s/templates/extensions/pipeline-elements/{extensions-all-jvm-service.yaml => extensions-all-iiot-service.yaml} (91%)
delete mode 100644 installer/k8s/templates/extensions/pipeline-elements/pipeline-elements-all-flink-deployment.yaml
delete mode 100644 installer/k8s/templates/external/flink/jobmanager-deployment.yaml
delete mode 100644 installer/k8s/templates/external/flink/jobmanager-service.yaml
delete mode 100644 installer/k8s/templates/external/flink/taskmanager-deployment.yaml
delete mode 100644 streampipes-client-python/docs/examples/2-extracting-data-from-the-streampipes-data-lake.ipynb
create mode 100644 streampipes-client-python/docs/getting-started/developing.md
create mode 100644 streampipes-client-python/docs/getting-started/first-steps.md
delete mode 100644 streampipes-client-python/docs/getting-started/installation.md
create mode 100644 streampipes-client-python/docs/img/streampipes-python-dark.png
create mode 100644 streampipes-client-python/docs/img/tutorial-preparation.gif
copy ui/projects/streampipes/shared-ui/src/lib/dialog/confirm-dialog/confirm-dialog.component.html => streampipes-client-python/docs/overrides/partials/integrations/analytics/matomo.html (50%)
rename streampipes-client-python/docs/{examples => tutorials}/1-introduction-to-streampipes-python-client.ipynb (69%)
create mode 100644 streampipes-client-python/docs/tutorials/2-extracting-data-from-the-streampipes-data-lake.ipynb
rename streampipes-client-python/docs/{examples => tutorials}/3-getting-live-data-from-the-streampipes-data-stream.ipynb (97%)
rename streampipes-client-python/docs/{examples => tutorials}/4-using-online-machine-learning-on-a-streampipes-data-stream.ipynb (92%)
copy streampipes-client-python/streampipes/functions/broker/{nats_broker.py => kafka_broker.py} (70%)
copy streampipes-client-python/streampipes/functions/broker/{__init__.py => kafka_message_fetcher.py} (53%)
copy streampipes-client-python/{streampipes => tests/endpoint}/__init__.py (100%)
create mode 100644 streampipes-client-python/tests/endpoint/test_data_lake_measure.py
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/DataExplorerQuery.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/DataExplorerQueryBuilder.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/EditRetentionPolicyQuery.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/ShowRetentionPolicyQuery.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/sdk/IDataLakeQueryBuilder.java
rename streampipes-data-explorer/src/{main/java/org/apache/streampipes/dataexplorer/param/RetentionPolicyQueryParams.java => test/java/org/apache/streampipes/dataexplorer/sdk/DataLakeQueryBuilderTest.java} (59%)
rename streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/template/QueryTemplates.java => streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/exceptions/SpJtsGeoemtryException.java (57%)
mode change 100644 => 100755
copy streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/model/Order.java => streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/helper/buffer/BufferSide.java (76%)
mode change 100644 => 100755
rename streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/ParameterizedDataExplorerQuery.java => streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/helper/buffer/CapStyle.java (76%)
mode change 100644 => 100755
rename streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/QueryParams.java => streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/helper/buffer/JoinStyle.java (72%)
mode change 100644 => 100755
create mode 100755 streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/helper/buffer/SpBufferBuilder.java
create mode 100644 streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/buffergeometry/BufferGeomProcessor.java
create mode 100644 streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/bufferpoint/BufferPointProcessor.java
copy streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/model/Order.java => streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/validation/ValidationOutput.java (77%)
mode change 100644 => 100755
rename streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/model/Order.java => streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/validation/ValidationType.java (77%)
mode change 100644 => 100755
create mode 100644 streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/validation/complex/TopologyValidationProcessor.java
create mode 100644 streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/validation/simple/GeometryValidationProcessor.java
create mode 100755 streampipes-extensions/streampipes-processors-geo-jvm/src/main/resources/org.apache.streampipes.processors.geo.jvm.jts.processor.buffergeometry/documentation.md
create mode 100644 streampipes-extensions/streampipes-processors-geo-jvm/src/main/resources/org.apache.streampipes.processors.geo.jvm.jts.processor.buffergeometry/icon.png
create mode 100755 streampipes-extensions/streampipes-processors-geo-jvm/src/main/resources/org.apache.streampipes.processors.geo.jvm.jts.processor.buffergeometry/strings.en
create mode 100755 streampipes-extensions/streampipes-processors-geo-jvm/src/main/resources/org.apache.streampipes.processors.geo.jvm.jts.processor.bufferpoint/documentation.md
create mode 100644 streampipes-extensions/streampipes-processors-geo-jvm/src/main/resources/org.apache.streampipes.processors.geo.jvm.jts.processor.bufferpoint/icon.png
create mode 100644 streampipes-extensions/streampipes-processors-geo-jvm/src/main/resources/org.apache.streampipes.processors.geo.jvm.jts.processor.bufferpoint/output.png
copy streampipes-client-python/streampipes/functions/broker/__init__.py => streampipes-extensions/streampipes-processors-geo-jvm/src/main/resources/org.apache.streampipes.processors.geo.jvm.jts.processor.bufferpoint/strings.en (50%)
mode change 100644 => 100755
create mode 100644 streampipes-extensions/streampipes-processors-geo-jvm/src/main/resources/org.apache.streampipes.processors.geo.jvm.jts.processor.validation.complex/documentation.md
create mode 100644 streampipes-extensions/streampipes-processors-geo-jvm/src/main/resources/org.apache.streampipes.processors.geo.jvm.jts.processor.validation.complex/icon.png
copy streampipes-client-python/streampipes/functions/broker/__init__.py => streampipes-extensions/streampipes-processors-geo-jvm/src/main/resources/org.apache.streampipes.processors.geo.jvm.jts.processor.validation.complex/strings.en (56%)
create mode 100644 streampipes-extensions/streampipes-processors-geo-jvm/src/main/resources/org.apache.streampipes.processors.geo.jvm.jts.processor.validation.simple/documentation.md
create mode 100644 streampipes-extensions/streampipes-processors-geo-jvm/src/main/resources/org.apache.streampipes.processors.geo.jvm.jts.processor.validation.simple/icon.png
copy streampipes-client-python/streampipes/functions/broker/__init__.py => streampipes-extensions/streampipes-processors-geo-jvm/src/main/resources/org.apache.streampipes.processors.geo.jvm.jts.processor.validation.simple/strings.en (55%)
create mode 100644 streampipes-extensions/streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/commons/ImagePropertyConstants.java
delete mode 100644 streampipes-extensions/streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/genericclassification/GenericImageClassificationController.java
delete mode 100644 streampipes-extensions/streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/genericclassification/GenericImageClassificationParameters.java
rename streampipes-extensions/streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/genericclassification/{GenericImageClassification.java => GenericImageClassificationProcessor.java} (50%)
delete mode 100644 streampipes-extensions/streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/imagecropper/ImageCropper.java
delete mode 100644 streampipes-extensions/streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/imagecropper/ImageCropperController.java
delete mode 100644 streampipes-extensions/streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/imagecropper/ImageCropperParameters.java
create mode 100644 streampipes-extensions/streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/imagecropper/ImageCropperProcessor.java
delete mode 100644 streampipes-extensions/streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/imageenrichment/ImageEnrichmentController.java
delete mode 100644 streampipes-extensions/streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/imageenrichment/ImageEnrichmentParameters.java
rename streampipes-extensions/streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/imageenrichment/{ImageEnricher.java => ImageEnrichmentProcessor.java} (51%)
delete mode 100644 streampipes-extensions/streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/qrreader/QrCodeReader.java
delete mode 100644 streampipes-extensions/streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/qrreader/QrCodeReaderController.java
delete mode 100644 streampipes-extensions/streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/qrreader/QrCodeReaderParameters.java
create mode 100644 streampipes-extensions/streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/qrreader/QrCodeReaderProcessor.java
delete mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/counter/BooleanCounter.java
delete mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/counter/BooleanCounterController.java
delete mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/counter/BooleanCounterParameters.java
create mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/counter/BooleanCounterProcessor.java
delete mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/inverter/BooleanInverter.java
delete mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/inverter/BooleanInverterParameters.java
rename streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/inverter/{BooleanInverterController.java => BooleanInverterProcessor.java} (62%)
delete mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/counter/StringCounter.java
delete mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/counter/StringCounterParameters.java
rename streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/counter/{StringCounterController.java => StringCounterProcessor.java} (57%)
delete mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/state/StringToState.java
delete mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/state/StringToStateParameters.java
rename streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/state/{StringToStateController.java => StringToStateProcessor.java} (61%)
delete mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/timer/StringTimer.java
delete mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/timer/StringTimerParameters.java
rename streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/timer/{StringTimerController.java => StringTimerProcessor.java} (55%)
create mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/counter/TestBooleanCounterProcessor.java
create mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/inverter/TestBooleanInverterProcessor.java
create mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/counter/TestStringCounterProcessor.java
create mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/state/TestStringToStateProcessor.java
create mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/timer/TestStringTimerProcessor.java
copy streampipes-model/src/main/java/org/apache/streampipes/model/datalake/{DataSeries.java => DataSeriesBuilder.java} (51%)
create mode 100644 streampipes-model/src/main/java/org/apache/streampipes/model/datalake/SpQueryResultBuilder.java
create mode 100644 streampipes-model/src/test/java/org/apache/streampipes/model/datalake/DataSeriesBuilderTest.java
create mode 100644 streampipes-model/src/test/java/org/apache/streampipes/model/datalake/SpQueryResultBuilderTest.java
create mode 100644 ui/cypress/tests/adapter/allAdapterActions.smoke.spec.ts
create mode 100644 ui/src/app/connect/dialog/start-all-adapters/all-adapter-actions-dialog.component.html
copy ui/src/app/{add/dialogs/add-endpoint/add-endpoint.component.scss => connect/dialog/start-all-adapters/all-adapter-actions-dialog.component.scss} (100%)
create mode 100644 ui/src/app/connect/dialog/start-all-adapters/all-adapter-actions-dialog.component.ts