This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 42222da46 Merge branch 'master' into rel/0.91.0
add 7b3872b84 [maven-release-plugin] prepare for next development iteration
add ae3676232 chore(release): increase version of python module
add 8351fa0a7 Bump commons-csv from 1.4 to 1.10.0 (#1238)
add 649f666a2 [hotfix] Fix query result response after database uppgrade
add 238c7cd08 chore(docs): describe official support of Java 17 (#1252)
add abb7df163 Fix logging configuration (#1266) (#1267)
add c8f800bd9 Properly override messaging protocol when importing
resources (#1274) (#1275)
add 72a1d0373 fix(python-docs): prevent mkdocs from loading gfonts (#1277)
add c53598674 Bump eslint from 8.33.0 to 8.34.0 in /ui (#1279)
add f599972b3 feature(gh-actions): create workflow that provides python
docs as artifact weekly (#1263)
add 116fe55b2 [#1245] provide a temporary workaround for inconsistency in
eventGrounding (#1250)
add 21491ef53 Bump maven-plugin-annotations from 3.6.0 to 3.7.1
add 867148f10 Bump ddogleg from 0.16 to 0.22
add d21351d7a [hotfix] Remove dependency ddogleg
add 63989d029 Bump @typescript-eslint/eslint-plugin from 5.50.0 to 5.52.0
in /ui (#1284)
add 4f463b690 Add pypi workflow
add 59f6ca4e6 Change token name
add 57becb11c Merge pull request #1280 from SvenO3/github-workflow-for-pypi
add 0c90b2c77 chore: improve python docs and fix some minor
inconsistencies (#1251)
add 99f8111d3 Bump maven-compiler-plugin from 3.8.1 to 3.10.1 (#1282)
add f891d1e01 Bump google-maps-services from 0.10.0 to 2.1.2
add afded8eb6 Bump byte-buddy.version from 1.12.6 to 1.13.0
add 83e8d1839 [hotfix] Remove dependency byte-buddy
add e710ceef2 Bump @typescript-eslint/parser from 5.51.0 to 5.52.0 in /ui
(#1299)
add 14724af4d Provide environment variables via Environment provider
(#1223) (#1224)
add 762c0ab72 Bump maven-deploy-plugin from 2.8.2 to 3.1.0 (#1298)
add 71b7b6f1d [hotfix] Add empty constructor to DataExplorerQuery
add 46bca376b [SP-1102] - GET/v2/info/versions update and removement of
deprecated endpoints (#1192)
add 0c35f6189 [#1308][CI] label-pr workflow fails on fork-based PRs (#1309)
add 633cec8ab remove extentions management module name from its pom (#1295)
add 0c51f2e0a Bump cypress from 12.3.0 to 12.5.1 in /ui (#1305)
add 8d0aea2a4 [#1040] misc changes in runtime names, ad missing fields in
schema
add d6343dcdc [#1040] remove dead code
add 495f0b9ca [#1040] remove supported code in declaire
add c1317a25f [#1040] fix strings due naming changes
add 8f0a3502b Merge pull request #1268 from
apache/1040-change-event-runtime-name-of-geometry-field
add bec082dc6 Bump @types/node from 18.13.0 to 18.14.0 in /ui (#1324)
add 3f903ec61 chore(ui): provide some more references for support in the
'about' view (#1319)
add 7b693a2fd Update data stream generator (#1258) (#1286)
add c8318c5b3 chore(docs): add information on how to develop the UI
locally (#1326)
add 62037abdf [#1296] Swinging Door Trending (SDT) Filter Processor (#1306)
add 417ac009b [hotfix] Use extensions-all-jvm module in backend environment
add 0f6bcf55f Rename endpoint to fetch all pipelines from API (#1333)
(#1334)
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 c307a7bd2 [hotfix] Temporarily revert to snakeyaml 1.33
add c33607da7 [hotfix] Fix configuration for pipeline element development
(#1465)
add 89d183d9c Merge branch 'dev' of github.com:apache/streampipes into dev
add 8503549cf Implement create method in Java PipelineApi (#1467)
add dac406332 Bump activemq-client from 5.17.3 to 5.18.0
add 51db2ee3f Bump spring-core from 6.0.3 to 6.0.7
add a201c5c05 Bump spring boot version
add a771e9f1b Bump Guava version, Bump spring-security version
add adc1d62af Add properties-migrator to dependency management
add c18643663 Improve data explorer query management (#1406) (#1407)
add eb4b9cbc2 Migrate KafkaPublisher (#1473)
add c627add09 Bump jasmine-core from 4.5.0 to 4.6.0 in /ui (#1474)
add 49c2f53b2 Bump @typescript-eslint/eslint-plugin from 5.55.0 to 5.57.1
in /ui
add fa69191b5 Provide database name in query object (#1479)
add cdcd83ea2 [#1289] Fix cypress test for data lake configuration (#1480)
add 1dcc11b5b [hotfix] Improve handling of count queries, improve table
widget (#1484)
add 07494bf59 Bump mkdocstrings[python] in /streampipes-client-python
(#1487)
add 50ddf52e4 [SP-1367] fix typo
add b0d235fb2 Bump mypy from 1.1.1 to 1.2.0 in /streampipes-client-python
(#1494)
add 3e5e57a62 Refactor method name in Kafka messaging layer (#1490)
add b66c6dd93 Bump rdf4j.version from 3.5.0 to 4.2.3 (#1472)
add b5f16f79c Bump animal-sniffer-annotations from 1.22 to 1.23 (#1469)
add 59915fa46 [hotfix] adapt image links in python docs (#1496)
add c73dbf6c7 [hotfix] Move sp-split-section to shared-ui module (#1497)
add 5e24be6b6 Bump log4j.version from 2.19.0 to 2.20.0 (#1499)
add cbae1b891 Bump pytest from 7.2.1 to 7.3.0 in
/streampipes-client-python (#1498)
add cb529cc98 #1107 Implementation of `OSV-scanner` with `gh-action`
(#1438)
add 9694615e5 [hotfix] Fix handling of count queries in data explorer
(#1501)
add 6920dafcb [hotfix] Improve layout of basic view
add 353cdd86e Bump mkdocs-awesome-pages-plugin in
/streampipes-client-python
add 31c68401a Bump zstd-jni from 1.4.3-1 to 1.5.5-1
add 71f931834 [hotfix] Remove zstd-jni from dependencies
add 5ef29883d Bump peter-evans/create-pull-request from 4 to 5
add 2308d9a9c [SP-1504] Do not remove streams on pipeline export (#1505)
add 4bd34bfb8 Bump pandas-stubs in /streampipes-client-python (#1506)
add 45775ec9a Bump maven-plugin-plugin from 3.7.0 to 3.8.1 (#1507)
add c5ec75cbc Sp 1367 Use QueryResult as return type for data lake measure
API (#1492)
add 1f1e29615 [release] update issue template & release notes
add 182649f44 Remove dependency 'reflections' (#1508)
add 8df326c7e Bump autoflake from 2.0.0 to 2.1.0 in
/streampipes-client-python (#1509)
add 14b996a8d Merge branch 'dev' of github.com:apache/streampipes into dev
add 57a342526 [hotfix] remove latest alias for dev python docs (#1515)
add f2a00425d [FEATURE] add division as operation for data harmonization
rules (#1517)
add ca9742e7a #1518 Add variable to set location of checkstyle base path
(#1519)
add 879a4a963 feature: add workflow that stales PRs (#1524)
add df636d22f [hotfix] adapt configuration of stale bot
add 36feed7c6 Bump mkdocs-gen-files from 0.4.0 to 0.5.0 in
/streampipes-client-python (#1525)
add 5d755aa9b Bump type-parser from 0.7.0 to 0.8.1 (#1510)
add 5674efe41 Map http 404 to Java Optional.empty [#1520] (#1521)
add 49680ba81 Semantic type dropdown UI fixes (#1526)
add d302b2f30 Bump jetty-server from 10.0.10 to 10.0.14 (#1512)
add 0d393efe0 Bump karma-chrome-launcher in
/ui/projects/streampipes/platform-services (#1516)
add ce1ff80b3 Bump types-requests in /streampipes-client-python (#1536)
add 7f2d6d216 Added vulnerability report (#1535)
add faf94210a [hotfix] add missing header for VULNERABILITY.md
add 3a7322d55 Bump spring-core from 6.0.7 to 6.0.8 & spring-bot from 3.0.5
to 3.0.6 & spring-security from 6.0.2 to 6.0.3 (#1511)
add 793674e86 Bump flask from 1.1.2 to 2.3.2 in
/streampipes-wrapper-python (#1540)
add 8f2d7d7d6 chore(deps): bump several dependencies to resolve
vulnerability issues (#1539)
add 9965f218e Bump pre-commit from 3.2.0 to 3.3.0 in
/streampipes-client-python (#1541)
add f3d8782f9 Bump jackson.version from 2.14.1 to 2.15.0 (#1542)
add 0d0176d07 chore: add header to file & refine reviewers (#1537)
add 3f7324e72 [hotfix] exclude versions file from pydocs update (#1532)
add a01f0941d Add integration test for MQTT (#1485) (#1489)
add 93f55a3d2 Bump consul from 1.17.6 to 1.18.0 (#1545)
add d957e7ec1 Bump commons-compress from 1.22 to 1.23.0 (#1550)
add 810829f08 [hotfix] Add import of shared-ui module to profile module
(#1548)
add d33800790 Python Functions: Distinction between consumer and publisher
(#1523)
add 8c1530fe8 Bump opencsv from 5.5.2 to 5.7.1 (#1552)
add e4c5d63ba Bump engine.io and socket.io in /ui (#1549)
add 192243dd3 Update README.md
add 90c05e70b Fix logo url of email templates (#1527) (#1554)
add ca97eb1f7 Fetch principalId instead of username when changing user
password (#655) (#1553)
add 7e8e5978d [hotfix] fix exclusion of versions-file in pydoc generation
add b0b5f9e66 [hotfix] exclude versions-file in pydoc generation
add 9b0ba98e3 [1475] fulfill PEP 561 & exclude test files from package
(#1555)
add f96999cc9 [1051] add further badges to readme of python client (#1556)
add 6700ce6a3 Bump types-requests in /streampipes-client-python (#1558)
add 1f0ced0d5 Bump pyupgrade from 3.3.1 to 3.4.0 in
/streampipes-client-python (#1559)
add e271aa245 Bump google-maps-services from 2.1.2 to 2.2.0 (#1560)
add 034fa79ac Bump jackson-databind from 2.14.1 to 2.15.0 (#1562)
add f8f8e5113 [1259] verify authentication on startup of python client
(#1557)
add 6361b97dd Bump retrofit from 2.5.0 to 2.9.0 (#1565)
add b47b811fe Add configuration view to create labels (#1564) (#1568)
add ca3642727 Bump mypy from 1.2.0 to 1.3.0 in /streampipes-client-python
(#1566)
add 116ed2e8b Fix input of standalone dashboard component (#1547)
add fd5d83756 Merge pull request #1569 from
apache/1547-standalone-dashborad-empty
add 4be2a6443 Bump annotations from 16.0.2 to 24.0.1 (#1570)
add 3417335aa Remove guice from dependencies (#1571)
add eddb9b082 Bump amqp-client from 5.16.0 to 5.17.0 (#1574)
add 1e544d067 Bump tubemq-client from 1.5.0 to 1.6.0 (#1577)
add 7b9d94df1 1411 create custom error page for python docs (#1572)
add ac2ca7977 [maven-release-plugin] prepare branch @{releaseLabel}
add 16688233a [hotfix] Update API docs version
add f97b05df6 chore: mark streampipes-wrapper-python as deprecated (#1623)
add fec887145 [hotfix] Add proper time selection to another cypress test
(#1641)
add de4e3904f [hotfix] Add release notes for 0.92.0 release
add 139ee45d5 [hotfix] Update release version in bug_report.yml
add 1e67ca4af [hotfix] Update release version for archetypes
add b4f2e9f70 [hotfix] Update release version for ui
add 0da8f30c8 [hotfix] Update release version for all installers
add 34e6f4adf [maven-release-plugin] prepare release release/0.92.0
add 025667dd3 [maven-release-plugin] prepare for next development iteration
add f9fa532e0 Revert changes for release
add 4e553fd62 [hotfix] Remove SNAPSHOT suffic from package-lock.json
add 8154ffa2c [maven-release-plugin] prepare release release/0.92.0
add fcd310b84 [maven-release-plugin] prepare for next development iteration
add 9db000c65 [hotfix] Rollback release
add fb07b40c5 [hotfix] Remove SNAPSHOT from package-lock.json
add 1ee4ab315 [maven-release-plugin] prepare release release/0.92.0
add 959f0fb06 [maven-release-plugin] prepare for next development iteration
add dcf70357e [hotfix] Rollback release due to failing integration test
add 2b495bfa3 [hotfix] Rollback release
add 07e2ad209 [maven-release-plugin] prepare release release/0.92.0
add 40ca51775 [maven-release-plugin] prepare for next development iteration
add 52a9b2f26 [hotfix] Revert release
add e7e0a6b70 [hotfix] Rollback release
add f02d710b4 [maven-release-plugin] prepare release release/0.92.0
add abd900063 [maven-release-plugin] prepare for next development iteration
add b0a364971 [hotfix] Rollback release
add 9b8831fc1 [hotfix] Rollback release
add 38569af62 [maven-release-plugin] prepare release release/0.92.0
new 127806444 Merge release 0.92.0 into master branch
new 9566748c0 [release] Release 0.92.0
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/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 +
.../{ => functions/broker/kafka}/__init__.py | 0
.../{kafka_broker.py => kafka/kafka_consumer.py} | 38 +-
.../broker/{ => kafka}/kafka_message_fetcher.py | 4 +-
.../{nats_broker.py => kafka/kafka_publisher.py} | 45 +-
.../{ => functions/broker/nats}/__init__.py | 0
.../{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} | 0
.../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, 13249 insertions(+), 8527 deletions(-)
create mode 100644 .github/workflows/osv-scanner.yml
create mode 100644 .github/workflows/stale-bot.yml
create mode 100644 VULNERABILITY.md
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
create mode 100644 streampipes-client-python/docs/img/interrogate_badge.svg
create mode 100644
streampipes-client-python/docs/img/streampipes-python-dark.png
copy ui/src/app/core-ui/split-section/split-section.component.html =>
streampipes-client-python/docs/overrides/404.html (62%)
create mode 100644
streampipes-client-python/streampipes/endpoint/api/version.py
create mode 100644
streampipes-client-python/streampipes/functions/broker/consumer.py
copy streampipes-client-python/streampipes/{ =>
functions/broker/kafka}/__init__.py (100%)
rename streampipes-client-python/streampipes/functions/broker/{kafka_broker.py
=> kafka/kafka_consumer.py} (69%)
copy streampipes-client-python/streampipes/functions/broker/{ =>
kafka}/kafka_message_fetcher.py (94%)
copy streampipes-client-python/streampipes/functions/broker/{nats_broker.py =>
kafka/kafka_publisher.py} (57%)
copy streampipes-client-python/streampipes/{ =>
functions/broker/nats}/__init__.py (100%)
copy streampipes-client-python/streampipes/functions/broker/{nats_broker.py =>
nats/nats_consumer.py} (70%)
rename streampipes-client-python/streampipes/functions/broker/{nats_broker.py
=> nats/nats_publisher.py} (66%)
copy
streampipes-extensions/streampipes-processors-geo-jvm/src/main/resources/org.apache.streampipes.processors.geo.jvm.jts.processor.reprojection/strings.en
=> streampipes-client-python/streampipes/functions/broker/publisher.py (55%)
mode change 100755 => 100644
create mode 100644
streampipes-client-python/streampipes/model/container/versions.py
rename
streampipes-client-python/streampipes/model/resource/{data_lake_series.py =>
data_series.py} (79%)
copy
streampipes-extensions/streampipes-processors-geo-jvm/src/main/resources/org.apache.streampipes.processors.geo.jvm.jts.processor.reprojection/strings.en
=> streampipes-client-python/streampipes/model/resource/exceptions.py (61%)
mode change 100755 => 100644
create mode 100644
streampipes-client-python/streampipes/model/resource/query_result.py
copy streampipes-client-python/streampipes/model/{container/__init__.py =>
resource/version.py} (55%)
copy
streampipes-wrapper-python/streampipes/model/base/abstract_streampipes_entity.py
=> streampipes-client-python/streampipes/py.typed (91%)
rename
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/QueryParams.java
=>
streampipes-commons/src/main/java/org/apache/streampipes/commons/exceptions/SpHttpErrorStatusCode.java
(56%)
delete mode 100644
streampipes-data-explorer-commons/src/main/java/org/apache/streampipes/dataexplorer/commons/configs/CouchDbConfigurations.java
delete mode 100644
streampipes-data-explorer-commons/src/main/java/org/apache/streampipes/dataexplorer/commons/configs/CouchDbEnvKeys.java
delete mode 100644
streampipes-data-explorer-commons/src/main/java/org/apache/streampipes/dataexplorer/commons/configs/DataExplorerConfigurations.java
delete mode 100644
streampipes-data-explorer-commons/src/main/java/org/apache/streampipes/dataexplorer/commons/configs/DataExplorerEnvKeys.java
create mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/DataExplorerQueryManagement.java
rename
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{DataLakeNoUserManagementV3.java
=> DataExplorerSchemaManagement.java} (54%)
delete mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/DataLakeManagementV4.java
create mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/api/IDataExplorerQueryManagement.java
copy
streampipes-client/src/main/java/org/apache/streampipes/client/api/CRUDApi.java
=>
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/api/IDataExplorerSchemaManagement.java
(64%)
copy
streampipes-client/src/main/java/org/apache/streampipes/client/api/CRUDApi.java
=>
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/api/IQueryStatement.java
(78%)
create mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/influx/DataExplorerInfluxQueryExecutor.java
create mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/influx/DataLakeInfluxQueryBuilder.java
rename
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/{RetentionPolicyQueryParams.java
=> DeleteQueryParams.java} (52%)
create mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/ProvidedRestQueryParamConverter.java
rename
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4/ProvidedQueryParams.java
=> param/ProvidedRestQueryParams.java} (86%)
create mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/SelectQueryParams.java
rename
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4/SupportedDataLakeQueryParameters.java
=> param/SupportedRestQueryParams.java} (96%)
rename
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4/params/ColumnFunction.java
=> param/model/AggregationFunction.java} (86%)
rename
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4/query/elements/Offset.java
=> param/model/FillClauseParams.java} (62%)
rename
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4/params/GroupingByTagsParams.java
=> param/model/GroupByTagsClauseParams.java} (56%)
rename
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4/params/GroupingByTimeParams.java
=> param/model/GroupByTimeClauseParams.java} (61%)
rename
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4/params/ItemLimitationParams.java
=> param/model/LimitClauseParams.java} (64%)
rename
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4/params/OffsetParams.java
=> param/model/OffsetClauseParams.java} (64%)
rename
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4/params/OrderingByTimeParams.java
=> param/model/OrderByClauseParams.java} (58%)
rename
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4/params/SelectFromStatementParams.java
=> param/model/SelectClauseParams.java} (50%)
create mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/model/SelectColumn.java
create mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/model/WhereClauseParams.java
rename
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4
=> query}/AutoAggregationHandler.java (64%)
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
create mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/DataExplorerQueryExecutor.java
delete mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/EditRetentionPolicyQuery.java
rename
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4
=> }/query/QueryResultProvider.java (61%)
delete mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/ShowRetentionPolicyQuery.java
rename
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4
=> }/query/StreamedQueryResultProvider.java (84%)
rename
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4
=> }/query/writer/ConfiguredCsvOutputWriter.java (86%)
rename
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4
=> }/query/writer/ConfiguredJsonOutputWriter.java (85%)
rename
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4
=> }/query/writer/ConfiguredOutputWriter.java (89%)
rename
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4
=> }/query/writer/OutputFormat.java (95%)
rename
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4
=> }/query/writer/item/CsvItemWriter.java (94%)
rename
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4
=> }/query/writer/item/ItemGenerator.java (92%)
rename
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4
=> }/query/writer/item/JsonItemWriter.java (95%)
copy
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{sdk
=> querybuilder}/DataLakeQueryOrdering.java (93%)
rename
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4/params/WhereCondition.java
=> querybuilder/FilterCondition.java} (70%)
create mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/querybuilder/IDataLakeQueryBuilder.java
delete mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/sdk/DataLakeQueryBuilder.java
delete mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/template/QueryTemplates.java
rename
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4
=> }/utils/TimeParser.java (97%)
delete mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/params/DeleteFromStatementParams.java
delete mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/params/FillParams.java
delete mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/params/SelectColumn.java
delete mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/params/WhereStatementParams.java
delete mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/DataExplorerQueryV4.java
delete mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/QueryBuilder.java
delete mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/elements/DeleteFromStatement.java
delete mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/elements/FillStatement.java
delete mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/elements/GroupingByTime.java
delete mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/elements/ItemLimitation.java
delete mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/elements/OrderingByTime.java
delete mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/elements/QueryElement.java
delete mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/elements/SelectFromStatement.java
delete mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/elements/TimeBoundary.java
delete mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/elements/WhereStatement.java
delete mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/template/QueryTemplatesV4.java
delete mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/utils/DataLakeManagementUtils.java
create mode 100644
streampipes-data-explorer/src/test/java/org/apache/streampipes/dataexplorer/param/SelectQueryParamsTest.java
rename
{streampipes-rest/src/test/java/org/apache/streampipes/dataexplorer/v4/params
=>
streampipes-data-explorer/src/test/java/org/apache/streampipes/dataexplorer/param}/WhereStatementParamsTest.java
(53%)
rename
streampipes-data-explorer/src/test/java/org/apache/{streampipesdataexplorer/v4
=> streampipes/dataexplorer}/query/writer/TestConfiguredCsvOutputWriter.java
(85%)
rename
streampipes-data-explorer/src/test/java/org/apache/{streampipesdataexplorer/v4
=> streampipes/dataexplorer}/query/writer/TestConfiguredJsonOutputWriter.java
(85%)
rename
streampipes-data-explorer/src/test/java/org/apache/{streampipesdataexplorer/v4
=> streampipes/dataexplorer}/query/writer/TestConfiguredOutputWriter.java (95%)
rename
streampipes-data-explorer/src/test/java/org/apache/{streampipesdataexplorer/v4
=> streampipes/dataexplorer}/query/writer/item/TestCsvItemWriter.java (91%)
rename
streampipes-data-explorer/src/test/java/org/apache/{streampipesdataexplorer/v4
=> streampipes/dataexplorer}/query/writer/item/TestItemWriter.java (94%)
rename
streampipes-data-explorer/src/test/java/org/apache/{streampipesdataexplorer/v4
=> streampipes/dataexplorer}/query/writer/item/TestJsonItemWriter.java (89%)
rename
streampipes-data-explorer/src/{main/java/org/apache/streampipes/dataexplorer/sdk/DataLakeQueryConstants.java
=>
test/java/org/apache/streampipes/dataexplorer/sdk/DataLakeQueryBuilderTest.java}
(59%)
create mode 100644
streampipes-data-explorer/src/test/java/org/apache/streampipes/dataexplorer/utils/ProvidedQueryParameterBuilder.java
create mode 100644
streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter/transform/value/CorrectionValueTest.java
delete mode 100644 streampipes-extensions/.github/workflows/build.yml
create mode 100644
streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/sdt/SwingingDoorTrendingFilter.java
create mode 100644
streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/sdt/SwingingDoorTrendingFilterProcessor.java
create mode 100644
streampipes-extensions/streampipes-processors-filters-jvm/src/main/resources/org.apache.streampipes.processors.filters.jvm.sdt/documentation.md
create mode 100644
streampipes-extensions/streampipes-processors-filters-jvm/src/main/resources/org.apache.streampipes.processors.filters.jvm.sdt/icon.png
create mode 100644
streampipes-extensions/streampipes-processors-filters-jvm/src/main/resources/org.apache.streampipes.processors.filters.jvm.sdt/strings.en
rename
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/params/TimeBoundaryParams.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/v4/params/QueryParamsV4.java
=>
streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/helper/buffer/CapStyle.java
(77%)
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/JoinStyle.java
(76%)
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
copy
streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/{reprojection/ReprojectionProcessor.java
=> bufferpoint/BufferPointProcessor.java} (52%)
copy
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/sdk/DataLakeQueryOrdering.java
=>
streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/validation/ValidationOutput.java
(86%)
mode change 100644 => 100755
copy
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/sdk/DataLakeQueryOrdering.java
=>
streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/validation/ValidationType.java
(85%)
mode change 100644 => 100755
copy
streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/{reprojection/ReprojectionProcessor.java
=> validation/complex/TopologyValidationProcessor.java} (53%)
copy
streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/{reprojection/ReprojectionProcessor.java
=> validation/simple/GeometryValidationProcessor.java} (53%)
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
rename
streampipes-client-python/streampipes/functions/broker/kafka_message_fetcher.py
=>
streampipes-extensions/streampipes-processors-geo-jvm/src/main/resources/org.apache.streampipes.processors.geo.jvm.jts.processor.bufferpoint/strings.en
(51%)
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-extensions/streampipes-processors-geo-jvm/src/main/resources/{org.apache.streampipes.processors.geo.jvm.jts.processor.reprojection
=>
org.apache.streampipes.processors.geo.jvm.jts.processor.validation.complex}/strings.en
(56%)
mode change 100755 => 100644
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-extensions/streampipes-processors-geo-jvm/src/main/resources/{org.apache.streampipes.processors.geo.jvm.jts.processor.reprojection
=>
org.apache.streampipes.processors.geo.jvm.jts.processor.validation.simple}/strings.en
(55%)
mode change 100755 => 100644
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
delete mode 100644
streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/kafka/KafkaController.java
create mode 100644
streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/kafka/KafkaPublishSink.java
delete mode 100644
streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/kafka/KafkaPublisher.java
create mode 100644
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/adapters/MqttAdapterTester.java
create mode 100644
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/containers/MosquittoContainer.java
rename
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/model/Order.java
=>
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/containers/MosquittoDevContainer.java
(78%)
copy
streampipes-wrapper-python/streampipes/model/base/abstract_streampipes_entity.py
=> streampipes-integration-tests/src/test/resources/mosquitto.conf (91%)
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
delete mode 100644
streampipes-platform-services/src/main/java/org/apache/streampipes/ps/DataLakeMeasureResourceV3.java
create mode 100644 ui/cypress/tests/adapter/allAdapterActions.smoke.spec.ts
create mode 100644 ui/cypress/tests/dashboard/standaloneDashboardTest.spec.ts
create mode 100644
ui/projects/streampipes/platform-services/src/lib/apis/labels.service.ts
copy
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/sdk/DataLakeQueryOrdering.java
=>
ui/projects/streampipes/platform-services/src/lib/model/labels/labels.model.ts
(84%)
copy ui/{src/app/core-ui/split-section/split-section.component.html =>
projects/streampipes/shared-ui/src/lib/components/sp-label/sp-label.component.html}
(67%)
copy
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/sdk/DataLakeQueryOrdering.java
=>
ui/projects/streampipes/shared-ui/src/lib/components/sp-label/sp-label.component.scss
(81%)
create mode 100644
ui/projects/streampipes/shared-ui/src/lib/components/sp-label/sp-label.component.ts
rename ui/{src/app/core-ui =>
projects/streampipes/shared-ui/src/lib/components}/split-section/split-section.component.html
(100%)
rename ui/{src/app/core-ui =>
projects/streampipes/shared-ui/src/lib/components}/split-section/split-section.component.scss
(100%)
rename ui/{src/app/core-ui =>
projects/streampipes/shared-ui/src/lib/components}/split-section/split-section.component.ts
(100%)
create mode 100644
ui/src/app/configuration/label-configuration/edit-label/edit-label.component.html
copy
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/sdk/DataLakeQueryOrdering.java
=>
ui/src/app/configuration/label-configuration/edit-label/edit-label.component.scss
(87%)
rename
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/elements/GroupingByTags.java
=>
ui/src/app/configuration/label-configuration/edit-label/edit-label.component.ts
(50%)
create mode 100644
ui/src/app/configuration/label-configuration/label-configuration.component.html
rename
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/sdk/DataLakeQueryOrdering.java
=>
ui/src/app/configuration/label-configuration/label-configuration.component.scss
(88%)
create mode 100644
ui/src/app/configuration/label-configuration/label-configuration.component.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
