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/01/16 16:51:53 UTC
[streampipes] branch master updated (4538cc494 -> 467dba6c1)
This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 4538cc494 [hotfix] Add workflow_dispatch trigger
add 03ea3766c [maven-release-plugin] prepare branch v 0.70.0
add 77a7c8907 [maven-release-plugin] prepare for next development iteration
add 8ca526568 update snapshot version
add bb4d2fca4 update snapshot version in installer
add 2c1c82f5d [hotfix] Improve x axis representation of line chart
add 2b924ab56 [STREAMPIPES-577] Improve error handling in StreamPipes Connect
add 9b2f7b912 [STREAMPIPES-577] Show live preview for OPC-UA adapter
add 72f19e579 [STREAMPIPES-577] Add check and warning message for bad readings
add c6be99b1e [STREAMPIPES-577] Add event preview to schema editor
add 8aca01778 [STREAMPIPES-577] Let JSON parser support adapter preview
add 1dede1727 [STREAMPIPES-577] More adapters support preview, improve preview appearance
add eeb30dae5 [STREAMPIPES-577] Improve error handling of adapters
add 768dc0b9d [STREAMPIPES-577] Let PLC adapter support preview
add c34d98641 [STREAMPIPES-577] Add missing header
add 91f08672b [STREAMPIPES-577] Improve parsing and preview of datatypes
add c55096f73 [STREAMPIPES-577] Fix wrong assignment of data type
add 7228f5b28 [hotfix] Remove comment
add 4f9958fcd Merge pull request #104 from apache/STREAMPIPES-577
add 672b0aa63 [hotfix] Add missing header
add 723870c3e [STREAMPIPES-577] Improve handling of unknown data types
add 66e5099f7 [hotfix] Properly close PLC connection
add ded2add17 [STREAMPIPES-565] Support broker settings override when importing resources
add 4f2617913 [STREAMPIPES-545] Improve assignment of multiple resource links
add 5459b1088 [hotfix] Move Netio adapters to connect-adapters module
add a1a4c1ec7 [STREAMPIPES-578] Reflect index changes in data download dialog
add a52fd21a0 [hotfix] Avoid refresh on field selection in schema editor
add 06d51d71c [hotfix] Optimize reloading of dashboard queries
add 324d15384 [STREAMPIPES-579] Fetch dashboard data in a single request
add 057636404 [STREAMPIPES-579] Properly initialize dashboard model
add 68a9c4461 Merge pull request #106 from apache/STREAMPIPES-579
add fcb325599 [hotfix] Remove MySQL connectors due to license conflict
add b84110b04 [hotfix] Improve resilience of OPC-UA adapter in subscription mode
add 0f5e68a31 [hotfix] Add button to delete an adapter description
add 329492d96 [STREAMPIPES-580] Refactor the Pulsar sink element
add fa1eb4450 [hotfix] Remove scm tags from extensions pom files
add 88352cd6f Upgrade pulsar version to 2.10.1
add 32429bc9e Fix dependency convergence error.
add e6dac369d Merge pull request #108 from RobertIndie/upgrade-pulsar
add 037cd3426 [STREAMPIPES-565] Let export feature ignore deleted resources
add d4086cea6 add release notes for 0.70.0
add fd36526c9 Merge branch 'dev' of github.com:apache/incubator-streampipes into dev
add 939418914 [hotfix] Extend query builder
add 85621e228 [hotfix] Remove SNAPSHOT versions
add f3f5265cc [hotfix] Add update method to data lake storage API
add 0fbe4acc6 [hotfix] Fix wrong column generation in group by queries
add effeaf640 [hotfix] Extend data lake measurement API
add f526ad2a3 [hotfix] Add option to hide navbar in basic view
add d8fae169e [hotfix] Fix connection retry of opc adapter
add 4c039efb8 [hotfix] Add dialog in case adapter cannot be started
add 0016cecc2 [hotfix] Remove year and week aggregations from data explorer panel
add 26da95851 [hotfix] Improve resize behaviour of data explorer widgets
add 3181e3332 [hotfix] Properly unsubscribe from data explorer subscriptions
add 16fad1327 [hotfix] Show loading spinner in widget toolbar
add d51a6909e [hotfix] Minor code improvement
add ef4a30695 [hotfix] Improve slide mode appearance in data explorer
add 4e248083b [hotfix] Increase length of time-series tooltip label
add dc3e1fe77 [hotfix] Fix tab size in data explorer panel
add 90bdcf422 [hotfix] Improve error handling in data explorer
add 82cc17842 [hotfix] Fix flickering in data explorer slide view
add 0f7152e2e update snakeyaml due to CVEs
add 72c10f170 Merge pull request #109 from pjfanning/patch-1
add 24f60b733 Merge branch 'dev' of github.com:apache/incubator-streampipes into dev
add e45f577d4 [STREAMPIPES-585] Improve error handling for runtime exceptions
add 5d1945b02 [STREAMPIPES-585] Minor refactoring in InfluxStore
add 1d0c9f5d4 [STREAMPIPES-594] Add Nats as messaging protocol
add a10aa9398 [STREAMPIPES-594] Add CLI environment for Nats
add 0ae81b772 [STREAMPIPES-595] Add nats adapter
add f0694c502 [STREAMPIPES-587] fix button tooltip for asset upload
add 6512a3020 fix labels and tool tip in asset view
add 49149920a Merge pull request #111 from apache/fix/some-ui-fixes
add 2cd4bb5ab [hotfix] Fix ui build
add b361dbab0 Use the Pulsar reader to fetch messages in Pulsar adapter
add 66f0bd5a7 Merge pull request #114 from RobertIndie/use-reader
add 9ada7ea32 Bump protobuf-java from 3.16.1 to 3.16.3 in /streampipes-extensions
add db315df49 Merge pull request #112 from apache/dependabot/maven/streampipes-extensions/com.google.protobuf-protobuf-java-3.16.3
add 28d14bf64 Merge branch 'dev' into STREAMPIPES-594
add ec2b779bd [hotfix] Properly integrate jnats version
add 15a9e21d8 [STREAMPIPES-594] Remove wildcard import
add c077f697b Merge pull request #115 from apache/STREAMPIPES-594
add effcd6411 [STREAMPIPES-595] Support authentication in Nats adapter
add 01900d3a2 [hotfix] Add missing licence header
add 9faf658e7 [STREAMPIPES-595] Add nats dependency to SDK bundle
add 07ae32a7f Add basic integration test framework
add 98ceff044 Format the root pom.xml
add 0d349e84a Merge branch 'integration-test' of https://github.com/RobertIndie/incubator-streampipes into dev
add f2c8cb60a [hotfix] Add workflow_dispatch trigger
add e7fef44a3 Fix compilation errors.
add c985769f2 Merge pull request #117 from RobertIndie/integration-test
add f8610e5cd [WIP] Created new components for download stepper
add ca4ed0e50 Merge branch 'dev' into STREAMPIPES-583
add eed5a5a53 Merge branch 'dev' into STREAMPIPES-583
add 9f94cead3 Merge branch 'dev' into STREAMPIPES-583
add 149ba5bb5 Merge branch 'dev' into STREAMPIPES-583
add 323814be3 [WIP] STREAMPIPS-583 working on download service
add 063afdc5f [STREAMPIPES-583] Refactore download component
add 7b5b1993d Merge branch 'dev' into STREAMPIPES-583
add a61d10bca Merge branch 'dev' into STREAMPIPES-583
add 7d433066c [STREAMPIPES-583] Updated file naming for the download
add ca109bb4f [hotfix] Remove cypress download folder
add 3b777aaa9 [hotfix] Add cypress download folder to gitignore
add 4b46c17af [STREAMPIPES-583] Add first cypress e2e test for the data download
add 141809ca1 [STREAMPIPES-583] Add cypress command to delete download folder
add 1acf16d82 [STREAMPIPES-583] Add cypress tests to download csv and json files
add d6ac241c0 [STREAMPIPES-583] Add test to ignore lines with missing values
add 8fd973401 [STREAMPIPES-593] Update cypress version
add d8e3acb55 [hotfix] Update cypress action in test
add 240644cf6 [hotfix] Change cypress port
add eb09751d2 [hotfix] Update version for angular-jwt
add 44fbe0df4 [hotfix] Decrease version number for angular-jwt
add ed4dc56e8 [hotfix] WIP fixing download dialog bugs
add 89739df13 [STREAMPIPES-583] Fix the test for the download dialog
add 2ead9221d Merge branch 'dev' into STREAMPIPES-583
add 233cd8ce3 Merge pull request #116 from apache/STREAMPIPES-583
add b9c2630e8 Merge branch 'dev' of github.com:apache/incubator-streampipes into dev
add fea44c604 [hotfix] Add missing license header to auto generated file
add e2f5d456c [hotfix] Fix widget configuration e2e test
add bd097fbd3 [STREAMPIPES-600] Add bash script to automatically generate typescript model
add b62c7a02f Bump elasticsearch from 6.6.2 to 6.8.17
add 70fee1716 Merge pull request #119 from apache/dependabot/maven/org.elasticsearch-elasticsearch-6.8.17
add 2846b2640 Bump snakeyaml from 1.26 to 1.31
add dfd73bd09 Merge pull request #118 from apache/dependabot/maven/org.yaml-snakeyaml-1.31
add 4b86c79c2 Merge branch 'dev' of github.com:apache/incubator-streampipes into dev
add 3d3cd1368 [hotfix] Fix ui build
add 1a0a0b416 [hotfix] Update cypress version for PR validation
add 62a993338 Bump snakeyaml from 1.31 to 1.32 in /streampipes-maven-plugin
add ef603dc6b Merge pull request #122 from apache/dependabot/maven/streampipes-maven-plugin/org.yaml-snakeyaml-1.32
add 816284ed9 Bump jackson-databind from 2.13.2.1 to 2.13.4.1
add 5eda8db73 Merge pull request #120 from apache/dependabot/maven/com.fasterxml.jackson.core-jackson-databind-2.13.4.1
add c6882e4eb [STREAMPIPES-597] Add component for adapter configuration header
add c30b1a44c [STREAMPIPES-597] Rename new adapter component to adapter configuration
add 3b87e82f8 [STREAMPIPES-597] Add component to add and edit adapters
add 5738cbb01 [STREAMPIPES-597] Refactor adapter configuration component
add 86a9a82c5 [STREAMPIPES-597] Remove legacy code
add 4be9985d5 [STREAMPIPES-597] Add view to edit adapters
add 649b118aa [STREAMPIPES-597] Very first version of adapter edit is complete
add 3bbfead4b [STREAMPIPES-597] Add component for event schema error hints
add b47c15c68 [STREAMPIPES-597] Integrate cypress component testing
add 177f98768 Merge branch 'dev' into STREAMPIPES-597
add 24bf91bb1 [STREAMPIPES-598] Show pipeline errors in UI
add e3b3576ff [STREAMPIPES-598] Display logs and metrics in UI
add af5806450 [STREAMPIPES-598] Remove obsolete monitoring classes
add 76074de61 Merge branch 'STREAMPIPES-597' into STREAMPIPES-598
add 03ad75f61 [STREAMPIPES-598] Add adapter metrics
add 239c916cd [STREAMPIPES-598] Add adapter log view
add 8b9f27a07 [STREAMPIPES-598] Add logging for adapters
add 1b98ccfac [STREAMPIPES-598] Add breadcrumb navigation to adapter details view
add e12b8e84d [STREAMPIPES-598] Support authenticated monitoring requests
add 8ef976e0a [STREAMPIPES-598] Disable adapter details overview for now
add 2da3a23e7 Merge branch 'dev' into STREAMPIPES-598
add 5ec566409 Merge branch 'dev' into STREAMPIPES-598
add 9ececed75 [STREAMPIPES-598] Fix cypress tests
add 7deedbfca Merge branch 'STREAMPIPES-598' into STREAMPIPES-597
add aa39813de [STREAMPIPES-601] Add ESLint and remove TSLint
add 9c578c1f8 [STREAMPIPES-601] Add prettier to project
add bd022e1c7 Merge branch 'STREAMPIPES-601' into STREAMPIPES-597
add 6b1c0836f [STREAMPIPES-597] Adjusted edit adapter test
add f0423ad16 Merge pull request #123 from apache/STREAMPIPES-597
add a99b7b5f8 [hotfix] Add missing license headers
add c06c51ed2 [STREAMPIPES-603] Add standalone functions
add b299964ba [STREAMPIPES-603] Show monitoring info for functions in pipeline overview
add 312823978 [hotfix] Change PR validation rat configuration
add 20bbe29da [hotfix] Change validation for PRs
add 75af67f7e Merge branch 'dev' of github.com:apache/incubator-streampipes into dev
add c445d4e27 [STREAMPIPES-603] Add breadcrumbs
add fc5aa42a0 Merge branch 'dev' into STREAMPIPES-597
add bf99bbae7 [STREAMPIPES-597] Add warning schema message when adapter is edited
add da04456ba [STREAMPIPES-597] Update data source when adapter is edited
add a711dbc3d Merge branch 'dev' into STREAMPIPES-597
add 8fcc53001 Merge branch 'dev' into STREAMPIPES-597
add 7b689d5f0 Update cypress.config.ts
add 8d229a4fe Merge pull request #124 from apache/STREAMPIPES-597
add b8c679aa5 [STREAMPIPES-602] Bump Angular to v14, update dependencies
add 5758aba0b [STREAMPIPES-598] Show adapter metrics in overview
add 302fcc348 [STREAMPIPES-603] Improve registration of functions
add 40fcd1445 [hotfix] Extend constructor of ts storage
add a945b84a7 [hotfix] Show horizontal scrollbar in data explorer table widget
add 3a3140243 [STREAMPIPES-603] Add config extractor to function definition
add 07bdbcfe7 [hotfix] Fix bug when unregister function
add 8bf2740cb [STREAMPIPES-604] Add NGINX volume to compose deplyment
add 6b8266d1b Add nginx config volumes to compose/
add 860dc4094 [WIP] Check if adapter is used within a pipeline
add 2549506ae [hotfix] Remove old pipeline service
add b2629d7b6 Merge branch 'dev' into STREAMPIPES-597
add d7b044def [STREAMPIPES-597] add typescript client function to get pipelines containing element
add 239365a8a [hotfix] add dialog class suffix to eslint
add 0d43a8fb5 [STREAMPIPES-597] add dialog that indicates when an adapter can not be edited
add ed40ad24b [STREAMPIPES-597] Add backend code to get all pipelines containing a specific pipeline element
add f795c7f35 Merge branch 'dev' into STREAMPIPES-597
add c8c5a4bce [hotfix] Add missing license header
add 48f235a16 Merge pull request #127 from apache/STREAMPIPES-597
add 2f8e8a896 [STREAMPIPES-611] Support retrieval of DataLakeMeasure in client API
add 59a071017 [hotfix] Improve logging of incomplete events when writing to event storage
add 03b7cf6c3 Improve the integration test framework
add a461ec251 Let pulsar consumer subscribe to the earliest to avoid data loss.
add b15da110c Fix compilation issue.
add 945e30bca Merge pull request #128 from RobertIndie/improve-integration
add 17a08c6df [hotfix] Fix package.json to prevent out of memory error
add 3e0f7bc0b Merge pull request #129 from SvenO3/dev
add a1ceb2b1f Merge branch 'dev' of github.com:apache/incubator-streampipes into dev
add 84814ed1e [STREAMPIPES-613] Add check if adapter should be started on service restart
add 6d7c6aa1a Add new Moving Average Processor
add f83036a9d Merge pull request #131 from SvenO3/dev
add 861ca23f2 [STREAMPIPES-625] Refactor the Pulsar Protocol Adapter
add 48b57469d [hotfix] Reduce logging output
add a9a00162b Merge branch 'dev' of github.com:apache/incubator-streampipes into dev
add 3f94b0501 [hotfix] Fix bug in function handler
add d27ea6633 [hotfix] Reuse database client in data explorer queries
add f688e7a81 [hotfix] Properly add date range to data download request
add f45c9d230 [STREAMPIPES-612] Add builder pattern for GenericAdapterStreamDescriptions
add 49ea97c04 Merge pull request #130 from apache/STREAMPIPES-612
add abeffd7c0 Merge branch 'dev' of github.com:apache/incubator-streampipes into dev
add f217c2b33 [STREAMPIPES-618] Fix wrong time selection in data explorer
add 75e0bba78 [STREAMPIPES-616] refactor cumsum processor
add 9c798d8c6 Update streampipes-extensions/streampipes-processors-change-detection-jvm/src/main/java/org/apache/streampipes/processors/changedetection/jvm/welford/WelfordChangeDetection.java
add d46230c50 Update streampipes-extensions/streampipes-processors-change-detection-jvm/src/main/resources/org.apache.streampipes.processors.changedetection.jvm.cusum/documentation.md
add ba7f9d891 Update streampipes-extensions/streampipes-processors-change-detection-jvm/src/main/resources/org.apache.streampipes.processors.changedetection.jvm.cusum/strings.en
add bed912818 Update streampipes-extensions/streampipes-processors-change-detection-jvm/src/main/resources/org.apache.streampipes.processors.changedetection.jvm.welford/strings.en
add 70a275724 Merge pull request #132 from apache/chore/STREAMPIPES-616
add afe0a3fc4 Merge branch 'dev' of github.com:apache/incubator-streampipes into dev
add d405ca066 [STREAMPIPES-619] Improve edit mode behaviour in data explorer
add 9ef0480de [STREAMPIPES-620] Properly cleanup subscriptions of data explorer widgets
add 945610a50 [STREAMPIPES-621] Add option to load incomplete events into data explorer
add 71b53f822 [STREAMPIPES-621] Change default behaviour for missing value in data explorer
add 6d7bccce5 Merge pull request #135 from apache/STREAMPIPES-621
add 142540b77 [STREAMPIPES-617] allow user to access API docs from the `Profile` menu
add eb55c3d10 [STREAMPIPES-617] adapt quote style in import
add 157ae8fe5 [STREAMPIPES-617] fix version of API docs
add 346092169 Merge pull request #133 from apache/chore/STREAMPIPES-617
add 7efb5dfed Initial commit
add 8518bb2e4 Add license headers
add 80d1b71bf Change Makefile
add ea0adc083 Merge pull request #134 from kulbachcedric/STREAMPIPES-606-python-client
add 9f2c25883 Bump spring-security-core from 5.6.4 to 5.6.9
add 2ee1c4383 Merge pull request #136 from apache/dependabot/maven/org.springframework.security-spring-security-core-5.6.9
add 8c61b006a [STREAMPIPES-622] Modify README intro text, add animated screenshots
add 599cc3012 [STREAMPIPES-622] Improve README structure
add 93a623b75 [#STREAMPIPES-622] Modify feature texts
add efc5b417b [STREAMPIPES-622] Modify introduction text
add 870920bad [STREAMPIPES-622] Fix some links in README file
add 3e6cb6640 [STREAMPIPES-622] Add teaser image
add 7f4147bf5 [hotfix] Update contribution section in README
add d69998853 Merge branch 'STREAMPIPES-622' of github.com:apache/incubator-streampipes into STREAMPIPES-622
add e755fe52d [STREAMPIPES-622] Change image path to dev
add 806299f23 Merge pull request #138 from apache/STREAMPIPES-622
add 53f14a30d [STREAMPIPES-623] Change name timestamp field for data export
add d23f99819 [STREAMPIPES-623] Updated the timestamp fields for all cypress tests
add bb7606fbf Merge branch 'dev' into STREAMPIPES-623
add c89212ab7 [STREAMPIPES-623] Add source and schema info to events in StreamPipesFunctions
add 01bead83d Merge pull request #137 from apache/STREAMPIPES-623
add 5b812eda9 [hotfix] Extend data explorer query builder
add 6fdc6690a STREAMPIPES-626: RocketMQ Support
add a57e51ea8 address_review_comments
add a57a147b2 address_review_comments
add 5c0b27af5 Merge pull request #139 from vesense/rocketmq_support
add d302769d0 [STREAMPIPES-626] Update RocketMQ icons and add template for docker-compose files
add 211fe9f11 Merge branch 'rocketmq_support' into dev
add 05cb33188 [STREAMPIPES-607] finalize Python setup
add 8be545a94 [STREAMPIPES-607] implement basic class structure & first version of the client itself
add eb230905b [STREAMPIPES-608] implement data lake measure endpoint
add 6262e5d64 [STREAMPIPES-607] provide initial README
add 24e5c9c4e [STREAMPIPES-607] add quickstart section to README
add f8f0ad110 [STREAMPIPES-607] add missing Apache headers
add 9e34d305d [STREAMPIPES-607] fix pre-commit config file
add f31ee9e67 [STREAMPIPES-607] improve Python README
add 14c97c132 provide default port for https connection
add 20dada245 adapt test
add 327ab1407 [STREAMPIPES-633] Add new default get method to PipelineResource
add 52b3e5ea6 Merge pull request #141 from apache/STREAMPIPES-633
add 7c08bf5d1 [STREAMPIPES-625] Merge master
add 327d01e2b Merge pull request #144 from RobertIndie/add-sub
add 947b8ee30 Feature/streampipes 627 (#142)
add 7b7b860e7 [STREAMPIPES-637] Remove incubating references from source code
add d511c435c Provide RocketMQ 5.0.0 Dockerfile and docker-compose.yml files
add a7e377fae [STREAMPIPES-589] Explicitly name MIT-licsensed files in LICENSE
add d15065ad9 [STREAMPIPES-588] Use range in NOTICE file
add 655cdc7a2 Merge branch 'dev' of github.com:apache/streampipes into dev
add fbbe78677 Streampipes 634 - ADD MkDocs Documentation (#143)
add 896994031 [STREAMPIPES-591] Prevent tests from failing with Java 17+
add d0300e2e5 [STREAMPIPES-590] add licence header to resource files
add e3c1c660c [STREAMPIPES-566] Fix query download, improve code structure
add 3ae6e5375 [STREAMPIPES-566] Delete unused classes
add e7123dbdc [STREAMPIPES-566] Add license header
add 4aeef8b3a [STREAMPIPES-566] Do not use wildcard imports
add 50af75b11 [STREAMPIPES-566] Add basic tests
add c6ad8b85a [STREAMPIPES-566] Use time field index over fixed assignment
add d9ae947a3 [hotfix] Add tsconfig to fix ui build in github actions
add f134cf1f7 Bump postgresql from 42.4.1 to 42.4.3
add f21ccb263 Merge pull request #153 from apache/dependabot/maven/org.postgresql-postgresql-42.4.3
add b69929063 Merge branch 'dev' of github.com:apache/streampipes into dev
add 66e8d970f [STREAMPIPES-648] Add license header check to checkstyle.xml
add cd4243bfa hotfix: update docs to remove incubator status
add af8785b04 [STREAMPIPES-649] Update REST API for data streams
add 9e6f11781 [STREAMPIPES-651] Activate Github issues
add cb952d168 STREAMPIPES-607: Add `get()` method to API endpoint (#157)
add 80716cd18 [STREAMPIPES-651] Temporarily send notifications to commits list
add bc5a175ae [hotfix] Fix notifications block in asf.yaml
add e201a7cf5 Create data stream endpoint for python client (#152)
add d7cb2fe68 770 issue templates (#807)
add 155a4603b Add user roles for asset management (#813)
add 3929afc24 [hotfix] Avoid document conflicts when handling adapter registration
add 73af6c9a2 [hotfix] Fix exception logging for unavailable endpoints
add f9f67c2ec [hotfix] Increase retry time to avoid document conflict
add 064f49152 Merge branch 'dev' of github.com:apache/streampipes into dev
add 01a9bb622 [hotfix] Allow data explorer admin role to remove widgets
add 7f27c5f98 [hotfix] Allow app users generic storage access
add b388991e6 [hotfix] Add offset to query builder
add f8912c9f4 Store data views and dashboards as non-public elements (#821)
add 74e44d55b Let discussions also happened in the dev mailing list
add c046a067d Merge pull request #816 from RobertIndie/discussion
add 5cf66dc64 Enable check style for `streampipes-integration-test`
add d377291b7 Merge pull request #814 from RobertIndie/check-integration
add 11153c3b5 Merge branch 'dev' of github.com:apache/streampipes into dev
add dce159811 [hotfix] Shorten longer username in profile menu to prevent overflow
add 84d2dfe8f Add docker-compose and CLI environments for Nats messaging option (#818)
add a981586d0 Always sort data explorer fields by name (#817)
add 1e680aa07 Ignore case when fetching users from database (#822)
add 2f67afd16 Add nats to k8s installation config (#818)
add ae4a2ab23 Remove obsolete volumes, cleanup pvc handling (#818)
add b11227ed5 Enable checkstyle for streampipes-messaging
add abcbe8a8f Enable checkstyle for streampipes-messaging-jms (#820)
add 855c5a6a1 Enable checkstyle for streampipes-messaging-nats (#820)
add 877e2816a Activate checkstyle in pom (#820)
add be6e9540b Deactivate checkstyle line ending rule (#820)
add a08d295ef [hotfix] Resolve checkstyle issues due to merge conflicts
add 99a6b8b68 Merge branch 'SP-820' of github.com:apache/streampipes into SP-820
add 1fe4ac5f0 Enable checkstyle for streampipes-messaging-kafka (#820)
add c7bfc4b1a Enable checkstyle for streampipes-messaging-mqtt (#820)
add 7f2a8be88 Enable checkstyle for streampipes-rest (#820)
add 6f72d49ae [hotfix] Remove old route that is no longer used
add bb71313fa Merge branch 'dev' into STREAMPIPES-814
add 152f9ea1e Merge remote-tracking branch 'origin/STREAMPIPES-814' into SP-820
add 35d55faf2 Merge pull request #827 from apache/SP-820
add d79d057bd [#830] enable checkstyle for streampipes-archetype-extensions-jvm (#831)
add 34cbd5867 [#833] enable checkstyle for streampipes-archetype-pe-processors-flink (#836)
add 54005abfd [#834] enable checkstyle for streampipes-commons (#837)
add fa779c49b [#838] enable checkstyle for streampipes-container-extensions (#839)
add e2e95563d [#832] enable checkstyle for streampipes-archetype-pe-sinks-flink (#835)
add 6837e12d0 [#808] simplify & update PR template (#840)
add a0080b96a [#805] create custom release notes configuration (#829)
add 19d4f6ca1 add-checkstyle-streampipes-service (#845)
add a0a9909ed Rename artifact `integration` to `streampipes-integration-tests`.
add 694031887 Simplify checkstyle configuration.
add 26b198c06 Simplify checkstyle violation configuration.
add a9912fe94 Merge pull request #851 from RobertIndie/simplify-checkstyle
add e1af7694e [#820] enable checkstyle for some extension modules
add 81e081c43 Fix the checkstyle plugin doesn't fail on violation
add d8687e56f Set inherited of parent pom to false
add 83a51757d [#820] enable checkstyle for adapters in extensions
add fd20ba661 [hotfix] Update checkstyle plugin as described in #851
add eef2f2403 hotfix: remove incubator status in streampipes-client-python (#852)
add 51c73443f [hotfix] Remove obsolete build config from ui
add 23a7a66ff [release] Bump development version to 0.90.0-SNAPSHOT
add e9b905f60 [release] Use next snapshot version in archetypes
add c6a6cf6c7 [release] Use next snapshot version in installer module
add e11e98b84 [release] Use next snapshot version in ui module
add 530277ac0 [maven-release-plugin] prepare branch @{releaseLabel}
add a40630c14 [release] Update OpenAPI version
add 1d667eacc add section about dependency updates to release notes (#906)
add f7860e785 [hotfix] fix header style
add b01f02e43 [release] Add release notes for upcoming version
add f3e71a99c [hotfix] Update year in NOTICE file
add cbb0f8c66 [release] Update release version in bug report template
add 74d313853 [release] Update StreamPipes version in archetype POMs
add 26a6ca988 [release] Update project version in UI
add ceda41c71 [release] Update StreamPipes version of installers
add 4a9a8f38e [maven-release-plugin] prepare release release/0.90.0
new 467dba6c1 Merge remote-tracking branch 'origin/master' into HEAD
The 1 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:
.asf.yaml | 13 +-
.github/ISSUE_TEMPLATE/bug.md | 47 --
.github/ISSUE_TEMPLATE/bug_report.yml | 115 ++++
.github/ISSUE_TEMPLATE/config.yml | 27 +
.../ISSUE_TEMPLATE/doc_website_issue_report.yml | 91 +++
.github/ISSUE_TEMPLATE/feature.md | 35 --
.github/ISSUE_TEMPLATE/maintainer_fast_track.yml | 31 +
.github/PULL_REQUEST_TEMPLATE.md | 32 +-
.github/release.yml | 41 ++
.github/workflows/cypress-test.yml | 2 +-
.github/workflows/pr-validation.yml | 79 ++-
.gitignore | 3 +
.idea/runConfigurations/backend.xml | 11 +-
DISCLAIMER | 5 -
LICENSE | 10 +-
NOTICE | 4 +-
README.md | 112 ++--
RELEASE_NOTES.md | 79 +++
RELEASE_VALIDATION.md | 4 +-
.../streampipes-archetype-extensions-jvm/pom.xml | 8 +-
.../src/main/resources/archetype-resources/pom.xml | 2 +-
.../strings.en | 17 +
.../__package__.pe.__packageName__.sink/strings.en | 17 +
.../pom.xml | 8 +-
.../src/main/resources/archetype-resources/pom.xml | 2 +-
.../streampipes-archetype-pe-sinks-flink/pom.xml | 8 +-
.../src/main/resources/archetype-resources/pom.xml | 2 +-
create-client-model.sh | 25 +
images/streampipes-connect.gif | Bin 0 -> 949971 bytes
images/streampipes-data-explorer.gif | Bin 0 -> 543486 bytes
images/streampipes-overview.png | Bin 0 -> 661478 bytes
images/streampipes-pipelines.gif | Bin 0 -> 1296806 bytes
installer/README.md | 13 +-
installer/cli/.env | 8 +-
installer/cli/README.md | 13 +-
.../cli/deploy/standalone/rocketmq/Dockerfile | 76 +++
.../standalone/rocketmq/docker-compose.dev.yml | 33 ++
.../deploy/standalone/rocketmq/docker-compose.yml | 82 +++
.../cli/deploy/standalone/ui/docker-compose.yml | 5 +
installer/cli/environments/backend-nats | 22 +
installer/cli/environments/basic-nats | 20 +
installer/cli/environments/lite | 3 +-
installer/cli/environments/lite-nats | 24 +
installer/cli/environments/pipeline-element-nats | 24 +
installer/compose/.env | 2 +-
installer/compose/README.md | 32 +-
installer/compose/docker-compose.full.yml | 5 +
installer/compose/docker-compose.nats.yml | 135 +++++
installer/compose/docker-compose.yml | 4 +
installer/k8s/Chart.yaml | 13 +-
installer/k8s/README.md | 13 +-
.../k8s/templates/core/backend-deployment.yaml | 4 +-
.../extensions-all-jvm-deployment.yaml | 7 -
.../extensions/pipeline-elements/files-pvc.yaml | 42 --
.../sources-vehicle-simulator-deployment.yaml | 41 --
.../sources-vehicle-simulator-service.yaml | 31 -
.../sources-watertank-simulator-deployment.yaml | 41 --
.../templates/external/kafka/kafka-deployment.yaml | 2 +
.../k8s/templates/external/kafka/kafka-pvc.yaml | 2 +
.../templates/external/kafka/kafka-service.yaml | 2 +
.../templates/external/nats/nats-deployment.yaml | 41 ++
.../k8s/templates/external/nats/nats-service.yaml | 30 +
.../external/zookeeper/zookeeper-deployment.yaml | 2 +
.../external/zookeeper/zookeeper-pvc.yaml | 2 +
.../external/zookeeper/zookeeper-service.yaml | 2 +
installer/k8s/values.yaml | 4 +-
pom.xml | 571 ++++++++++++++++--
streampipes-backend/pom.xml | 14 +-
.../backend/StreamPipesBackendApplication.java | 13 +
.../backend/StreamPipesResourceConfig.java | 4 +-
.../backend/migrations/AvailableMigrations.java | 4 +-
.../v090/UpdateUsernameViewMigration.java | 61 ++
.../src/main/resources/openapi.yaml | 2 +-
streampipes-client-python/.coveragerc | 24 +
streampipes-client-python/.gitignore | 262 ++++++++
streampipes-client-python/.pre-commit-config.yaml | 78 +++
streampipes-client-python/DEVELOPMENT.md | 76 +++
streampipes-client-python/Makefile | 52 ++
streampipes-client-python/README.md | 102 ++++
.../docs/getting-started/installation.md | 41 ++
.../docs/getting-started/quickstart.md | 68 +++
.../docs/img/how-to-get-api-key.gif | Bin 0 -> 196505 bytes
.../docs/img/streampipes-python.png | Bin 0 -> 192272 bytes
streampipes-client-python/docs/index.md | 102 ++++
streampipes-client-python/docs/overrides/main.html | 47 ++
.../docs/overrides/partials/footer.html | 47 ++
.../docs/scripts/gen_ref_pages.py | 50 ++
.../docs/stylesheets/extra.css | 21 +
streampipes-client-python/mkdocs.yml | 81 +++
streampipes-client-python/setup.py | 110 ++++
.../streampipes_client}/__init__.py | 0
.../streampipes_client/__version__.py | 21 +
.../streampipes_client/client/__init__.py | 22 +
.../streampipes_client/client/client.py | 178 ++++++
.../streampipes_client/client/client_config.py | 59 ++
.../client/credential_provider.py | 151 +++++
.../streampipes_client/endpoint/__init__.py | 23 +
.../endpoint/data_lake_measure.py | 121 ++++
.../streampipes_client/endpoint/data_stream.py | 87 +++
.../streampipes_client/endpoint/endpoint.py | 199 +++++++
.../streampipes_client/model}/__init__.py | 0
.../streampipes_client/model/common.py | 153 +++++
.../streampipes_client/model/container/__init__.py | 24 +
.../model/container/data_lake_measures.py | 53 ++
.../model/container/data_streams.py | 53 ++
.../model/container/resource_container.py | 226 +++++++
.../streampipes_client/model/resource/__init__.py | 24 +
.../model/resource/data_lake_measure.py | 58 ++
.../model/resource/data_lake_series.py | 118 ++++
.../model/resource/data_stream.py | 68 +++
.../streampipes_client/model/resource/resource.py | 43 ++
.../tests}/__init__.py | 0
.../tests/client}/__init__.py | 0
.../tests/client/test_client.py | 70 +++
.../tests/client/test_credential_provider.py | 49 ++
.../tests/client/test_data_lake_series.py | 154 +++++
.../tests/client/test_endpoint.py | 356 +++++++++++
streampipes-client/pom.xml | 18 +-
.../streampipes/client/StreamPipesClient.java | 4 +
.../streampipes/client/api/AbstractClientApi.java | 22 +-
.../client/api/AbstractTypedClientApi.java | 5 -
.../apache/streampipes/client/api/AdminApi.java | 20 +
.../streampipes/client/api/CustomRequestApi.java | 4 +
.../streampipes/client/api/DataLakeMeasureApi.java | 65 ++
.../streampipes/client/api/DataStreamApi.java | 3 +-
.../credentials/StreamPipesApiKeyCredentials.java | 4 +-
.../streampipes/client/http/DeleteRequest.java | 30 +-
.../streampipes/client/http/HttpRequest.java | 2 +-
.../apache/streampipes/client/http/PutRequest.java | 57 ++
streampipes-commons/pom.xml | 20 +-
.../java/org/apache/streampipes/commons/MD5.java | 58 +-
.../commons/constants/DefaultEnvValues.java | 1 +
.../apache/streampipes/commons/constants/Envs.java | 7 +-
.../exceptions/ElementNotFoundException.java | 2 +-
.../RemoteServerNotAccessibleException.java | 48 +-
.../exceptions/SpConfigurationException.java | 2 +-
.../commons/exceptions/SpException.java | 2 +-
.../commons/exceptions/SpRuntimeException.java | 2 +-
.../commons/exceptions/TooManyEdgesException.java | 2 +-
.../commons/exceptions/UserNotFoundException.java | 2 +-
.../exceptions/UsernameAlreadyTakenException.java | 2 +-
.../streampipes/commons/networking/Networking.java | 6 +-
.../streampipes/commons/zip/ZipFileExtractor.java | 6 +-
streampipes-config/pom.xml | 8 +-
.../streampipes/config/backend/BackendConfig.java | 10 +
.../config/backend/BackendConfigKeys.java | 2 +
.../config/backend/MessagingSettings.java | 13 +-
.../streampipes/config/backend/SpProtocol.java | 3 +-
streampipes-connect-api/pom.xml | 4 +-
.../apache/streampipes/connect/api/IProtocol.java | 3 +-
streampipes-connect-container-master/pom.xml | 14 +-
.../master/health/AdapterHealthCheck.java | 195 +++---
.../master/health/AdapterOperationLock.java | 37 ++
.../master/management/AdapterMasterManagement.java | 41 +-
.../master/management/SourcesManagement.java | 147 +++--
.../management/WorkerAdministrationManagement.java | 65 +-
.../master/management/WorkerRestClient.java | 61 +-
.../master/health/AdapterHealthCheckTest.java | 41 +-
.../management/AdapterMasterManagementTest.java | 8 +-
.../master/management/SourcesManagementTest.java | 93 +--
streampipes-connect-container-worker/pom.xml | 16 +-
.../init/ConnectWorkerRegistrationService.java | 3 +-
.../worker/management/AdapterWorkerManagement.java | 6 +
.../worker/rest/AdapterWorkerResource.java | 17 +-
streampipes-connect/pom.xml | 40 +-
.../streampipes/connect/adapter/Adapter.java | 18 +-
.../connect/adapter/AdapterPipelineGenerator.java | 15 +-
.../connect/adapter/GroundingService.java | 39 +-
.../format/json/object/JsonObjectFormat.java | 9 +-
.../preprocessing/elements/DebugAdapterSink.java | 46 ++
.../elements/SendToBrokerAdapterSink.java | 18 +-
.../elements/SendToNatsAdapterSink.java | 36 ++
streampipes-container-extensions/pom.xml | 16 +-
.../extensions/ExtensionsModelSubmitter.java | 42 +-
.../extensions/ExtensionsResourceConfig.java | 9 +-
.../function/FunctionDeregistrationHandler.java | 48 ++
.../function/FunctionRegistrationHandler.java | 46 ++
.../extensions/function/RegistrationHandler.java | 73 +++
.../function/StreamPipesFunctionHandler.java | 71 +++
streampipes-container-standalone/pom.xml | 6 +-
.../PipelineElementServiceShutdownHandler.java | 1 +
streampipes-container/pom.xml | 16 +-
.../container/api/AbstractExtensionsResource.java | 58 ++
.../api/AbstractPipelineElementResource.java | 35 +-
.../api/DataProcessorPipelineElementResource.java | 18 +-
.../api/DataSinkPipelineElementResource.java | 12 +-
.../container/api/MonitoringResource.java | 42 ++
.../declarer/IStreamPipesFunctionDeclarer.java | 35 ++
.../BaseExtensionsServiceResourceProvider.java | 7 +-
.../container/init/DeclarersSingleton.java | 7 +
.../container/model/SpServiceDefinition.java | 11 +
.../model/SpServiceDefinitionBuilder.java | 6 +
.../container/monitoring/SpMonitoringManager.java | 116 ++++
.../container/util/GroundingDebugUtils.java | 34 ++
streampipes-data-explorer-commons/pom.xml | 10 +-
.../dataexplorer/commons/DataExplorerUtils.java | 16 +-
.../dataexplorer/commons/influx/InfluxStore.java | 315 +++++-----
streampipes-data-explorer/pom.xml | 14 +-
.../dataexplorer/DataLakeManagementV4.java | 202 ++-----
.../autoagg/AbstractAutoAggregationQuery.java | 70 ---
.../autoagg/FromNowAutoAggregationQuery.java | 49 --
.../autoagg/GroupedAutoAggregationQuery.java | 48 --
.../autoagg/TimeBoundAutoAggregationQuery.java | 49 --
.../param/AggregatedTimeBoundQueryParams.java | 50 --
.../param/AggregatedTimeUnitQueryParams.java | 51 --
.../dataexplorer/param/CountQueryParams.java | 21 -
.../GroupedAggregatedTimeBoundQueryParams.java | 46 --
.../dataexplorer/param/GroupedQueryParams.java | 42 --
.../dataexplorer/param/PagingQueryParams.java | 95 ---
.../dataexplorer/param/TimeBoundQueryParams.java | 44 --
.../dataexplorer/param/TimeUnitQueryParams.java | 42 --
.../query/GetAggregatedEventsFromNowQuery.java | 47 --
.../query/GetAggregatedEventsQuery.java | 45 --
.../query/GetDateFromSortedTableRecord.java | 69 ---
.../query/GetEventsAutoAggregationQuery.java | 21 -
.../dataexplorer/query/GetEventsFromNowQuery.java | 44 --
.../dataexplorer/query/GetEventsQuery.java | 42 --
.../query/GetGroupedAggregatedEventsQuery.java | 44 --
.../dataexplorer/query/GetGroupedEventsQuery.java | 42 --
.../query/GetHeadersWithTypesQuery.java | 46 --
.../dataexplorer/query/GetMaxPagesQuery.java | 41 --
.../query/GetNumberOfRecordsByTimeUnitQuery.java | 52 --
.../query/GetNumberOfRecordsQuery.java | 51 --
.../dataexplorer/query/GetPagingEventsQuery.java | 72 ---
.../dataexplorer/sdk/DataLakeQueryBuilder.java | 17 +
.../dataexplorer/v4/AutoAggregationHandler.java | 4 +-
.../v4/SupportedDataLakeQueryParameters.java | 3 +
.../dataexplorer/v4/query/DataExplorerQueryV4.java | 36 +-
.../dataexplorer/v4/query/QueryResultProvider.java | 64 ++
.../v4/query/StreamedQueryResultProvider.java | 118 ++++
.../v4/query/writer/ConfiguredCsvOutputWriter.java | 76 +++
.../query/writer/ConfiguredJsonOutputWriter.java | 70 +++
.../v4/query/writer/ConfiguredOutputWriter.java | 53 ++
.../dataexplorer/v4/query/writer/OutputFormat.java | 36 ++
.../v4/query/writer/item/CsvItemWriter.java | 37 ++
.../v4/query/writer/item/ItemGenerator.java | 57 ++
.../v4/query/writer/item/JsonItemWriter.java | 50 ++
.../dataexplorer/v4/utils/TimeParser.java | 48 ++
.../writer/TestConfiguredCsvOutputWriter.java | 52 ++
.../writer/TestConfiguredJsonOutputWriter.java | 53 ++
.../query/writer/TestConfiguredOutputWriter.java | 42 ++
.../v4/query/writer/item/TestCsvItemWriter.java | 48 ++
.../v4/query/writer/item/TestItemWriter.java | 36 ++
.../v4/query/writer/item/TestJsonItemWriter.java | 39 ++
streampipes-data-export/pom.xml | 10 +-
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/README.md | 24 +-
streampipes-extensions/pom.xml | 494 +---------------
.../streampipes-connect-adapters-iiot/pom.xml | 20 +-
.../connect/iiot/ConnectAdapterIiotInit.java | 62 +-
.../connect/iiot/adapters/PullAdapter.java | 114 ++--
.../connect/iiot/adapters/PullRestAdapter.java | 65 +-
.../iiot/adapters/influxdb/InfluxDbClient.java | 493 ++++++++--------
.../iiot/adapters/influxdb/InfluxDbSetAdapter.java | 256 ++++----
.../adapters/influxdb/InfluxDbStreamAdapter.java | 306 +++++-----
.../opcua/MiloOpcUaConfigurationProvider.java | 52 +-
.../connect/iiot/adapters/opcua/OpcNode.java | 195 +++---
.../connect/iiot/adapters/opcua/OpcUaAdapter.java | 417 ++++++-------
.../iiot/adapters/opcua/OpcUaNodeBrowser.java | 18 +-
.../connect/iiot/adapters/opcua/SpOpcUaClient.java | 228 +++----
.../opcua/configuration/SpOpcUaConfig.java | 51 +-
.../opcua/configuration/SpOpcUaConfigBuilder.java | 38 +-
.../adapters/opcua/utils/OpcUaNodeVariants.java | 39 +-
.../iiot/adapters/opcua/utils/OpcUaTypes.java | 57 +-
.../iiot/adapters/opcua/utils/OpcUaUtil.java | 39 +-
.../adapters/plc4x/modbus/ModbusConfigFile.java | 78 +--
.../adapters/plc4x/modbus/Plc4xModbusAdapter.java | 590 +++++++++---------
.../plc4x/passive/Plc4xPassiveAdapter.java | 157 ++---
.../iiot/adapters/plc4x/s7/Plc4xS7Adapter.java | 568 +++++++++---------
.../iiot/adapters/ros/RosBridgeAdapter.java | 326 +++++-----
.../simulator/machine/MachineDataSimulator.java | 238 ++++----
.../machine/MachineDataSimulatorUtils.java | 205 +++----
.../machine/MachineDataStreamAdapter.java | 99 ++--
.../connect/iiot/protocol/set/FileProtocol.java | 195 +++---
.../connect/iiot/protocol/set/HttpProtocol.java | 172 +++---
.../iiot/protocol/stream/BrokerEventProcessor.java | 48 ++
.../iiot/protocol/stream/FileStreamProtocol.java | 130 ++--
.../iiot/protocol/stream/HttpServerProtocol.java | 47 +-
.../iiot/protocol/stream/HttpStreamProtocol.java | 211 +++----
.../iiot/protocol/stream/KafkaProtocol.java | 353 +++++------
.../connect/iiot/protocol/stream/MqttProtocol.java | 39 +-
.../connect/iiot/protocol/stream/NatsProtocol.java | 191 ++++++
.../connect/iiot/protocol/stream/PullProtocol.java | 105 ++--
.../protocol/stream/pulsar/PulsarConsumer.java | 88 ---
.../protocol/stream/pulsar/PulsarProtocol.java | 123 ++--
.../iiot/protocol/stream/pulsar/PulsarUtils.java | 4 +-
.../protocol/stream/rocketmq/RocketMQConsumer.java | 66 +++
.../protocol/stream/rocketmq/RocketMQProtocol.java | 177 ++++++
.../protocol/stream/rocketmq/RocketMQUtils.java | 48 ++
.../connect/iiot/utils/FileProtocolUtils.java | 69 +--
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../documentation.md | 63 ++
.../icon.png | Bin
.../strings.en | 57 ++
.../strings.en | 18 +
.../documentation.md | 32 +
.../icon.png | Bin 0 -> 12775 bytes
.../strings.en | 29 +
.../streampipes-connect-adapters/pom.xml | 14 +-
.../streampipes/connect/ConnectAdapterInit.java | 38 +-
.../streampipes/connect/adapters/PullAdapter.java | 106 ++--
.../connect/adapters/PullRestAdapter.java | 66 ++-
.../adapters/coindesk/CoindeskBitcoinAdapter.java | 30 +-
.../connect/adapters/coindesk/model/Bpi.java | 60 +-
.../adapters/coindesk/model/CoindeskRawModel.java | 64 +-
.../connect/adapters/coindesk/model/EUR.java | 103 ++--
.../connect/adapters/coindesk/model/GBP.java | 100 ++--
.../connect/adapters/coindesk/model/Time.java | 60 +-
.../connect/adapters/coindesk/model/USD.java | 100 ++--
.../connect/adapters/flic/FlicMQTTAdapter.java | 214 +++----
.../connect/adapters/flic/FlicOutput.java | 41 +-
.../connect/adapters/flic/FlicUtils.java | 62 +-
.../connect/adapters/gdelt/GdeltAdapter.java | 327 +++++-----
.../connect/adapters/iex/IexCloudAdapter.java | 12 +-
.../connect/adapters/iex/IexCloudNewsAdapter.java | 60 +-
.../connect/adapters/iex/IexCloudStockAdapter.java | 34 +-
.../connect/adapters/iex/model/IexNewsData.java | 180 +++---
.../connect/adapters/iex/model/IexStockData.java | 656 ++++++++++-----------
.../connect/adapters/image/ImageZipAdapter.java | 113 ++--
.../connect/adapters/image/ImageZipUtils.java | 16 +-
.../adapters/image/ZipFileImageIterator.java | 117 ++--
.../adapters/image/set/ImageSetAdapter.java | 117 ++--
.../adapters/image/stream/ImageStreamAdapter.java | 119 ++--
.../connect/adapters/iss/IssAdapter.java | 211 +++----
.../connect/adapters/iss/model/IssModel.java | 60 +-
.../connect/adapters/iss/model/IssPosition.java | 40 +-
.../connect/adapters/netio/NetioMQTTAdapter.java | 239 ++++----
.../connect/adapters/netio/NetioRestAdapter.java | 334 ++++++-----
.../connect/adapters/netio/NetioUtils.java | 282 ++++-----
.../adapters/netio/model/NetioAllPowerOutputs.java | 32 +-
.../adapters/netio/model/NetioGlobalMeasure.java | 96 +--
.../adapters/netio/model/NetioPowerOutput.java | 144 ++---
.../adapters/sensemap/OpenSenseMapAdapter.java | 578 +++++++++---------
.../connect/adapters/sensemap/SensorNames.java | 213 ++++---
.../adapters/sensemap/model/CurrentLocation.java | 52 +-
.../connect/adapters/sensemap/model/Geometry.java | 52 +-
.../adapters/sensemap/model/LastMeasurement.java | 40 +-
.../connect/adapters/sensemap/model/Loc.java | 40 +-
.../connect/adapters/sensemap/model/SenseBox.java | 184 +++---
.../connect/adapters/sensemap/model/Sensor.java | 120 ++--
.../simulator/random/RandomDataSetAdapter.java | 19 +-
.../simulator/random/RandomDataSimulatorUtils.java | 22 +-
.../simulator/random/RandomDataStreamAdapter.java | 21 +-
.../connect/adapters/slack/SlackAdapter.java | 35 +-
.../connect/adapters/slack/SlackConsumer.java | 3 +-
.../connect/adapters/ti/TISensorTag.java | 325 +++++-----
.../adapters/wikipedia/WikipediaAdapter.java | 104 ++--
.../wikipedia/WikipediaEditedArticlesAdapter.java | 8 +-
.../wikipedia/WikipediaModelConverter.java | 17 +-
.../wikipedia/WikipediaNewArticlesAdapter.java | 8 +-
.../adapters/wikipedia/WikipediaSseConsumer.java | 2 +-
.../connect/adapters/wikipedia/model/Length.java | 40 +-
.../connect/adapters/wikipedia/model/Meta.java | 180 +++---
.../connect/adapters/wikipedia/model/Revision.java | 40 +-
.../adapters/wikipedia/model/WikipediaModel.java | 338 +++++------
.../streampipes/connect/config/ConfigKeys.java | 12 +-
.../connect/config/ConnectWorkerConfig.java | 6 +-
.../strings.en | 17 +
.../strings.en | 17 +
.../strings.en | 17 +
.../strings.en | 17 +
.../strings.en | 17 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 17 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../streampipes-extensions-all-iiot/pom.xml | 43 +-
.../extensions/all/iiot/AllExtensionsIIoTInit.java | 48 +-
.../streampipes-extensions-all-jvm/pom.xml | 45 +-
.../extensions/all/jvm/AllExtensionsInit.java | 46 +-
.../pom.xml | 37 +-
.../streampipes-pipeline-elements-all-jvm/pom.xml | 45 +-
.../pe/jvm/config/AllPipelineElementsConfig.java | 12 +-
.../pom.xml | 27 +-
.../pe/simulator/StreamPipesSimulationRunner.java | 9 +-
.../streampipes-pipeline-elements-shared/pom.xml | 34 +-
.../pe/shared/PlaceholderExtractor.java | 2 +-
.../pe/shared/config/kafka/KafkaConfig.java | 96 +--
.../pe/shared/config/kafka/KafkaConnectUtils.java | 174 +++---
.../pe/shared/config/kafka/kafka/KafkaConfig.java | 74 +--
.../config/kafka/kafka/KafkaConnectUtils.java | 184 +++---
.../pe/shared/config/mqtt/MqttConnectUtils.java | 112 ++--
.../pe/shared/config/mqtt/MqttConsumer.java | 7 +-
.../pe/shared/config/nats/NatsConfigUtils.java | 71 +++
.../pom.xml | 29 +-
.../flink/AbstractAggregationProgram.java | 13 +-
.../aggregation/flink/AggregationFlinkInit.java | 46 +-
.../aggregation/flink/config/ConfigKeys.java | 8 +-
.../flink/processor/aggregation/Aggregation.java | 7 +-
.../aggregation/AggregationController.java | 101 ++--
.../aggregation/AggregationParameters.java | 96 +--
.../processor/aggregation/AggregationProgram.java | 28 +-
.../processor/aggregation/CountAggregation.java | 11 +-
.../processor/aggregation/TimeAggregation.java | 10 +-
.../flink/processor/count/CountController.java | 44 +-
.../flink/processor/count/CountMapper.java | 5 +-
.../flink/processor/count/CountProgram.java | 21 +-
.../flink/processor/count/CountTrigger.java | 3 +-
.../flink/processor/count/Tuple2MapMapper.java | 3 +-
.../processor/eventcount/EventCountController.java | 40 +-
.../processor/eventcount/EventCountMapper.java | 3 +-
.../eventcount/EventCountOutputMapper.java | 3 +-
.../processor/eventcount/EventCountProgram.java | 12 +-
.../flink/processor/rate/EventRate.java | 7 +-
.../flink/processor/rate/EventRateController.java | 28 +-
.../flink/processor/rate/EventRateParameter.java | 18 +-
.../flink/processor/rate/EventRateProgram.java | 33 +-
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../processor/aggregation/AggregationTestData.java | 2 +-
.../aggregation/TestTimeAggregationProgram.java | 34 +-
.../flink/processor/count/TestCountProgram.java | 22 +-
.../flink/processor/rate/TestRateProgram.java | 37 +-
.../pom.xml | 30 +-
.../jvm/ChangeDetectionJvmInit.java | 46 +-
.../changedetection/jvm/cusum/Cusum.java | 144 ++---
.../changedetection/jvm/cusum/CusumController.java | 79 +--
.../jvm/cusum/CusumEventFields.java | 10 +-
.../changedetection/jvm/cusum/CusumParameters.java | 45 +-
.../jvm/cusum/WelfordAggregate.java | 75 +--
.../jvm/welford/WelfordAggregate.java | 55 ++
.../jvm/welford/WelfordChangeDetection.java | 152 +++++
.../jvm/welford/WelfordEventFields.java | 37 ++
.../documentation.md | 4 +-
.../icon.png | Bin 0 -> 62957 bytes
.../strings.en | 22 +-
.../documentation.md | 59 ++
.../icon.png | Bin 0 -> 62957 bytes
.../strings.en | 29 +
.../streampipes-processors-enricher-flink/pom.xml | 25 +-
.../enricher/flink/AbstractEnricherProgram.java | 13 +-
.../enricher/flink/EnricherFlinkInit.java | 38 +-
.../enricher/flink/config/ConfigKeys.java | 8 +-
.../processor/timestamp/TimestampController.java | 30 +-
.../processor/timestamp/TimestampEnricher.java | 3 +-
.../processor/timestamp/TimestampParameters.java | 20 +-
.../processor/timestamp/TimestampProgram.java | 23 +-
.../urldereferencing/UrlDereferencing.java | 59 +-
.../UrlDereferencingController.java | 63 +-
.../UrlDereferencingParameter.java | 26 +-
.../urldereferencing/UrlDereferencingProgram.java | 23 +-
.../strings.en | 18 +
.../strings.en | 18 +
.../streampipes-processors-enricher-jvm/pom.xml | 30 +-
.../processors/enricher/jvm/EnricherJvmInit.java | 32 +-
.../enricher/jvm/processor/jseval/JSEval.java | 57 +-
.../jvm/processor/jseval/JSEvalController.java | 44 +-
.../jvm/processor/jseval/JSEvalParameters.java | 16 +-
.../jvm/processor/math/MathOpProcessor.java | 63 +-
.../jvm/processor/math/operation/Operation.java | 2 +-
.../math/operation/OperationAddition.java | 8 +-
.../processor/math/operation/OperationDivide.java | 8 +-
.../processor/math/operation/OperationModulo.java | 8 +-
.../math/operation/OperationMultiply.java | 10 +-
.../math/operation/OperationSubtracting.java | 8 +-
.../math/staticmathop/StaticMathOpProcessor.java | 58 +-
.../jvm/processor/sizemeasure/SizeMeasure.java | 3 +-
.../sizemeasure/SizeMeasureController.java | 53 +-
.../trigonometry/TrigonometryProcessor.java | 52 +-
.../valueChange/ValueChangeProcessor.java | 111 ++--
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../streampipes-processors-filters-jvm/pom.xml | 30 +-
.../processors/filters/jvm/FiltersJvmInit.java | 50 +-
.../booleanfilter/BooleanFilterProcessor.java | 79 +--
.../jvm/processor/compose/ComposeProcessor.java | 35 +-
.../processor/enrich/MergeByEnrichProcessor.java | 39 +-
.../jvm/processor/limit/RateLimitProcessor.java | 215 +++----
.../jvm/processor/limit/util/EventSelection.java | 6 +-
.../jvm/processor/limit/util/ProcessJob.java | 11 +-
.../jvm/processor/limit/util/SchedulerUtil.java | 49 +-
.../jvm/processor/limit/util/WindowFactory.java | 46 +-
.../jvm/processor/limit/util/WindowType.java | 6 +-
.../jvm/processor/limit/window/CronWindow.java | 31 +-
.../jvm/processor/limit/window/LengthWindow.java | 84 +--
.../jvm/processor/limit/window/ScheduleWindow.java | 133 ++---
.../jvm/processor/limit/window/TimeWindow.java | 31 +-
.../filters/jvm/processor/limit/window/Window.java | 8 +-
.../jvm/processor/merge/MergeByTimeProcessor.java | 33 +-
.../filters/jvm/processor/merge/StreamBuffer.java | 56 +-
.../movingaverage/MovingAverageProcessor.java | 106 ++++
.../movingaverage/util/MovingAverageFilter.java | 38 ++
.../processor/movingaverage/util/MovingFilter.java | 48 ++
.../movingaverage/util/MovingMedianFilter.java | 42 ++
.../numericalfilter/NumericalFilterProcessor.java | 35 +-
.../NumericalTextFilterProcessor.java | 68 ++-
.../numericaltextfilter/StringOperator.java | 2 +-
.../processor/projection/ProjectionProcessor.java | 23 +-
.../processor/schema/MergeBySchemaProcessor.java | 63 +-
.../jvm/processor/textfilter/StringOperator.java | 2 +-
.../processor/textfilter/TextFilterProcessor.java | 40 +-
.../threshold/ThresholdDetectionProcessor.java | 80 +--
.../throughputmon/ThroughputMonitorProcessor.java | 53 +-
.../strings.en | 17 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../documentation.md | 40 ++
.../strings.en | 29 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 17 +
.../strings.en | 18 +
.../streampipes-processors-filters-siddhi/pom.xml | 32 +-
.../processors/siddhi/FiltersSiddhiInit.java | 36 +-
.../processors/siddhi/count/CountAggregation.java | 77 +--
.../processors/siddhi/filter/NumericalFilter.java | 19 +-
.../siddhi/filter/NumericalFilterController.java | 41 +-
.../siddhi/filter/NumericalFilterParameters.java | 2 +-
.../processors/siddhi/frequency/Frequency.java | 18 +-
.../siddhi/frequency/FrequencyController.java | 31 +-
.../siddhi/frequencychange/FrequencyChange.java | 18 +-
.../frequencychange/FrequencyChangeController.java | 35 +-
.../siddhi/listcollector/ListCollector.java | 70 ++-
.../processors/siddhi/listfilter/ListFilter.java | 32 +-
.../processors/siddhi/sequence/Sequence.java | 24 +-
.../siddhi/sequence/SequenceController.java | 36 +-
.../processors/siddhi/stop/StreamStop.java | 22 +-
.../siddhi/stop/StreamStopController.java | 35 +-
.../streampipes/processors/siddhi/topk/TopK.java | 86 +--
.../streampipes/processors/siddhi/trend/Trend.java | 40 +-
.../processors/siddhi/trend/TrendController.java | 93 +--
.../processors/siddhi/trend/TrendOperator.java | 2 +-
.../processors/siddhi/trend/TrendParameters.java | 60 +-
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../streampipes-processors-geo-flink/pom.xml | 26 +-
.../processor/geo/flink/AbstractGeoProgram.java | 12 +-
.../processor/geo/flink/GeoFlinkInit.java | 36 +-
.../processor/geo/flink/config/ConfigKeys.java | 8 +-
.../flink/processor/gridenricher/CellOption.java | 212 ++++---
.../processor/gridenricher/EnrichmentSettings.java | 3 +-
.../gridenricher/SpatialGridCalculator.java | 21 +-
.../gridenricher/SpatialGridEnricher.java | 7 +-
.../SpatialGridEnrichmentController.java | 66 ++-
.../gridenricher/SpatialGridEnrichmentProgram.java | 3 +-
.../strings.en | 18 +
.../streampipes-processors-geo-jvm/pom.xml | 10 +-
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../strings.en | 18 +
.../pom.xml | 8 +-
.../strings.en | 18 +
.../strings.en | 17 +
.../strings.en | 18 +
.../strings.en | 18 +
.../pom.xml | 10 +-
.../strings.en | 17 +
.../strings.en | 17 +
.../strings.en | 17 +
.../strings.en | 17 +
.../pom.xml | 8 +-
.../strings.en | 17 +
.../strings.en | 17 +
.../pom.xml | 10 +-
.../strings.en | 17 +
.../strings.en | 17 +
.../streampipes-processors-text-mining-jvm/pom.xml | 11 +-
.../strings.en | 17 +
.../strings.en | 17 +
.../strings.en | 17 +
.../strings.en | 17 +
.../strings.en | 17 +
.../strings.en | 17 +
.../pom.xml | 12 +-
.../strings.en | 17 +
.../strings.en | 17 +
.../strings.en | 17 +
.../strings.en | 17 +
.../strings.en | 17 +
.../strings.en | 17 +
.../pom.xml | 8 +-
.../strings.en | 17 +
.../strings.en | 17 +
.../strings.en | 17 +
.../strings.en | 17 +
.../strings.en | 17 +
.../strings.en | 17 +
.../strings.en | 17 +
.../strings.en | 17 +
.../strings.en | 17 +
.../strings.en | 17 +
.../strings.en | 17 +
.../strings.en | 19 +-
.../strings.en | 17 +
.../strings.en | 18 +-
.../strings.en | 18 +
.../strings.en | 18 +-
.../strings.en | 18 +-
.../strings.en | 17 +
.../strings.en | 17 +
.../strings.en | 17 +
.../strings.en | 19 +-
.../strings.en | 19 +-
.../strings.en | 18 +-
.../strings.en | 19 +-
.../strings.en | 19 +-
.../streampipes-sinks-brokers-jvm/pom.xml | 17 +-
.../sinks/brokers/jvm/BrokersJvmInit.java | 2 +
.../sinks/brokers/jvm/nats/NatsController.java | 22 +-
.../sinks/brokers/jvm/nats/NatsParameters.java | 37 +-
.../sinks/brokers/jvm/nats/NatsPublisher.java | 47 +-
.../brokers/jvm/rocketmq/RocketMQParameters.java | 44 ++
.../jvm/rocketmq/RocketMQPublisherSink.java | 123 ++++
.../strings.en | 17 +
.../strings.en | 18 +-
.../strings.en | 17 +
.../strings.en | 19 +-
.../strings.en | 17 +
.../strings.en | 19 +-
.../strings.en | 18 +-
.../strings.en | 19 +-
.../documentation.md | 53 ++
.../icon.png | Bin 0 -> 12775 bytes
.../strings.en | 25 +
.../strings.en | 19 +-
.../jvm/rocketmq/TestRocketMQPublisherSink.java | 83 +++
.../streampipes-sinks-databases-flink/pom.xml | 8 +-
.../strings.en | 19 +-
.../streampipes-sinks-databases-jvm/pom.xml | 8 +-
.../strings.en | 17 +
.../strings.en | 19 +-
.../strings.en | 17 +
.../strings.en | 17 +
.../strings.en | 18 +-
.../strings.en | 17 +
.../strings.en | 17 +
.../strings.en | 17 +
.../streampipes-sinks-internal-jvm/pom.xml | 12 +-
.../sinks/internal/jvm/datalake/DataLakeSink.java | 6 -
.../strings.en | 17 +
.../strings.en | 17 +
.../streampipes-sinks-notifications-jvm/pom.xml | 11 +-
.../strings.en | 17 +
.../strings.en | 19 +-
.../strings.en | 19 +-
.../strings.en | 17 +
.../streampipes-sources-vehicle-simulator/pom.xml | 12 +-
.../pom.xml | 12 +-
.../strings.en | 17 +
.../strings.en | 17 +
.../strings.en | 17 +
.../strings.en | 17 +
.../strings.en | 17 +
streampipes-integration-tests/pom.xml | 88 +++
.../integration/adapters/AdapterTesterBase.java | 60 ++
.../integration/adapters/AdaptersTest.java | 42 ++
.../integration/adapters/PulsarAdapterTester.java | 122 ++++
.../integration/containers/PulsarContainer.java | 61 ++
.../integration/containers/PulsarDevContainer.java | 36 ++
streampipes-logging/pom.xml | 2 +-
streampipes-mail/pom.xml | 6 +-
streampipes-maven-plugin/pom.xml | 4 +-
streampipes-measurement-units/pom.xml | 4 +-
streampipes-messaging-jms/pom.xml | 15 +-
.../messaging/jms/ActiveMQConnectionProvider.java | 20 +-
.../messaging/jms/ActiveMQConsumer.java | 19 +-
.../messaging/jms/ActiveMQPublisher.java | 17 +-
.../streampipes/messaging/jms/ActiveMQUtils.java | 13 +-
.../streampipes/messaging/jms/SpJmsProtocol.java | 4 +-
streampipes-messaging-kafka/pom.xml | 17 +-
.../messaging/kafka/SpKafkaConsumer.java | 34 +-
.../messaging/kafka/SpKafkaProducer.java | 31 +-
.../messaging/kafka/SpKafkaProtocol.java | 4 +-
.../kafka/config/ConsumerConfigFactory.java | 7 +-
.../kafka/config/KafkaConfigAppender.java | 2 +-
.../kafka/config/ProducerConfigFactory.java | 14 +-
.../security/KafkaSecuritySaslPlainConfig.java | 31 +-
.../kafka/security/KafkaSecuritySaslSSLConfig.java | 31 +-
.../KafkaSecurityUnauthenticatedPlainConfig.java | 7 +-
.../KafkaSecurityUnauthenticatedSSLConfig.java | 8 +-
streampipes-messaging-mqtt/pom.xml | 14 +-
.../messaging/mqtt/AbstractMqttConnector.java | 26 +-
.../streampipes/messaging/mqtt/MqttConsumer.java | 36 +-
.../streampipes/messaging/mqtt/MqttPublisher.java | 26 +-
.../streampipes/messaging/mqtt/SpMqttProtocol.java | 29 +-
.../messaging/mqtt/SpMqttProtocolFactory.java | 27 +-
streampipes-messaging-nats/pom.xml | 55 ++
.../messaging/nats/AbstractNatsConnector.java | 57 ++
.../streampipes/messaging/nats/NatsConsumer.java | 77 +++
.../streampipes/messaging/nats/NatsPublisher.java | 59 ++
.../streampipes/messaging/nats/NatsUtils.java | 75 +++
.../streampipes/messaging/nats/SpNatsProtocol.java | 45 ++
.../messaging/nats/SpNatsProtocolFactory.java | 42 ++
streampipes-messaging/pom.xml | 15 +-
.../streampipes/messaging/EventConsumer.java | 10 +-
.../streampipes/messaging/EventProducer.java | 10 +-
.../messaging/SpProtocolDefinition.java | 6 +-
.../streampipes/messaging/SpProtocolManager.java | 19 +-
streampipes-model-client/pom.xml | 6 +-
.../streampipes/model/client/user/Privilege.java | 16 +-
.../apache/streampipes/model/client/user/Role.java | 18 +-
streampipes-model-shared/pom.xml | 2 +-
streampipes-model/pom.xml | 10 +-
.../streampipes/model/StreamPipesErrorMessage.java | 4 +
.../model/connect/adapter/AdapterDescription.java | 421 +++++++------
.../adapter/GenericAdapterStreamDescription.java | 73 +--
.../connect/grounding/ProtocolDescription.java | 1 +
.../connect/rules/DebugSinkRuleDescription.java | 27 +
.../rules/TransformationRuleDescription.java | 1 +
.../model/constants/PropertySelectorConstants.java | 1 +
.../model/datalake/DataLakeMeasure.java | 168 +++---
.../model/function/FunctionDefinition.java | 63 ++
.../streampipes/model/function/FunctionId.java | 66 +++
.../model/grounding/MqttTransportProtocol.java | 9 +-
.../model/grounding/NatsTransportProtocol.java | 52 ++
.../model/grounding/TransportProtocol.java | 1 +
.../model/monitoring/MessageCounter.java | 44 ++
.../model/monitoring/SpEndpointMonitoringInfo.java | 56 ++
.../streampipes/model/monitoring/SpLogEntry.java | 60 ++
.../model/monitoring/SpMetricsEntry.java | 84 +++
.../apache/streampipes/model/nats/NatsConfig.java | 71 +++
.../apache/streampipes/model/runtime/Event.java | 61 +-
.../staticproperty/FreeTextStaticProperty.java | 6 +
.../org/apache/streampipes/model/util/Cloner.java | 2 +
.../model/datalake/DataLakeMeasureTest.java | 59 ++
streampipes-performance-tests/pom.xml | 10 +-
streampipes-pipeline-management/pom.xml | 45 +-
.../manager/execution/http/HttpRequestBuilder.java | 30 +-
.../function/FunctionRegistrationService.java | 49 ++
.../manager/matching/DataSetGroundingSelector.java | 14 +-
.../manager/matching/ProtocolSelector.java | 124 ++--
.../monitoring/pipeline/ExtensionsLogProvider.java | 116 ++++
.../pipeline/ExtensionsServiceLogExecutor.java | 85 +++
.../pipeline/PipelineExecutionStatusCollector.java | 61 --
.../monitoring/pipeline/TopicInfoCollector.java | 233 --------
.../manager/pipeline/PipelineManager.java | 217 +++----
.../runtime/PipelineElementRuntimeInfoFetcher.java | 155 ++---
.../manager/setup/CouchDbInstallationStep.java | 53 +-
.../manager/setup/design/DesignDocumentUtils.java | 30 +
.../manager/setup/design/UserDesignDocument.java | 79 +++
.../streampipes/manager/util/AuthTokenUtils.java | 65 ++
.../manager/pipeline/TestPipelineManager.java | 21 +-
.../pipeline/TestPipelinesContainingElements.java | 88 +++
streampipes-platform-services/pom.xml | 12 +-
.../streampipes/ps/DataLakeMeasureResourceV4.java | 40 +-
.../apache/streampipes/ps/DataLakeResourceV4.java | 57 +-
streampipes-resource-management/pom.xml | 20 +-
.../AbstractDashboardResourceManager.java | 3 +-
.../management/AdapterResourceManager.java | 34 +-
.../management/DataStreamResourceManager.java | 14 +-
.../resource/management/UserResourceManager.java | 8 +
.../management/AdapterResourceManagerTest.java | 39 ++
.../management/DataStreamResourceManagerTest.java | 40 ++
streampipes-rest-core-base/pom.xml | 10 +-
streampipes-rest-shared/pom.xml | 6 +-
streampipes-rest/pom.xml | 41 +-
.../apache/streampipes/rest/ResetManagement.java | 175 +++---
.../streampipes/rest/api/IPipelineElement.java | 36 --
.../streampipes/rest/api/IPipelineMonitoring.java | 25 -
.../rest/filter/TokenAuthenticationFilter.java | 132 +++--
.../rest/impl/AbstractMonitoringResource.java | 34 ++
.../rest/impl/AccountActivationResource.java | 6 +-
.../rest/impl/AdapterMonitoringResource.java | 47 ++
.../rest/impl/AssetDashboardResource.java | 14 +-
.../rest/impl/AssetManagementResource.java | 124 ++++
.../streampipes/rest/impl/Authentication.java | 19 +-
.../apache/streampipes/rest/impl/AutoComplete.java | 12 +-
.../streampipes/rest/impl/CategoryResource.java | 146 ++---
.../streampipes/rest/impl/EmailResource.java | 3 +-
.../streampipes/rest/impl/FunctionsResource.java | 77 +++
.../rest/impl/GenericStorageResource.java | 155 ++---
.../streampipes/rest/impl/LabelResource.java | 198 ++++---
.../rest/impl/MeasurementUnitResource.java | 26 +-
.../apache/streampipes/rest/impl/Notification.java | 134 +++--
.../rest/impl/OntologyMeasurementUnit.java | 52 +-
.../streampipes/rest/impl/PipelineCache.java | 6 +-
.../rest/impl/PipelineCanvasMetadataCache.java | 8 +-
.../rest/impl/PipelineCanvasMetadataResource.java | 15 +-
.../streampipes/rest/impl/PipelineCategory.java | 78 +--
.../rest/impl/PipelineElementAsset.java | 4 +-
.../rest/impl/PipelineElementCategory.java | 71 +--
.../streampipes/rest/impl/PipelineElementFile.java | 14 +-
.../rest/impl/PipelineElementPreview.java | 8 +-
.../rest/impl/PipelineElementRuntimeInfo.java | 3 +-
.../streampipes/rest/impl/PipelineMonitoring.java | 23 +-
.../streampipes/rest/impl/PipelineResource.java | 135 +++--
.../streampipes/rest/impl/PipelineTemplate.java | 44 +-
.../streampipes/rest/impl/ResetResource.java | 23 +-
.../rest/impl/RestorePasswordResource.java | 8 +-
.../org/apache/streampipes/rest/impl/Setup.java | 4 +-
.../apache/streampipes/rest/impl/UserResource.java | 56 +-
.../rest/impl/admin/AssetManagementResource.java | 117 ----
.../streampipes/rest/impl/admin/ConsulConfig.java | 26 +-
.../rest/impl/admin/DataExportResource.java | 6 +-
.../rest/impl/admin/DataImportResource.java | 7 +-
.../impl/admin/EmailConfigurationResource.java | 9 +-
.../admin/ExtensionsServiceEndpointResource.java | 57 +-
.../impl/admin/GeneralConfigurationResource.java | 12 +-
.../rest/impl/admin/PermissionResource.java | 2 +
.../rest/impl/admin/PipelineElementImport.java | 16 +-
.../rest/impl/admin/UserGroupResource.java | 8 +-
.../rest/impl/connect/AdapterResource.java | 245 ++++----
.../rest/impl/connect/DescriptionResource.java | 267 +++++----
.../rest/impl/connect/GuessResource.java | 26 +-
.../impl/connect/RuntimeResolvableResource.java | 63 +-
.../rest/impl/connect/SourcesResource.java | 67 ++-
.../rest/impl/connect/UnitResource.java | 35 +-
.../rest/impl/connect/WelcomePageMaster.java | 98 +--
.../impl/connect/WorkerAdministrationResource.java | 23 +-
.../impl/dashboard/AbstractDashboardResource.java | 10 +-
.../AbstractPipelineExtractionResource.java | 49 +-
.../streampipes/rest/impl/dashboard/Dashboard.java | 41 +-
.../rest/impl/dashboard/DashboardWidget.java | 9 +-
.../dashboard/VisualizablePipelineResource.java | 10 +-
.../impl/datalake/DataLakeDashboardResource.java | 40 +-
.../rest/impl/datalake/DataLakeWidgetResource.java | 9 +-
.../impl/datalake/PersistedDataStreamResource.java | 5 +-
.../impl/nouser/PipelineElementImportNoUser.java | 82 ---
.../rest/impl/pe/DataProcessorResource.java | 86 +--
.../streampipes/rest/impl/pe/DataSinkResource.java | 8 +-
.../rest/impl/pe/DataStreamResource.java | 108 ++--
.../streampipes/rest/security/AuthConstants.java | 77 ++-
.../rest/security/SpPermissionEvaluator.java | 13 +-
.../v4/params/WhereStatementParamsTest.java | 68 +--
.../datalake/DataLakeNoUserManagementV3Test.java | 211 -------
streampipes-sdk-bundle/pom.xml | 25 +-
streampipes-sdk/pom.xml | 8 +-
.../builder/adapter/AdapterDescriptionBuilder.java | 2 +-
.../adapter/GenericDataStreamAdapterBuilder.java | 67 ++-
.../GenericDataStreamAdapterBuilderTest.java | 88 +++
streampipes-security-jwt/pom.xml | 4 +-
streampipes-serializers-json/pom.xml | 8 +-
streampipes-service-base/pom.xml | 14 +-
.../service/base/BaseNetworkingConfig.java | 12 +-
.../service/base/StreamPipesServiceBase.java | 22 +-
.../service/base/rest/BaseResourceConfig.java | 2 +-
.../security/UnauthorizedRequestEntryPoint.java | 14 +-
.../src/main/resources/logback-spring.xml | 2 +-
streampipes-service-discovery-api/pom.xml | 11 +-
.../svcdiscovery/api/ISpServiceDiscovery.java | 12 +-
.../streampipes/svcdiscovery/api/SpConfig.java | 38 +-
.../svcdiscovery/api/model/ConfigItem.java | 11 +-
.../api/model/DefaultSpServiceTags.java | 3 +-
.../svcdiscovery/api/model/PeConfig.java | 72 +--
.../api/model/SpServiceRegistrationRequest.java | 28 +-
.../svcdiscovery/api/model/SpServiceTag.java | 11 +-
.../api/model/SpServiceUrlProvider.java | 34 +-
streampipes-service-discovery-consul/pom.xml | 17 +-
.../consul/ConsulHealthServiceManager.java | 29 +-
.../svcdiscovery/consul/ConsulProvider.java | 5 +-
.../svcdiscovery/consul/ConsulSpConfig.java | 376 ++++++------
.../svcdiscovery/consul/SpConsulKvManagement.java | 15 +-
.../consul/SpConsulServiceDiscovery.java | 45 +-
streampipes-service-discovery/pom.xml | 16 +-
.../svcdiscovery/SpServiceDiscovery.java | 2 +-
streampipes-service-extensions-base/pom.xml | 17 +-
.../base/StreamPipesExtensionsServiceBase.java | 111 ++--
.../service/extensions/base/WebSecurityConfig.java | 37 +-
...StreamPipesClientRuntimeConnectionResolver.java | 15 +-
.../base/security/TokenAuthenticationFilter.java | 6 +-
.../base/security/UnauthenticatedInterfaces.java | 12 +-
streampipes-sources/pom.xml | 4 +-
streampipes-storage-api/pom.xml | 6 +-
.../streampipes/storage/api/IDataLakeStorage.java | 4 +
streampipes-storage-couchdb/pom.xml | 12 +-
.../storage/couchdb/impl/DataLakeStorageImpl.java | 10 +
.../storage/couchdb/impl/UserStorage.java | 4 +-
streampipes-storage-management/pom.xml | 6 +-
streampipes-test-utils/pom.xml | 4 +-
.../generator/pipeline/DummyPipelineGenerator.java | 4 +-
.../pipelineelement/DummyProcessorGenerator.java | 2 +
.../pipelineelement/DummySinkGenerator.java | 2 +
.../pipelineelement/DummyStreamGenerator.java | 27 +
streampipes-user-management/pom.xml | 10 +-
.../user/management/jwt/JwtTokenProvider.java | 3 +-
.../user/management/util/UserInfoUtil.java | 30 +-
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/LICENSE | 201 -------
streampipes-wrapper-python/NOTICE | 7 -
streampipes-wrapper-python/README.md | 18 +-
streampipes-wrapper-python/pom.xml | 2 +-
streampipes-wrapper-siddhi/pom.xml | 4 +-
streampipes-wrapper-standalone/pom.xml | 4 +-
.../StandaloneEventProcessingDeclarer.java | 1 +
.../standalone/function/FunctionContext.java | 79 +++
.../function/FunctionContextGenerator.java | 59 ++
.../standalone/function/StreamPipesFunction.java | 166 ++++++
.../standalone/manager/ProtocolManager.java | 10 +-
.../routing/StandaloneSpInputCollector.java | 4 -
.../routing/StandaloneSpOutputCollector.java | 18 +-
.../runtime/StandaloneEventProcessorRuntime.java | 50 +-
.../runtime/StandaloneEventSinkRuntime.java | 22 +-
.../StandaloneExternalEventProcessorRuntime.java | 2 +-
.../StandaloneExternalEventSinkRuntime.java | 2 +-
.../runtime/StandalonePipelineElementRuntime.java | 14 +
streampipes-wrapper/pom.xml | 14 +-
.../wrapper/context/RuntimeContext.java | 4 +-
.../context/SpEventProcessorRuntimeContext.java | 6 +-
.../wrapper/context/SpEventSinkRuntimeContext.java | 6 +-
.../wrapper/context/SpRuntimeContext.java | 12 +-
.../binding/EventProcessorBindingParams.java | 1 +
.../runtime/EventProcessorRuntimeParams.java | 16 +-
.../params/runtime/EventSinkRuntimeParams.java | 12 +-
.../wrapper/routing/RawDataProcessor.java | 4 +-
.../wrapper/runtime/EventProcessor.java | 1 +
.../maven/checkstyle-header.txt | 0
tools/maven/checkstyle.xml | 19 +-
ui/.eslintrc.json | 47 ++
ui/.gitignore | 4 +
ui/.prettierrc.json | 17 +
ui/README.md | 47 --
ui/angular.json | 26 +-
ui/cypress.config.ts | 60 ++
ui/cypress.json | 16 -
ui/cypress/README.md | 2 +-
.../downloads/sp_adaptertotestschemarules.csv | 2 -
.../fixtures/connect/aggregationRules/expected.csv | 2 +-
.../connect/removeDuplicateRules/expected.csv | 2 +-
.../fixtures/connect/valueRules/expected.csv | 2 +-
ui/cypress/fixtures/dataDownloadDialog/input.json | 5 +
.../fixtures/dataDownloadDialog/testCsvComma.csv | 6 +
.../dataDownloadDialog/testCsvSemicolon.csv | 6 +
.../fixtures/dataDownloadDialog/testJson.json | 1 +
.../testRemoveLinesWithMissingValues.csv | 4 +
ui/cypress/fixtures/datalake/missingData.json | 5 +
.../enrich-jvm/jsEvaluator1/expected.csv | 2 +-
.../enrich-jvm/jsEvaluator2/expected.csv | 2 +-
.../pipelineElement/enrich-jvm/math1/expected.csv | 2 +-
.../pipelineElement/enrich-jvm/math2/expected.csv | 2 +-
.../pipelineElement/enrich-jvm/math3/expected.csv | 2 +-
.../enrich-jvm/staticmath1/expected.csv | 2 +-
.../enrich-jvm/staticmath2/expected.csv | 2 +-
.../enrich-jvm/trigonometry1/expected.csv | 2 +-
.../enrich-jvm/trigonometry2/expected.csv | 2 +-
.../enrich-jvm/valueChange1/expected.csv | 2 +-
.../filters-jvm/booleanFilter1/expected.csv | 4 +-
.../filters-jvm/booleanFilter2/expected.csv | 2 +-
.../filters-jvm/numericalFilter1/expected.csv | 2 +-
.../filters-jvm/projection1/expected.csv | 2 +-
.../filters-jvm/rateLimit1/expected.csv | 2 +-
.../filters-jvm/textFilter1/expected.csv | 2 +-
.../filters-jvm/textFilter2/expected.csv | 2 +-
.../filters-jvm/thresholdDetection1/expected.csv | 2 +-
.../filters-siddhi/increase1/expected.csv | 2 +-
.../filters-siddhi/increase3/expected.csv | 2 +-
.../booleanCounter1/expected.csv | 2 +-
.../booleanCounter2/expected.csv | 2 +-
.../booleanInverter1/expected.csv | 2 +-
.../transformation-jvm/countArray1/expected.csv | 2 +-
.../transformation-jvm/fieldHasher1/expected.csv | 2 +-
.../transformation-jvm/fieldHasher2/expected.csv | 2 +-
.../transformation-jvm/fieldMapper1/expected.csv | 2 +-
.../transformation-jvm/fieldRenamer1/expected.csv | 2 +-
.../signalEdgeFilter1/expected.csv | 2 +-
.../transformation-jvm/splitArray1/expected.csv | 2 +-
ui/cypress/plugins/index.ts | 57 +-
.../support/builder/GenericAdapterBuilder.ts | 2 +-
.../support/builder/SpecificAdapterBuilder.ts | 3 +-
ui/cypress/support/builder/UserInputBuilder.ts | 46 ++
ui/cypress/support/commands.ts | 55 ++
ui/cypress/support/component-index.html | 29 +
ui/cypress/support/component.ts | 58 ++
ui/cypress/support/e2e.ts | 36 ++
ui/cypress/support/general/InitStreamPipesTest.ts | 17 -
ui/cypress/support/general/dataCy.ts | 7 +-
.../support/general/removeDownloadDirectory.ts | 31 +
ui/cypress/support/index.ts | 35 --
.../support/utils/ConnectEventSchemaUtils.ts | 2 +
ui/cypress/support/utils/ConnectUtils.ts | 250 --------
.../support/utils/DataDownloadDialogUtils.ts | 72 +++
ui/cypress/support/utils/DataLakeUtils.ts | 304 ----------
ui/cypress/support/utils/DataSetUtils.ts | 40 ++
ui/cypress/support/utils/PipelineUtils.ts | 6 -
ui/cypress/support/utils/PrepareTestDataUtils.ts | 67 +++
.../support/utils/ProcessingElementTestUtils.ts | 4 +-
.../support/utils/ThirdPartyIntegrationUtils.ts | 4 +-
ui/cypress/support/utils/connect/ConnectBtns.ts | 43 ++
ui/cypress/support/utils/connect/ConnectUtils.ts | 251 ++++++++
ui/cypress/support/utils/datalake/DataLakeUtils.ts | 288 +++++++++
.../utils/datalake/DataLakeWidgetTableUtils.ts | 28 +
ui/cypress/tests/adapter/editAdapter.smoke.spec.ts | 98 +++
.../adapter/editAdapterWithPipeline.smoke.spec.ts | 54 ++
ui/cypress/tests/adapter/fileStream.smoke.spec.ts | 2 +-
.../adapter/machineDataSimulator.smoke.spec.ts | 2 +-
ui/cypress/tests/adapter/opcAdapter.ts | 2 +-
.../tests/adapter/persistInDataLake.smoke.spec.ts | 2 +-
.../tests/adapter/randomDataSimulatorStream.ts | 2 +-
ui/cypress/tests/adapter/schemaRules.smoke.spec.ts | 2 +-
ui/cypress/tests/adapter/streamRules.ts | 2 +-
ui/cypress/tests/adapter/valueRules.ts | 2 +-
.../tests/dashboard/dashboardTest.smoke.spec.ts | 2 +-
.../dataDownloadDialogTest.smoke.spec.ts | 90 +++
.../tests/datalake/configuration.smoke.spec.ts | 2 +-
ui/cypress/tests/datalake/deleteWidget.ts | 4 +-
.../tests/datalake/missingDataInDataLake.spec.ts | 43 ++
.../tests/datalake/testSpecialCharactersInName.ts | 85 ---
.../datalake/widgetDataConfiguration.smoke.spec.ts | 25 +-
ui/cypress/tests/datalake/widgets/table.ts | 2 +-
.../tests/datalake/widgets/timeSeriesSave.ts | 4 +-
.../restartStreamPipes/restartStreamPipes1.ts | 4 +-
.../restartStreamPipes/restartStreamPipes2.ts | 2 +-
.../testJvmArchetype/testJvmArchetype.ts | 4 +-
.../tests/pipeline/pipelineTest.smoke.spec.ts | 4 +-
ui/deployment/modules.yml | 2 +-
ui/deployment/rel/config.yml | 29 -
ui/deployment/rel/img/logo.png | Bin 14358 -> 0 bytes
ui/deployment/rel/img/sp-logo-right-white.png | Bin 21453 -> 0 bytes
ui/package.json | 75 +--
.../streampipes/platform-services/karma.conf.js | 1 -
.../streampipes/platform-services/package.json | 17 +-
.../src/lib/apis/abstract-monitoring.service.ts | 48 ++
.../src/lib/apis/adapter-monitoring.service.ts | 55 ++
.../src/lib/apis/adapter.service.ts | 29 +-
.../src/lib/apis/datalake-rest.service.ts | 15 +-
.../src/lib/apis/functions.service.ts | 53 ++
.../src/lib/apis/pipeline-monitoring.service.ts | 31 +-
.../src/lib/apis/pipeline.service.spec.ts | 65 ++
.../src/lib/apis/pipeline.service.ts | 219 ++++---
.../lib/model/datalake/DatalakeQueryParameters.ts | 3 +
.../model/datalake/data-lake-query-config.model.ts | 3 +
.../src/lib/model/gen/streampipes-model-client.ts | 27 +-
.../src/lib/model/gen/streampipes-model.ts | 138 ++++-
.../platform-services/src/lib/pipeline.service.ts | 41 --
.../src/lib/query/DatalakeQueryParameterBuilder.ts | 8 +-
.../lib/query/data-view-query-generator.service.ts | 12 +-
.../platform-services/src/public-api.ts | 2 +
.../platform-services/tsconfig.lib.json | 2 +-
ui/projects/streampipes/shared-ui/package.json | 16 +-
.../basic-view/basic-view.component.html | 2 +-
.../components/basic-view/basic-view.component.ts | 3 +
.../exception-details-dialog.component.html | 4 +
.../exception-details-dialog.component.scss | 10 +
.../exception-details-dialog.component.ts | 10 +-
.../sp-exception-message.component.html | 31 +-
.../sp-exception-message.component.scss | 4 +
.../sp-exception-message.component.ts | 3 +
.../src/lib/dialog/base-dialog/dialog-ref.ts | 3 +-
.../streampipes/shared-ui/tsconfig.lib.json | 2 +-
ui/src/app/_enums/user-role.enum.ts | 4 +-
.../asset-overview/asset-overview.component.html | 4 +-
.../create-asset-dialog.component.html | 4 +-
.../edit-asset-link-dialog.component.ts | 4 +-
.../datalake-configuration.component.ts | 4 +-
.../email-configuration.component.ts | 36 +-
.../general-configuration.component.ts | 20 +-
.../edit-group-dialog.component.ts | 8 +-
.../edit-user-dialog/edit-user-dialog.component.ts | 30 +-
.../adapter-configuration-header.component.html | 34 ++
.../adapter-configuration-header.component.scss | 26 +
.../adapter-configuration-header.component.ts | 46 ++
.../adapter-configuration.component.html | 91 +++
.../adapter-configuration.component.scss | 49 ++
.../adapter-configuration.component.ts | 161 +++++
.../adapter-template-configuration.directive.ts | 94 +++
.../format-configuration.component.html | 0
.../format-configuration.component.scss | 0
.../format-configuration.component.ts | 122 ++++
.../format-item-json.component.html | 0
.../format-item-json.component.scss | 0
.../format-item-json/format-item-json.component.ts | 0
.../format-item/format-item.component.html | 0
.../format-item/format-item.component.scss | 0
.../format-item/format-item.component.ts | 0
.../format-list/format-list.component.html | 0
.../format-list/format-list.component.scss | 0
.../format-list/format-list.component.ts | 0
.../generic-adapter-configuration.component.html | 0
.../generic-adapter-configuration.component.scss | 0
.../generic-adapter-configuration.component.ts | 82 +++
.../error-message/error-message.component.html | 0
.../error-message/error-message.component.scss | 0
.../error-message/error-message.component.ts | 0
.../event-property-row.component.html | 0
.../event-property-row.component.scss | 0
.../event-property-row.component.ts | 0
.../event-schema-error-hints.component.cy.ts | 97 +++
.../event-schema-error-hints.component.html | 53 ++
.../event-schema-error-hints.component.scss | 50 ++
.../event-schema-error-hints.component.ts | 40 ++
.../event-schema-preview.component.html | 0
.../event-schema-preview.component.scss | 0
.../event-schema-preview.component.ts | 0
.../event-schema/event-schema.component.html | 107 ++++
.../event-schema/event-schema.component.scss | 177 ++++++
.../event-schema/event-schema.component.ts | 342 +++++++++++
.../loading-message/loading-message.component.html | 0
.../loading-message/loading-message.component.scss | 0
.../loading-message/loading-message.component.ts | 0
.../schema-editor-header.component.html | 67 +++
.../schema-editor-header.component.scss | 0
.../schema-editor-header.component.ts | 0
.../specific-adapter-configuration.component.html | 0
.../specific-adapter-configuration.component.scss | 0
.../specific-adapter-configuration.component.ts | 74 +++
.../adapter-options-panel.component.html | 0
.../adapter-options-panel.component.scss | 0
.../adapter-options-panel.component.ts | 0
.../start-adapter-configuration.component.html | 119 ++++
.../start-adapter-configuration.component.scss | 0
.../start-adapter-configuration.component.ts | 176 ++++++
.../abstract-adapter-details.directive.ts | 66 +++
.../adapter-details-logs.component.html | 42 ++
.../adapter-details-logs.component.scss} | 0
.../adapter-details-logs.component.ts | 60 ++
.../adapter-details-metrics.component.html | 43 ++
.../adapter-details-metrics.component.ts | 59 ++
.../adapter-details-overview.component.html | 27 +
.../adapter-details-overview.component.scss} | 0
.../adapter-details-overview.component.ts | 50 ++
.../adapter-details/adapter-details-tabs.ts | 30 +
.../configuration-group.component.ts | 4 +-
.../adapter-description.component.ts | 31 +-
.../edit-adapter/edit-adapter.component.html | 24 +
.../edit-adapter/edit-adapter.component.scss} | 0
.../edit-adapter/edit-adapter.component.ts | 54 ++
.../existing-adapters.component.html | 350 +++++++----
.../existing-adapters.component.scss | 8 +
.../existing-adapters.component.ts | 314 +++++++---
.../new-adapter/adapter-configuration.directive.ts | 98 ---
.../format-configuration.component.ts | 122 ----
.../generic-adapter-configuration.component.ts | 82 ---
.../new-adapter/new-adapter.component.html | 86 +--
.../new-adapter/new-adapter.component.scss | 40 --
.../new-adapter/new-adapter.component.ts | 232 +-------
.../event-schema/event-schema.component.html | 129 ----
.../event-schema/event-schema.component.scss | 209 -------
.../event-schema/event-schema.component.ts | 278 ---------
.../schema-editor-header.component.html | 66 ---
.../specific-adapter-configuration.component.ts | 74 ---
.../start-adapter-configuration.component.html | 104 ----
.../start-adapter-configuration.component.ts | 163 -----
ui/src/app/connect/connect.module.ts | 252 ++++----
ui/src/app/connect/connect.routes.ts | 1 +
.../adapter-export-dialog.component.scss | 31 -
.../adapter-export-dialog.component.ts | 54 --
.../adapter-export/adapter-export-dialog.html | 34 --
.../adapter-started-dialog.component.html | 18 +-
.../adapter-started-dialog.component.ts | 114 ++--
.../adapter-upload-dialog.component.scss | 20 -
.../adapter-upload-dialog.component.ts | 64 --
.../adapter-upload/adapter-upload-dialog.html | 47 --
.../can-not-edit-adapter-dialog.component.cy.ts | 48 ++
.../can-not-edit-adapter-dialog.component.html | 52 ++
.../can-not-edit-adapter-dialog.component.scss} | 0
.../can-not-edit-adapter-dialog.component.ts | 37 ++
.../edit-schema-transformation.component.ts | 4 +-
.../edit-unit-transformation.component.ts | 8 +-
.../edit-event-property.component.ts | 6 +-
.../connect/services/adapter-template.service.ts | 1 -
ui/src/app/connect/services/connect.service.ts | 4 +-
ui/src/app/connect/services/icon.service.ts | 40 --
ui/src/app/connect/services/rest.service.ts | 37 +-
ui/src/app/core-ui/core-ui.module.ts | 33 +-
.../components/download/download.component.html | 30 +
.../components/download/download.component.scss | 18 +
.../components/download/download.component.ts | 55 ++
.../select-data-missing-values.component.html | 35 ++
.../select-data-missing-values.component.scss | 19 +
.../select-data-missing-values.component.ts | 38 ++
.../select-data-range.component.html | 91 +++
.../select-data-range.component.scss | 18 +
.../select-data-range.component.ts | 55 ++
.../select-data/select-data.component.html | 28 +
.../select-data/select-data.component.scss | 36 ++
.../select-data/select-data.component.ts | 42 ++
.../select-format/select-format.component.html | 49 ++
.../select-format/select-format.component.scss | 18 +
.../select-format/select-format.component.ts | 37 ++
.../data-download-dialog.component.html | 137 ++---
.../data-download-dialog.component.scss | 5 -
.../data-download-dialog.component.ts | 213 +------
.../model/data-download-dialog.model.ts | 33 ++
.../model/data-export-config.model.ts | 45 ++
.../model/download-progress.model.ts | 22 +
.../model/export-config.model.ts | 44 ++
.../model/format-export-config.model.ts | 48 ++
.../services/data-export.service.ts | 128 ++++
.../services/file-name.service.spec.ts | 98 +++
.../services/file-name.service.ts | 52 ++
ui/src/app/core-ui/image/services/color.service.ts | 4 +-
ui/src/app/core-ui/image/util/color.util.ts | 4 +-
.../configure-labels/configure-labels.component.ts | 8 +-
.../simple-logs/simple-logs.component.html | 33 ++
.../simple-logs/simple-logs.component.ts | 34 ++
.../simple-metrics/simple-metrics.component.html | 35 ++
.../simple-metrics/simple-metrics.component.ts | 42 ++
.../object-permission-dialog.component.ts | 14 +-
.../base/abstract-static-property.ts | 6 +-
.../base/abstract-validated-static-property.ts | 4 +-
.../static-color-picker.component.ts | 4 +-
.../static-file-input.component.ts | 4 +-
.../static-properties/static-property.component.ts | 4 +-
.../base-runtime-resolvable-input.ts | 2 +-
.../base-runtime-resolvable-selection-input.ts | 2 +-
...tic-runtime-resolvable-oneof-input.component.ts | 4 +-
.../static-tree-input.component.ts | 4 +-
.../status/status-widget.component.css | 0
.../core-ui/status/status-widget.component.html | 29 +
.../app/core-ui/status/status-widget.component.ts | 70 +++
.../core/components/toolbar/toolbar.component.html | 2 +-
.../core/components/toolbar/toolbar.component.scss | 4 +
.../core/components/toolbar/toolbar.component.ts | 9 +-
.../add-visualization-dialog.component.ts | 6 +-
...ta-explorer-widget-data-settings.component.html | 11 +-
...data-explorer-widget-data-settings.component.ts | 1 -
.../field-selection-panel.component.ts | 4 +-
.../data-explorer-dashboard-overview.component.ts | 15 +-
.../data-explorer-dashboard-panel.component.ts | 42 +-
.../time-selector/timeRangeSelector.component.ts | 6 +-
.../widget-view/abstract-widget-view.directive.ts | 4 +
...ta-explorer-dashboard-slide-view.component.html | 58 +-
...ta-explorer-dashboard-slide-view.component.scss | 28 +-
...data-explorer-dashboard-slide-view.component.ts | 3 +-
.../data-explorer-dashboard-widget.component.html | 138 +++--
.../data-explorer-dashboard-widget.component.scss | 9 +
.../data-explorer-dashboard-widget.component.ts | 81 ++-
.../base/base-data-explorer-widget.directive.ts | 24 +-
.../components/widgets/base/base-widget-config.ts | 1 -
.../widgets/base/data-explorer-widget-data.ts | 9 +-
.../correlation-chart-widget.component.html | 11 +-
.../correlation-chart-widget.component.ts | 14 +-
.../distribution-chart-widget.component.html | 10 +-
.../widgets/heatmap/heatmap-widget.component.html | 12 +-
.../widgets/image/image-widget.component.html | 2 -
.../indicator-chart-widget.component.html | 10 +-
.../widgets/map/map-widget.component.html | 9 +-
.../widgets/table/table-widget.component.html | 13 +-
.../time-series-chart/services/color.service.ts | 6 +-
.../time-series-chart-widget.component.html | 11 +-
.../time-series-chart-widget.component.ts | 119 ++--
.../aggregate-configuration.component.ts | 4 +-
.../components/widgets/utils/color-utils.ts | 34 ++
.../no-data/no-data-in-date-range.component.html | 6 +-
.../too-much-data/too-much-data.component.html | 8 +-
.../models/dataview-dashboard.model.ts | 2 +-
.../output-strategy/base/BaseOutputStrategy.ts | 6 +-
.../custom-output-strategy.component.ts | 4 +-
.../output-strategy/output-strategy.component.ts | 4 +-
.../user-defined-output.component.ts | 4 +-
.../pipeline-element-options.component.ts | 1 +
.../components/pipeline/pipeline.component.ts | 1 +
.../editor/dialog/customize/customize.component.ts | 6 +-
ui/src/app/editor/dialog/help/help.component.html | 7 +-
.../save-pipeline/save-pipeline.component.ts | 8 +-
ui/src/app/home/home.component.html | 2 +-
ui/src/app/home/home.component.ts | 8 +
ui/src/app/info/about/about.component.html | 4 +-
.../app/login/components/login/login.component.ts | 10 +-
.../components/register/register.component.ts | 16 +-
.../restore-password/restore-password.component.ts | 8 +-
.../set-new-password/set-new-password.component.ts | 10 +-
.../app/login/components/setup/setup.component.ts | 4 +-
.../components/edit/quickedit.component.ts | 6 +-
.../components/model/pipeline-details.model.ts | 5 +
.../monitoring/pipeline-monitoring.component.html | 91 +--
.../monitoring/pipeline-monitoring.component.ts | 35 +-
.../pipeline-element-statistics.component.html | 62 +-
.../pipeline-element-statistics.component.ts | 104 ++--
.../widget/status/status-widget.component.html | 29 -
.../widget/status/status-widget.component.ts | 67 ---
.../pipeline-logs/pipeline-logs.component.html | 62 ++
.../pipeline-logs/pipeline-logs.component.scss} | 0
.../pipeline-logs/pipeline-logs.component.ts | 74 +++
.../app/pipeline-details/pipeline-details-tabs.ts | 4 +-
.../pipeline-details/pipeline-details.module.ts | 4 +-
.../abstract-function-details.directive.ts | 87 +++
.../functions-logs/functions-logs.component.html | 41 ++
.../functions-logs/functions-logs.component.ts | 51 ++
.../functions-metrics.component.html | 45 ++
.../functions-metrics.component.ts | 50 ++
.../functions-overview.component.html | 55 ++
.../functions-overview.component.scss} | 0
.../functions-overview.component.ts | 48 ++
ui/src/app/pipelines/pipelines.component.html | 11 +-
ui/src/app/pipelines/pipelines.component.ts | 56 +-
ui/src/app/pipelines/pipelines.module.ts | 23 +-
ui/src/app/pipelines/pipelines.routes.ts | 2 +-
.../token/token-management-settings.component.html | 10 +-
.../change-email/change-email-dialog.component.ts | 16 +-
.../change-password-dialog.component.ts | 16 +-
ui/src/app/profile/profile.component.html | 6 +-
ui/src/app/profile/profile.module.ts | 4 +-
ui/src/app/services/available-roles.service.ts | 2 +
ui/src/scss/sp/mat-tab.scss | 8 +-
ui/tsconfig.json | 5 +-
ui/tslint.json | 101 ----
1331 files changed, 37126 insertions(+), 20721 deletions(-)
delete mode 100644 .github/ISSUE_TEMPLATE/bug.md
create mode 100644 .github/ISSUE_TEMPLATE/bug_report.yml
create mode 100644 .github/ISSUE_TEMPLATE/config.yml
create mode 100644 .github/ISSUE_TEMPLATE/doc_website_issue_report.yml
delete mode 100644 .github/ISSUE_TEMPLATE/feature.md
create mode 100644 .github/ISSUE_TEMPLATE/maintainer_fast_track.yml
create mode 100644 .github/release.yml
delete mode 100644 DISCLAIMER
create mode 100755 create-client-model.sh
create mode 100644 images/streampipes-connect.gif
create mode 100644 images/streampipes-data-explorer.gif
create mode 100644 images/streampipes-overview.png
create mode 100644 images/streampipes-pipelines.gif
create mode 100644 installer/cli/deploy/standalone/rocketmq/Dockerfile
create mode 100644 installer/cli/deploy/standalone/rocketmq/docker-compose.dev.yml
create mode 100644 installer/cli/deploy/standalone/rocketmq/docker-compose.yml
create mode 100644 installer/cli/environments/backend-nats
create mode 100644 installer/cli/environments/basic-nats
create mode 100644 installer/cli/environments/lite-nats
create mode 100644 installer/cli/environments/pipeline-element-nats
create mode 100644 installer/compose/docker-compose.nats.yml
delete mode 100644 installer/k8s/templates/extensions/pipeline-elements/files-pvc.yaml
delete mode 100644 installer/k8s/templates/extensions/pipeline-elements/sources-vehicle-simulator-deployment.yaml
delete mode 100644 installer/k8s/templates/extensions/pipeline-elements/sources-vehicle-simulator-service.yaml
delete mode 100644 installer/k8s/templates/extensions/pipeline-elements/sources-watertank-simulator-deployment.yaml
create mode 100644 installer/k8s/templates/external/nats/nats-deployment.yaml
create mode 100644 installer/k8s/templates/external/nats/nats-service.yaml
create mode 100644 streampipes-backend/src/main/java/org/apache/streampipes/backend/migrations/v090/UpdateUsernameViewMigration.java
create mode 100644 streampipes-client-python/.coveragerc
create mode 100644 streampipes-client-python/.gitignore
create mode 100644 streampipes-client-python/.pre-commit-config.yaml
create mode 100644 streampipes-client-python/DEVELOPMENT.md
create mode 100644 streampipes-client-python/Makefile
create mode 100644 streampipes-client-python/README.md
create mode 100644 streampipes-client-python/docs/getting-started/installation.md
create mode 100644 streampipes-client-python/docs/getting-started/quickstart.md
create mode 100644 streampipes-client-python/docs/img/how-to-get-api-key.gif
create mode 100644 streampipes-client-python/docs/img/streampipes-python.png
create mode 100644 streampipes-client-python/docs/index.md
create mode 100644 streampipes-client-python/docs/overrides/main.html
create mode 100644 streampipes-client-python/docs/overrides/partials/footer.html
create mode 100644 streampipes-client-python/docs/scripts/gen_ref_pages.py
create mode 100644 streampipes-client-python/docs/stylesheets/extra.css
create mode 100644 streampipes-client-python/mkdocs.yml
create mode 100644 streampipes-client-python/setup.py
copy {streampipes-wrapper-python/streampipes/api/resources => streampipes-client-python/streampipes_client}/__init__.py (100%)
create mode 100644 streampipes-client-python/streampipes_client/__version__.py
create mode 100644 streampipes-client-python/streampipes_client/client/__init__.py
create mode 100644 streampipes-client-python/streampipes_client/client/client.py
create mode 100644 streampipes-client-python/streampipes_client/client/client_config.py
create mode 100644 streampipes-client-python/streampipes_client/client/credential_provider.py
create mode 100644 streampipes-client-python/streampipes_client/endpoint/__init__.py
create mode 100644 streampipes-client-python/streampipes_client/endpoint/data_lake_measure.py
create mode 100644 streampipes-client-python/streampipes_client/endpoint/data_stream.py
create mode 100644 streampipes-client-python/streampipes_client/endpoint/endpoint.py
copy {streampipes-wrapper-python/streampipes/api/resources => streampipes-client-python/streampipes_client/model}/__init__.py (100%)
create mode 100644 streampipes-client-python/streampipes_client/model/common.py
create mode 100644 streampipes-client-python/streampipes_client/model/container/__init__.py
create mode 100644 streampipes-client-python/streampipes_client/model/container/data_lake_measures.py
create mode 100644 streampipes-client-python/streampipes_client/model/container/data_streams.py
create mode 100644 streampipes-client-python/streampipes_client/model/container/resource_container.py
create mode 100644 streampipes-client-python/streampipes_client/model/resource/__init__.py
create mode 100644 streampipes-client-python/streampipes_client/model/resource/data_lake_measure.py
create mode 100644 streampipes-client-python/streampipes_client/model/resource/data_lake_series.py
create mode 100644 streampipes-client-python/streampipes_client/model/resource/data_stream.py
create mode 100644 streampipes-client-python/streampipes_client/model/resource/resource.py
copy {streampipes-wrapper-python/streampipes/api/resources => streampipes-client-python/tests}/__init__.py (100%)
copy {streampipes-wrapper-python/streampipes/api/resources => streampipes-client-python/tests/client}/__init__.py (100%)
create mode 100644 streampipes-client-python/tests/client/test_client.py
create mode 100644 streampipes-client-python/tests/client/test_credential_provider.py
create mode 100644 streampipes-client-python/tests/client/test_data_lake_series.py
create mode 100644 streampipes-client-python/tests/client/test_endpoint.py
create mode 100644 streampipes-client/src/main/java/org/apache/streampipes/client/api/DataLakeMeasureApi.java
create mode 100644 streampipes-client/src/main/java/org/apache/streampipes/client/http/PutRequest.java
create mode 100644 streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master/health/AdapterOperationLock.java
create mode 100644 streampipes-connect/src/main/java/org/apache/streampipes/connect/adapter/preprocessing/elements/DebugAdapterSink.java
create mode 100644 streampipes-connect/src/main/java/org/apache/streampipes/connect/adapter/preprocessing/elements/SendToNatsAdapterSink.java
create mode 100644 streampipes-container-extensions/src/main/java/org/apache/streampipes/container/extensions/function/FunctionDeregistrationHandler.java
create mode 100644 streampipes-container-extensions/src/main/java/org/apache/streampipes/container/extensions/function/FunctionRegistrationHandler.java
create mode 100644 streampipes-container-extensions/src/main/java/org/apache/streampipes/container/extensions/function/RegistrationHandler.java
create mode 100644 streampipes-container-extensions/src/main/java/org/apache/streampipes/container/extensions/function/StreamPipesFunctionHandler.java
create mode 100644 streampipes-container/src/main/java/org/apache/streampipes/container/api/AbstractExtensionsResource.java
create mode 100644 streampipes-container/src/main/java/org/apache/streampipes/container/api/MonitoringResource.java
create mode 100644 streampipes-container/src/main/java/org/apache/streampipes/container/declarer/IStreamPipesFunctionDeclarer.java
create mode 100644 streampipes-container/src/main/java/org/apache/streampipes/container/monitoring/SpMonitoringManager.java
create mode 100644 streampipes-container/src/main/java/org/apache/streampipes/container/util/GroundingDebugUtils.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/autoagg/AbstractAutoAggregationQuery.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/autoagg/FromNowAutoAggregationQuery.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/autoagg/GroupedAutoAggregationQuery.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/autoagg/TimeBoundAutoAggregationQuery.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/AggregatedTimeBoundQueryParams.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/AggregatedTimeUnitQueryParams.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/CountQueryParams.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/GroupedAggregatedTimeBoundQueryParams.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/GroupedQueryParams.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/PagingQueryParams.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/TimeBoundQueryParams.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/TimeUnitQueryParams.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetAggregatedEventsFromNowQuery.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetAggregatedEventsQuery.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetDateFromSortedTableRecord.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetEventsAutoAggregationQuery.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetEventsFromNowQuery.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetEventsQuery.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetGroupedAggregatedEventsQuery.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetGroupedEventsQuery.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetHeadersWithTypesQuery.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetMaxPagesQuery.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetNumberOfRecordsByTimeUnitQuery.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetNumberOfRecordsQuery.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetPagingEventsQuery.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/QueryResultProvider.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/StreamedQueryResultProvider.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/writer/ConfiguredCsvOutputWriter.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/writer/ConfiguredJsonOutputWriter.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/writer/ConfiguredOutputWriter.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/writer/OutputFormat.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/writer/item/CsvItemWriter.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/writer/item/ItemGenerator.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/writer/item/JsonItemWriter.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/utils/TimeParser.java
create mode 100644 streampipes-data-explorer/src/test/java/org/apache/streampipesdataexplorer/v4/query/writer/TestConfiguredCsvOutputWriter.java
create mode 100644 streampipes-data-explorer/src/test/java/org/apache/streampipesdataexplorer/v4/query/writer/TestConfiguredJsonOutputWriter.java
create mode 100644 streampipes-data-explorer/src/test/java/org/apache/streampipesdataexplorer/v4/query/writer/TestConfiguredOutputWriter.java
create mode 100644 streampipes-data-explorer/src/test/java/org/apache/streampipesdataexplorer/v4/query/writer/item/TestCsvItemWriter.java
create mode 100644 streampipes-data-explorer/src/test/java/org/apache/streampipesdataexplorer/v4/query/writer/item/TestItemWriter.java
create mode 100644 streampipes-data-explorer/src/test/java/org/apache/streampipesdataexplorer/v4/query/writer/item/TestJsonItemWriter.java
create mode 100644 streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream/BrokerEventProcessor.java
create mode 100644 streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream/NatsProtocol.java
delete mode 100644 streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream/pulsar/PulsarConsumer.java
create mode 100644 streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream/rocketmq/RocketMQConsumer.java
create mode 100644 streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream/rocketmq/RocketMQProtocol.java
create mode 100644 streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream/rocketmq/RocketMQUtils.java
create mode 100644 streampipes-extensions/streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.nats/documentation.md
copy streampipes-extensions/{streampipes-sinks-brokers-jvm/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.nats => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.nats}/icon.png (100%)
create mode 100644 streampipes-extensions/streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.nats/strings.en
create mode 100644 streampipes-extensions/streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.rocketmq/documentation.md
create mode 100644 streampipes-extensions/streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.rocketmq/icon.png
create mode 100644 streampipes-extensions/streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.rocketmq/strings.en
create mode 100644 streampipes-extensions/streampipes-pipeline-elements-shared/src/main/java/org/apache/streampipes/pe/shared/config/nats/NatsConfigUtils.java
create mode 100644 streampipes-extensions/streampipes-processors-change-detection-jvm/src/main/java/org/apache/streampipes/processors/changedetection/jvm/welford/WelfordAggregate.java
create mode 100644 streampipes-extensions/streampipes-processors-change-detection-jvm/src/main/java/org/apache/streampipes/processors/changedetection/jvm/welford/WelfordChangeDetection.java
create mode 100644 streampipes-extensions/streampipes-processors-change-detection-jvm/src/main/java/org/apache/streampipes/processors/changedetection/jvm/welford/WelfordEventFields.java
create mode 100644 streampipes-extensions/streampipes-processors-change-detection-jvm/src/main/resources/org.apache.streampipes.processors.changedetection.jvm.cusum/icon.png
create mode 100644 streampipes-extensions/streampipes-processors-change-detection-jvm/src/main/resources/org.apache.streampipes.processors.changedetection.jvm.welford/documentation.md
create mode 100644 streampipes-extensions/streampipes-processors-change-detection-jvm/src/main/resources/org.apache.streampipes.processors.changedetection.jvm.welford/icon.png
create mode 100644 streampipes-extensions/streampipes-processors-change-detection-jvm/src/main/resources/org.apache.streampipes.processors.changedetection.jvm.welford/strings.en
create mode 100644 streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/movingaverage/MovingAverageProcessor.java
create mode 100644 streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/movingaverage/util/MovingAverageFilter.java
create mode 100644 streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/movingaverage/util/MovingFilter.java
create mode 100644 streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/movingaverage/util/MovingMedianFilter.java
create mode 100644 streampipes-extensions/streampipes-processors-filters-jvm/src/main/resources/org.apache.streampipes.processors.filters.jvm.movingaverage/documentation.md
create mode 100644 streampipes-extensions/streampipes-processors-filters-jvm/src/main/resources/org.apache.streampipes.processors.filters.jvm.movingaverage/strings.en
create mode 100644 streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/rocketmq/RocketMQParameters.java
create mode 100644 streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/rocketmq/RocketMQPublisherSink.java
create mode 100644 streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.rocketmq/documentation.md
create mode 100644 streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.rocketmq/icon.png
create mode 100644 streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.rocketmq/strings.en
create mode 100644 streampipes-extensions/streampipes-sinks-brokers-jvm/src/test/java/org/apache/streampipes/sinks/brokers/jvm/rocketmq/TestRocketMQPublisherSink.java
create mode 100644 streampipes-integration-tests/pom.xml
create mode 100644 streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/adapters/AdapterTesterBase.java
create mode 100644 streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/adapters/AdaptersTest.java
create mode 100644 streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/adapters/PulsarAdapterTester.java
create mode 100644 streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/containers/PulsarContainer.java
create mode 100644 streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/containers/PulsarDevContainer.java
create mode 100644 streampipes-messaging-nats/pom.xml
create mode 100644 streampipes-messaging-nats/src/main/java/org/apache/streampipes/messaging/nats/AbstractNatsConnector.java
create mode 100644 streampipes-messaging-nats/src/main/java/org/apache/streampipes/messaging/nats/NatsConsumer.java
create mode 100644 streampipes-messaging-nats/src/main/java/org/apache/streampipes/messaging/nats/NatsPublisher.java
create mode 100644 streampipes-messaging-nats/src/main/java/org/apache/streampipes/messaging/nats/NatsUtils.java
create mode 100644 streampipes-messaging-nats/src/main/java/org/apache/streampipes/messaging/nats/SpNatsProtocol.java
create mode 100644 streampipes-messaging-nats/src/main/java/org/apache/streampipes/messaging/nats/SpNatsProtocolFactory.java
create mode 100644 streampipes-model/src/main/java/org/apache/streampipes/model/connect/rules/DebugSinkRuleDescription.java
create mode 100644 streampipes-model/src/main/java/org/apache/streampipes/model/function/FunctionDefinition.java
create mode 100644 streampipes-model/src/main/java/org/apache/streampipes/model/function/FunctionId.java
create mode 100644 streampipes-model/src/main/java/org/apache/streampipes/model/grounding/NatsTransportProtocol.java
create mode 100644 streampipes-model/src/main/java/org/apache/streampipes/model/monitoring/MessageCounter.java
create mode 100644 streampipes-model/src/main/java/org/apache/streampipes/model/monitoring/SpEndpointMonitoringInfo.java
create mode 100644 streampipes-model/src/main/java/org/apache/streampipes/model/monitoring/SpLogEntry.java
create mode 100644 streampipes-model/src/main/java/org/apache/streampipes/model/monitoring/SpMetricsEntry.java
create mode 100644 streampipes-model/src/main/java/org/apache/streampipes/model/nats/NatsConfig.java
create mode 100644 streampipes-model/src/test/java/org/apache/streampipes/model/datalake/DataLakeMeasureTest.java
create mode 100644 streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/function/FunctionRegistrationService.java
create mode 100644 streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/pipeline/ExtensionsLogProvider.java
create mode 100644 streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/pipeline/ExtensionsServiceLogExecutor.java
delete mode 100644 streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/pipeline/PipelineExecutionStatusCollector.java
delete mode 100644 streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/pipeline/TopicInfoCollector.java
create mode 100644 streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/setup/design/DesignDocumentUtils.java
create mode 100644 streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/setup/design/UserDesignDocument.java
create mode 100644 streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/util/AuthTokenUtils.java
create mode 100644 streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/pipeline/TestPipelinesContainingElements.java
create mode 100644 streampipes-resource-management/src/test/java/org/apache/streampipes/resource/management/AdapterResourceManagerTest.java
create mode 100644 streampipes-resource-management/src/test/java/org/apache/streampipes/resource/management/DataStreamResourceManagerTest.java
delete mode 100644 streampipes-rest/src/main/java/org/apache/streampipes/rest/api/IPipelineElement.java
delete mode 100644 streampipes-rest/src/main/java/org/apache/streampipes/rest/api/IPipelineMonitoring.java
create mode 100644 streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/AbstractMonitoringResource.java
create mode 100644 streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/AdapterMonitoringResource.java
create mode 100644 streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/AssetManagementResource.java
create mode 100644 streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/FunctionsResource.java
delete mode 100644 streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/admin/AssetManagementResource.java
delete mode 100644 streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/nouser/PipelineElementImportNoUser.java
delete mode 100644 streampipes-rest/src/test/java/org/apache/streampipes/rest/impl/datalake/DataLakeNoUserManagementV3Test.java
create mode 100644 streampipes-sdk/src/test/java/org/apache/streampipes/sdk/builder/adapter/GenericDataStreamAdapterBuilderTest.java
create mode 100644 streampipes-test-utils/src/main/java/org/apache/streampipes/test/generator/pipelineelement/DummyStreamGenerator.java
delete mode 100644 streampipes-wrapper-python/LICENSE
delete mode 100644 streampipes-wrapper-python/NOTICE
create mode 100644 streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/function/FunctionContext.java
create mode 100644 streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/function/FunctionContextGenerator.java
create mode 100644 streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/function/StreamPipesFunction.java
copy ui/src/app/connect/components/new-adapter/schema-editor/schema-editor-header/schema-editor-header.component.scss => tools/maven/checkstyle-header.txt (100%)
create mode 100644 ui/.eslintrc.json
create mode 100644 ui/.prettierrc.json
delete mode 100644 ui/README.md
create mode 100644 ui/cypress.config.ts
delete mode 100644 ui/cypress.json
delete mode 100644 ui/cypress/downloads/sp_adaptertotestschemarules.csv
create mode 100644 ui/cypress/fixtures/dataDownloadDialog/input.json
create mode 100644 ui/cypress/fixtures/dataDownloadDialog/testCsvComma.csv
create mode 100644 ui/cypress/fixtures/dataDownloadDialog/testCsvSemicolon.csv
create mode 100644 ui/cypress/fixtures/dataDownloadDialog/testJson.json
create mode 100644 ui/cypress/fixtures/dataDownloadDialog/testRemoveLinesWithMissingValues.csv
create mode 100644 ui/cypress/fixtures/datalake/missingData.json
create mode 100644 ui/cypress/support/builder/UserInputBuilder.ts
create mode 100644 ui/cypress/support/commands.ts
create mode 100644 ui/cypress/support/component-index.html
create mode 100644 ui/cypress/support/component.ts
create mode 100644 ui/cypress/support/e2e.ts
create mode 100644 ui/cypress/support/general/removeDownloadDirectory.ts
delete mode 100644 ui/cypress/support/index.ts
delete mode 100644 ui/cypress/support/utils/ConnectUtils.ts
create mode 100644 ui/cypress/support/utils/DataDownloadDialogUtils.ts
delete mode 100644 ui/cypress/support/utils/DataLakeUtils.ts
create mode 100644 ui/cypress/support/utils/DataSetUtils.ts
create mode 100644 ui/cypress/support/utils/PrepareTestDataUtils.ts
create mode 100644 ui/cypress/support/utils/connect/ConnectBtns.ts
create mode 100644 ui/cypress/support/utils/connect/ConnectUtils.ts
create mode 100644 ui/cypress/support/utils/datalake/DataLakeUtils.ts
create mode 100644 ui/cypress/support/utils/datalake/DataLakeWidgetTableUtils.ts
create mode 100644 ui/cypress/tests/adapter/editAdapter.smoke.spec.ts
create mode 100644 ui/cypress/tests/adapter/editAdapterWithPipeline.smoke.spec.ts
create mode 100644 ui/cypress/tests/dataDownloadDialog/dataDownloadDialogTest.smoke.spec.ts
create mode 100644 ui/cypress/tests/datalake/missingDataInDataLake.spec.ts
delete mode 100644 ui/cypress/tests/datalake/testSpecialCharactersInName.ts
delete mode 100644 ui/deployment/rel/config.yml
delete mode 100644 ui/deployment/rel/img/logo.png
delete mode 100644 ui/deployment/rel/img/sp-logo-right-white.png
create mode 100644 ui/projects/streampipes/platform-services/src/lib/apis/abstract-monitoring.service.ts
create mode 100644 ui/projects/streampipes/platform-services/src/lib/apis/adapter-monitoring.service.ts
create mode 100644 ui/projects/streampipes/platform-services/src/lib/apis/functions.service.ts
create mode 100644 ui/projects/streampipes/platform-services/src/lib/apis/pipeline.service.spec.ts
delete mode 100644 ui/projects/streampipes/platform-services/src/lib/pipeline.service.ts
create mode 100644 ui/src/app/connect/components/adapter-configuration/adapter-configuration-header/adapter-configuration-header.component.html
create mode 100644 ui/src/app/connect/components/adapter-configuration/adapter-configuration-header/adapter-configuration-header.component.scss
create mode 100644 ui/src/app/connect/components/adapter-configuration/adapter-configuration-header/adapter-configuration-header.component.ts
create mode 100644 ui/src/app/connect/components/adapter-configuration/adapter-configuration.component.html
create mode 100644 ui/src/app/connect/components/adapter-configuration/adapter-configuration.component.scss
create mode 100644 ui/src/app/connect/components/adapter-configuration/adapter-configuration.component.ts
create mode 100644 ui/src/app/connect/components/adapter-configuration/directives/adapter-template-configuration.directive.ts
rename ui/src/app/connect/components/{new-adapter => adapter-configuration}/format-configuration/format-configuration.component.html (100%)
rename ui/src/app/connect/components/{new-adapter => adapter-configuration}/format-configuration/format-configuration.component.scss (100%)
create mode 100644 ui/src/app/connect/components/adapter-configuration/format-configuration/format-configuration.component.ts
rename ui/src/app/connect/components/{new-adapter => adapter-configuration}/format-configuration/format-item-json/format-item-json.component.html (100%)
rename ui/src/app/connect/components/{new-adapter => adapter-configuration}/format-configuration/format-item-json/format-item-json.component.scss (100%)
rename ui/src/app/connect/components/{new-adapter => adapter-configuration}/format-configuration/format-item-json/format-item-json.component.ts (100%)
rename ui/src/app/connect/components/{new-adapter => adapter-configuration}/format-configuration/format-item/format-item.component.html (100%)
rename ui/src/app/connect/components/{new-adapter => adapter-configuration}/format-configuration/format-item/format-item.component.scss (100%)
rename ui/src/app/connect/components/{new-adapter => adapter-configuration}/format-configuration/format-item/format-item.component.ts (100%)
rename ui/src/app/connect/components/{new-adapter => adapter-configuration}/format-configuration/format-list/format-list.component.html (100%)
rename ui/src/app/connect/components/{new-adapter => adapter-configuration}/format-configuration/format-list/format-list.component.scss (100%)
rename ui/src/app/connect/components/{new-adapter => adapter-configuration}/format-configuration/format-list/format-list.component.ts (100%)
rename ui/src/app/connect/components/{new-adapter => adapter-configuration}/generic-adapter-configuration/generic-adapter-configuration.component.html (100%)
rename ui/src/app/connect/components/{new-adapter => adapter-configuration}/generic-adapter-configuration/generic-adapter-configuration.component.scss (100%)
create mode 100644 ui/src/app/connect/components/adapter-configuration/generic-adapter-configuration/generic-adapter-configuration.component.ts
rename ui/src/app/connect/components/{new-adapter => adapter-configuration}/schema-editor/error-message/error-message.component.html (100%)
rename ui/src/app/connect/components/{new-adapter => adapter-configuration}/schema-editor/error-message/error-message.component.scss (100%)
rename ui/src/app/connect/components/{new-adapter => adapter-configuration}/schema-editor/error-message/error-message.component.ts (100%)
rename ui/src/app/connect/components/{new-adapter => adapter-configuration}/schema-editor/event-property-row/event-property-row.component.html (100%)
rename ui/src/app/connect/components/{new-adapter => adapter-configuration}/schema-editor/event-property-row/event-property-row.component.scss (100%)
rename ui/src/app/connect/components/{new-adapter => adapter-configuration}/schema-editor/event-property-row/event-property-row.component.ts (100%)
create mode 100644 ui/src/app/connect/components/adapter-configuration/schema-editor/event-schema-error-hints/event-schema-error-hints.component.cy.ts
create mode 100644 ui/src/app/connect/components/adapter-configuration/schema-editor/event-schema-error-hints/event-schema-error-hints.component.html
create mode 100644 ui/src/app/connect/components/adapter-configuration/schema-editor/event-schema-error-hints/event-schema-error-hints.component.scss
create mode 100644 ui/src/app/connect/components/adapter-configuration/schema-editor/event-schema-error-hints/event-schema-error-hints.component.ts
rename ui/src/app/connect/components/{new-adapter => adapter-configuration}/schema-editor/event-schema-preview/event-schema-preview.component.html (100%)
rename ui/src/app/connect/components/{new-adapter => adapter-configuration}/schema-editor/event-schema-preview/event-schema-preview.component.scss (100%)
rename ui/src/app/connect/components/{new-adapter => adapter-configuration}/schema-editor/event-schema-preview/event-schema-preview.component.ts (100%)
create mode 100644 ui/src/app/connect/components/adapter-configuration/schema-editor/event-schema/event-schema.component.html
create mode 100644 ui/src/app/connect/components/adapter-configuration/schema-editor/event-schema/event-schema.component.scss
create mode 100644 ui/src/app/connect/components/adapter-configuration/schema-editor/event-schema/event-schema.component.ts
rename ui/src/app/connect/components/{new-adapter => adapter-configuration}/schema-editor/loading-message/loading-message.component.html (100%)
rename ui/src/app/connect/components/{new-adapter => adapter-configuration}/schema-editor/loading-message/loading-message.component.scss (100%)
rename ui/src/app/connect/components/{new-adapter => adapter-configuration}/schema-editor/loading-message/loading-message.component.ts (100%)
create mode 100644 ui/src/app/connect/components/adapter-configuration/schema-editor/schema-editor-header/schema-editor-header.component.html
rename ui/src/app/connect/components/{new-adapter => adapter-configuration}/schema-editor/schema-editor-header/schema-editor-header.component.scss (100%)
rename ui/src/app/connect/components/{new-adapter => adapter-configuration}/schema-editor/schema-editor-header/schema-editor-header.component.ts (100%)
rename ui/src/app/connect/components/{new-adapter => adapter-configuration}/specific-adapter-configuration/specific-adapter-configuration.component.html (100%)
rename ui/src/app/connect/components/{new-adapter => adapter-configuration}/specific-adapter-configuration/specific-adapter-configuration.component.scss (100%)
create mode 100644 ui/src/app/connect/components/adapter-configuration/specific-adapter-configuration/specific-adapter-configuration.component.ts
rename ui/src/app/connect/components/{new-adapter => adapter-configuration}/start-adapter-configuration/adapter-options-panel/adapter-options-panel.component.html (100%)
rename ui/src/app/connect/components/{new-adapter => adapter-configuration}/start-adapter-configuration/adapter-options-panel/adapter-options-panel.component.scss (100%)
rename ui/src/app/connect/components/{new-adapter => adapter-configuration}/start-adapter-configuration/adapter-options-panel/adapter-options-panel.component.ts (100%)
create mode 100644 ui/src/app/connect/components/adapter-configuration/start-adapter-configuration/start-adapter-configuration.component.html
rename ui/src/app/connect/components/{new-adapter => adapter-configuration}/start-adapter-configuration/start-adapter-configuration.component.scss (100%)
create mode 100644 ui/src/app/connect/components/adapter-configuration/start-adapter-configuration/start-adapter-configuration.component.ts
create mode 100644 ui/src/app/connect/components/adapter-details/abstract-adapter-details.directive.ts
create mode 100644 ui/src/app/connect/components/adapter-details/adapter-details-logs/adapter-details-logs.component.html
copy ui/src/app/{apidocs/apidocs.component.scss => connect/components/adapter-details/adapter-details-logs/adapter-details-logs.component.scss} (100%)
create mode 100644 ui/src/app/connect/components/adapter-details/adapter-details-logs/adapter-details-logs.component.ts
create mode 100644 ui/src/app/connect/components/adapter-details/adapter-details-metrics/adapter-details-metrics.component.html
create mode 100644 ui/src/app/connect/components/adapter-details/adapter-details-metrics/adapter-details-metrics.component.ts
create mode 100644 ui/src/app/connect/components/adapter-details/adapter-details-overview/adapter-details-overview.component.html
copy ui/src/app/{apidocs/apidocs.component.scss => connect/components/adapter-details/adapter-details-overview/adapter-details-overview.component.scss} (100%)
create mode 100644 ui/src/app/connect/components/adapter-details/adapter-details-overview/adapter-details-overview.component.ts
create mode 100644 ui/src/app/connect/components/adapter-details/adapter-details-tabs.ts
create mode 100644 ui/src/app/connect/components/edit-adapter/edit-adapter.component.html
copy ui/src/app/{apidocs/apidocs.component.scss => connect/components/edit-adapter/edit-adapter.component.scss} (100%)
create mode 100644 ui/src/app/connect/components/edit-adapter/edit-adapter.component.ts
delete mode 100644 ui/src/app/connect/components/new-adapter/adapter-configuration.directive.ts
delete mode 100644 ui/src/app/connect/components/new-adapter/format-configuration/format-configuration.component.ts
delete mode 100644 ui/src/app/connect/components/new-adapter/generic-adapter-configuration/generic-adapter-configuration.component.ts
delete mode 100644 ui/src/app/connect/components/new-adapter/schema-editor/event-schema/event-schema.component.html
delete mode 100644 ui/src/app/connect/components/new-adapter/schema-editor/event-schema/event-schema.component.scss
delete mode 100644 ui/src/app/connect/components/new-adapter/schema-editor/event-schema/event-schema.component.ts
delete mode 100644 ui/src/app/connect/components/new-adapter/schema-editor/schema-editor-header/schema-editor-header.component.html
delete mode 100644 ui/src/app/connect/components/new-adapter/specific-adapter-configuration/specific-adapter-configuration.component.ts
delete mode 100644 ui/src/app/connect/components/new-adapter/start-adapter-configuration/start-adapter-configuration.component.html
delete mode 100644 ui/src/app/connect/components/new-adapter/start-adapter-configuration/start-adapter-configuration.component.ts
delete mode 100644 ui/src/app/connect/dialog/adapter-export/adapter-export-dialog.component.scss
delete mode 100644 ui/src/app/connect/dialog/adapter-export/adapter-export-dialog.component.ts
delete mode 100644 ui/src/app/connect/dialog/adapter-export/adapter-export-dialog.html
delete mode 100644 ui/src/app/connect/dialog/adapter-upload/adapter-upload-dialog.component.scss
delete mode 100644 ui/src/app/connect/dialog/adapter-upload/adapter-upload-dialog.component.ts
delete mode 100644 ui/src/app/connect/dialog/adapter-upload/adapter-upload-dialog.html
create mode 100644 ui/src/app/connect/dialog/can-not-edit-adapter-dialog/can-not-edit-adapter-dialog.component.cy.ts
create mode 100644 ui/src/app/connect/dialog/can-not-edit-adapter-dialog/can-not-edit-adapter-dialog.component.html
copy ui/src/app/{configuration/export/export-dialog/data-export-dialog.component.scss => connect/dialog/can-not-edit-adapter-dialog/can-not-edit-adapter-dialog.component.scss} (100%)
create mode 100644 ui/src/app/connect/dialog/can-not-edit-adapter-dialog/can-not-edit-adapter-dialog.component.ts
delete mode 100644 ui/src/app/connect/services/icon.service.ts
create mode 100644 ui/src/app/core-ui/data-download-dialog/components/download/download.component.html
create mode 100644 ui/src/app/core-ui/data-download-dialog/components/download/download.component.scss
create mode 100644 ui/src/app/core-ui/data-download-dialog/components/download/download.component.ts
create mode 100644 ui/src/app/core-ui/data-download-dialog/components/select-data/select-data-missing-values/select-data-missing-values.component.html
create mode 100644 ui/src/app/core-ui/data-download-dialog/components/select-data/select-data-missing-values/select-data-missing-values.component.scss
create mode 100644 ui/src/app/core-ui/data-download-dialog/components/select-data/select-data-missing-values/select-data-missing-values.component.ts
create mode 100644 ui/src/app/core-ui/data-download-dialog/components/select-data/select-data-range/select-data-range.component.html
create mode 100644 ui/src/app/core-ui/data-download-dialog/components/select-data/select-data-range/select-data-range.component.scss
create mode 100644 ui/src/app/core-ui/data-download-dialog/components/select-data/select-data-range/select-data-range.component.ts
create mode 100644 ui/src/app/core-ui/data-download-dialog/components/select-data/select-data.component.html
create mode 100644 ui/src/app/core-ui/data-download-dialog/components/select-data/select-data.component.scss
create mode 100644 ui/src/app/core-ui/data-download-dialog/components/select-data/select-data.component.ts
create mode 100644 ui/src/app/core-ui/data-download-dialog/components/select-format/select-format.component.html
create mode 100644 ui/src/app/core-ui/data-download-dialog/components/select-format/select-format.component.scss
create mode 100644 ui/src/app/core-ui/data-download-dialog/components/select-format/select-format.component.ts
create mode 100644 ui/src/app/core-ui/data-download-dialog/model/data-download-dialog.model.ts
create mode 100644 ui/src/app/core-ui/data-download-dialog/model/data-export-config.model.ts
create mode 100644 ui/src/app/core-ui/data-download-dialog/model/download-progress.model.ts
create mode 100644 ui/src/app/core-ui/data-download-dialog/model/export-config.model.ts
create mode 100644 ui/src/app/core-ui/data-download-dialog/model/format-export-config.model.ts
create mode 100644 ui/src/app/core-ui/data-download-dialog/services/data-export.service.ts
create mode 100644 ui/src/app/core-ui/data-download-dialog/services/file-name.service.spec.ts
create mode 100644 ui/src/app/core-ui/data-download-dialog/services/file-name.service.ts
create mode 100644 ui/src/app/core-ui/monitoring/simple-logs/simple-logs.component.html
create mode 100644 ui/src/app/core-ui/monitoring/simple-logs/simple-logs.component.ts
create mode 100644 ui/src/app/core-ui/monitoring/simple-metrics/simple-metrics.component.html
create mode 100644 ui/src/app/core-ui/monitoring/simple-metrics/simple-metrics.component.ts
rename ui/src/app/{pipeline-details/components/monitoring/widget => core-ui}/status/status-widget.component.css (100%)
create mode 100644 ui/src/app/core-ui/status/status-widget.component.html
create mode 100644 ui/src/app/core-ui/status/status-widget.component.ts
create mode 100644 ui/src/app/data-explorer/components/widgets/utils/color-utils.ts
delete mode 100644 ui/src/app/pipeline-details/components/monitoring/widget/status/status-widget.component.html
delete mode 100644 ui/src/app/pipeline-details/components/monitoring/widget/status/status-widget.component.ts
create mode 100644 ui/src/app/pipeline-details/components/pipeline-logs/pipeline-logs.component.html
copy ui/src/app/{apidocs/apidocs.component.scss => pipeline-details/components/pipeline-logs/pipeline-logs.component.scss} (100%)
create mode 100644 ui/src/app/pipeline-details/components/pipeline-logs/pipeline-logs.component.ts
create mode 100644 ui/src/app/pipelines/components/functions-overview/abstract-function-details.directive.ts
create mode 100644 ui/src/app/pipelines/components/functions-overview/functions-logs/functions-logs.component.html
create mode 100644 ui/src/app/pipelines/components/functions-overview/functions-logs/functions-logs.component.ts
create mode 100644 ui/src/app/pipelines/components/functions-overview/functions-metrics/functions-metrics.component.html
create mode 100644 ui/src/app/pipelines/components/functions-overview/functions-metrics/functions-metrics.component.ts
create mode 100644 ui/src/app/pipelines/components/functions-overview/functions-overview.component.html
copy ui/src/app/{apidocs/apidocs.component.scss => pipelines/components/functions-overview/functions-overview.component.scss} (100%)
create mode 100644 ui/src/app/pipelines/components/functions-overview/functions-overview.component.ts
delete mode 100644 ui/tslint.json
[streampipes] 01/01: Merge remote-tracking branch 'origin/master' into HEAD
Posted by ri...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
riemer pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/streampipes.git
commit 467dba6c162d8a8c3f9c5bac41cdf5150230f45a
Merge: 4a9a8f38e 4538cc494
Author: Dominik Riemer <do...@gmail.com>
AuthorDate: Mon Jan 16 17:47:11 2023 +0100
Merge remote-tracking branch 'origin/master' into HEAD