This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch sp-1157-upgrade-third-party-services
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 592c59ecc Use latest CouchDB version 3.3.1 (#1157)
add 73422d4a4 [#1132] Remove set adapters from e2e tests
add ec9ee297e Merge branch 'dev' into SP-1132
add 6b826b28c [#1132] Fix preprocessing rule e2e tests
add 62c2ea4c6 Merge branch 'dev' into SP-1132
add 4a97d1229 [#1132] Add wait to fix processing element tests
add 09e70845e [hotfix] Extract string into a variable
add 8b079f028 Merge pull request #1153 from apache/SP-1132
add dc3aa010b [hotfix] Fix processing element e2e tests
add 8e2a4c3ed Bump proton-j from 0.30.0 to 0.34.0
add 8a4f9df82 Merge pull request #1130 from
apache/dependabot/maven/org.apache.qpid-proton-j-0.34.0
add d1df87d77 Bump javapoet from 1.6.1 to 1.13.0
add 6270a449d remove javapoet
add 21ebe64ef Merge branch 'dev' into
dependabot/maven/com.squareup-javapoet-1.13.0
add 4b0636995 Merge pull request #1131 from
apache/dependabot/maven/com.squareup-javapoet-1.13.0
add 10e0e720c Bump ua-parser-js from 0.7.32 to 0.7.33 in /ui
add 09ff63830 Merge pull request #1156 from
apache/dependabot/npm_and_yarn/ui/ua-parser-js-0.7.33
add a43b05635 Bump @angular-eslint/eslint-plugin from 15.1.0 to 15.2.0 in
/ui (#1152)
add 381465a10 [#877] apply formatting and linting to data-explorer module
(#1139)
add b89ab89ab [#877] Format and lint dashboard module (#1154)
add f38b07910 [#877] apply formatting and linting to editor module (#1138)
add ede2fff0b add rest endpoint to query a function definition by it's id
(#1149)
add 51ba6d871 Bump pre-commit from 2.21.0 to 3.0.0 in
/streampipes-client-python (#1151)
add 569421cd8 refactor: further clean up python data model & introduce
function definition (#1147)
add a5f44f65e Bump lz4-java from 1.7.1 to 1.8.0 (#1160)
add a23795b43 Bump @angular-eslint/eslint-plugin-template from 15.1.0 to
15.2.0 in /ui (#1161)
add 9e71a2809 Update GitHub notification settings (#1162)
add ebfd339fb remove outdated README files (#1167)
add 22182a9a1 Bump simple-java-mail from 7.6.0 to 7.8.0
add b18285738 Merge pull request #1170 from
apache/dependabot/maven/org.simplejavamail-simple-java-mail-7.8.0
add 679e61517 Bump maven-dependency-plugin from 3.2.0 to 3.5.0
add 540650aa0 Merge pull request #1159 from
apache/dependabot/maven/org.apache.maven.plugins-maven-dependency-plugin-3.5.0
add b7c3e5ebf [#1146] Session based implementation of IoTDB sink
add f57039132 [#1146] Fix onEvent() implementation
add 9340f7f2f [#1146] add tests
add 0120fd201 [#1146] update iotdb docker-compose files in installer/cli
add 56f464c03 [#1146] using SessionPool instead of Session to handle
connection dies
add 3abfd88fe Merge pull request #1166 from
SteveYurongSu/iotdb-session-client
add e02d3bf5e Replace consul-client with consul-api library (#1158)
add bac4d45e6 Remove obsolete class (#1158)
add 19f525019 Fix checkstyle (#1158)
add ca9d9b33b Bump consul version to 1.14.3 (#1157)
add 00a043c3f [hotfix] Update Consul version in root docker-compose.yml
new 99b67f90d Use latest CouchDB version 3.3.1 (#1157)
new 530bac0c3 Refactor code to support Influx 2 (#1157)
new c50fae6d4 Bump influx version to 2.6 in compose files (#1157)
new 15d71e53e Bump influx version to 2.6 in helm charts (#1157)
new b1eac7409 Merge branch 'sp-1157-upgrade-third-party-services' of
github.com:apache/streampipes into sp-1157-upgrade-third-party-services
The 5 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 | 14 +
docker-compose.yml | 16 +-
installer/README.md | 78 --
.../deploy/standalone/consul/docker-compose.yml | 6 +-
.../deploy/standalone/influxdb/docker-compose.yml | 10 +-
.../deploy/standalone/iotdb/docker-compose.dev.yml | 5 +-
.../cli/deploy/standalone/iotdb/docker-compose.yml | 5 +-
installer/compose/docker-compose.full.yml | 12 +-
installer/compose/docker-compose.nats.yml | 12 +-
installer/compose/docker-compose.yml | 12 +-
.../external/consul/consul-deployment.yaml | 2 +-
.../external/influxdb/influxdb-deployment.yaml | 19 +-
.../{influxdb-pvc.yaml => influxdb2-pvc.yaml} | 10 +-
installer/k8s/values.yaml | 13 +-
pom.xml | 26 +-
...ive-data-from-the-streampipes-data-stream.ipynb | 2 +-
streampipes-client-python/setup.py | 2 +-
.../functions/broker/__init__.py | 8 +
.../functions/function_handler.py | 7 +-
.../functions/streampipes_function.py | 25 +-
.../streampipes_client/model/common.py | 33 +-
.../model/container/resource_container.py | 12 +-
.../streampipes_client/model/resource/__init__.py | 2 +
.../model/resource/data_lake_measure.py | 1 +
.../model/resource/data_stream.py | 1 +
.../model/resource/function_definition.py | 71 ++
.../streampipes_client/model/resource/resource.py | 22 +-
.../tests/client/test_endpoint.py | 8 +-
.../tests/functions/test_function_handler.py | 8 +-
.../apache/streampipes/commons/constants/Envs.java | 83 +-
.../commons/environment/DefaultEnvironment.java | 101 ++
.../commons/environment/Environment.java | 63 ++
.../commons/environment/Environments.java | 11 +-
.../variable/BooleanEnvironmentVariable.java} | 13 +-
.../variable/EnvResolver.java} | 5 +-
.../environment/variable/EnvironmentVariable.java | 68 ++
.../variable/IntEnvironmentVariable.java} | 10 +-
.../variable/StringEnvironmentVariable.java} | 11 +-
.../streampipes/config/backend/BackendConfig.java | 4 -
.../dataexplorer/commons/DataExplorerWriter.java | 67 --
.../dataexplorer/commons/TimeSeriesStore.java | 8 +-
.../dataexplorer/commons/auth/AuthInterceptor.java | 32 +-
.../dataexplorer/commons/image/ImageStore.java | 20 +-
.../commons/influx/InfluxClientProvider.java | 66 ++
.../commons/influx/InfluxConnectionSettings.java | 39 +-
.../dataexplorer/commons/influx/InfluxStore.java | 14 +-
streampipes-data-explorer/pom.xml | 5 +
.../dataexplorer/DataLakeManagementV4.java | 3 +-
.../dataexplorer/query/DataExplorerQuery.java | 4 +-
.../dataexplorer/utils/DataExplorerUtils.java | 15 -
.../dataexplorer/v4/query/DataExplorerQueryV4.java | 6 +-
.../management/config/ConfigExtractor.java | 4 +-
streampipes-extensions/README.md | 110 --
.../iiot/protocol/stream/FileStreamProtocol.java | 4 +-
.../streampipes-sinks-databases-jvm/pom.xml | 17 +-
.../sinks/databases/jvm/iotdb/IotDb.java | 214 ++--
.../sinks/databases/jvm/iotdb/IotDbController.java | 66 +-
.../sinks/databases/jvm/iotdb/IotDbParameters.java | 70 +-
.../jvm/jdbcclient/model/DbDataTypeFactory.java | 21 -
.../jvm/jdbcclient/model/DbDataTypes.java | 5 -
.../jvm/jdbcclient/model/SupportedDbEngines.java | 1 -
.../documentation.md | 31 +-
.../strings.en | 15 +-
.../databases/jvm/iotdb/TestIotDbParameters.java | 52 +
.../sinks/internal/jvm/datalake/DataLakeSink.java | 3 +-
.../pom.xml | 2 +-
streampipes-integration-tests/pom.xml | 11 +
.../svcdiscovery/AbstractConsulTest.java | 74 ++
.../svcdiscovery/ConsulKvManagementTest.java | 63 ++
.../svcdiscovery/ConsulSpConfigTest.java | 71 ++
.../svcdiscovery/ConsulSpServiceDiscoveryTest.java | 105 ++
.../src/test/resources/logback-test.xml | 20 +-
.../function/FunctionRegistrationService.java | 4 +
.../streampipes/rest/impl/FunctionsResource.java | 7 +
streampipes-sdk/pom.xml | 6 +-
.../svcdiscovery/api/ISpKvManagement.java | 2 -
.../svcdiscovery/api/model/ConfigItem.java | 24 +
streampipes-service-discovery-consul/pom.xml | 9 +-
.../svcdiscovery/consul/AbstractConsulService.java | 14 +-
.../consul/ConsulHealthServiceManager.java | 82 +-
.../svcdiscovery/consul/ConsulProvider.java | 79 +-
.../svcdiscovery/consul/ConsulSpConfig.java | 63 +-
.../svcdiscovery/consul/SpConsulKvManagement.java | 55 +-
.../consul/SpConsulServiceDiscovery.java | 95 +-
.../svcdiscovery/SpServiceDiscovery.java | 21 +-
streampipes-storage-couchdb/pom.xml | 4 +
ui/.eslintignore | 6 -
ui/.prettierignore | 6 -
.../fixtures/connect/aggregationRules/expected.csv | 2 -
.../support/builder/GenericAdapterBuilder.ts | 2 +-
.../support/utils/DataDownloadDialogUtils.ts | 2 -
ui/cypress/support/utils/PrepareTestDataUtils.ts | 14 +-
.../support/utils/ProcessingElementTestUtils.ts | 20 +-
ui/cypress/support/utils/connect/ConnectUtils.ts | 52 +-
ui/cypress/support/utils/datalake/DataLakeUtils.ts | 16 +-
.../adapter/createAdapterWithoutStarting.spec.ts | 5 +-
ui/cypress/tests/adapter/formats/format.spec.ts | 4 +-
ui/cypress/tests/adapter/rules/streamRules.spec.ts | 2 +-
.../dataDownloadDialogTest.smoke.spec.ts | 1 +
ui/cypress/tests/datalake/deleteWidget.ts | 1 -
.../datalake/widgetDataConfiguration.smoke.spec.ts | 2 -
ui/package-lock.json | 424 ++++----
ui/package.json | 4 +-
.../pipeline-element-runtime-info.component.html | 2 +-
.../adapter-started-dialog.component.html | 3 +-
.../components/grid/dashboard-grid.component.css | 2 +-
.../components/grid/dashboard-grid.component.html | 32 +-
.../components/grid/dashboard-grid.component.ts | 255 ++---
.../overview/dashboard-overview.component.css | 4 +-
.../overview/dashboard-overview.component.html | 262 +++--
.../overview/dashboard-overview.component.ts | 240 +++--
.../components/panel/dashboard-panel.component.css | 6 +-
.../panel/dashboard-panel.component.html | 81 +-
.../components/panel/dashboard-panel.component.ts | 136 ++-
.../standalone/standalone-dashboard.component.css | 2 +-
.../standalone/standalone-dashboard.component.html | 10 +-
.../standalone/standalone-dashboard.component.ts | 20 +-
.../widget/dashboard-widget.component.css | 17 +-
.../widget/dashboard-widget.component.html | 385 ++++---
.../widget/dashboard-widget.component.ts | 311 +++---
.../components/widgets/area/area-config.ts | 3 -
.../widgets/area/area-widget.component.css | 6 +-
.../widgets/area/area-widget.component.html | 49 +-
.../widgets/area/area-widget.component.ts | 15 +-
.../components/widgets/bar-race/bar-race-config.ts | 49 +-
.../bar-race/bar-race-widget.component.html | 26 +-
.../bar-race/bar-race-widget.component.scss | 30 +-
.../widgets/bar-race/bar-race-widget.component.ts | 276 ++---
.../components/widgets/base/base-config.ts | 1 -
.../components/widgets/base/base-echarts-widget.ts | 40 +-
.../widgets/base/base-ngx-charts-widget.ts | 27 +-
.../widgets/base/base-ngx-line-charts-widget.ts | 46 +-
.../widgets/base/base-ngx-line-config.ts | 60 +-
.../components/widgets/base/base-widget.ts | 437 ++++----
.../components/widgets/gauge/gauge-config.ts | 33 +-
.../widgets/gauge/gauge-widget.component.css | 10 +-
.../widgets/gauge/gauge-widget.component.html | 38 +-
.../widgets/gauge/gauge-widget.component.ts | 26 +-
.../components/widgets/html/html-config.ts | 21 +-
.../widgets/html/html-widget.component.css | 10 +-
.../widgets/html/html-widget.component.html | 17 +-
.../widgets/html/html-widget.component.ts | 20 +-
.../components/widgets/image/image-config.ts | 16 +-
.../widgets/image/image-widget.component.css | 6 +-
.../widgets/image/image-widget.component.html | 4 +-
.../widgets/image/image-widget.component.ts | 25 +-
.../components/widgets/line/line-config.ts | 13 +-
.../widgets/line/line-widget.component.css | 10 +-
.../widgets/line/line-widget.component.html | 49 +-
.../widgets/line/line-widget.component.ts | 16 +-
.../dashboard/components/widgets/map/map-config.ts | 66 +-
.../widgets/map/map-widget.component.css | 8 +-
.../widgets/map/map-widget.component.html | 29 +-
.../components/widgets/map/map-widget.component.ts | 90 +-
.../components/widgets/number/number-config.ts | 21 +-
.../widgets/number/number-widget.component.css | 15 +-
.../widgets/number/number-widget.component.html | 16 +-
.../widgets/number/number-widget.component.ts | 105 +-
.../dashboard/components/widgets/raw/raw-config.ts | 33 +-
.../widgets/raw/raw-widget.component.css | 10 +-
.../widgets/raw/raw-widget.component.html | 23 +-
.../components/widgets/raw/raw-widget.component.ts | 30 +-
.../stacked-line-chart-config.ts | 42 +-
.../stacked-line-chart-widget.component.html | 26 +-
.../stacked-line-chart-widget.component.scss | 30 +-
.../stacked-line-chart-widget.component.ts | 203 ++--
.../components/widgets/status/status-config.ts | 34 +-
.../widgets/status/status-widget.component.html | 19 +-
.../widgets/status/status-widget.component.scss | 42 +-
.../widgets/status/status-widget.component.ts | 94 +-
.../components/widgets/table/table-config.ts | 43 +-
.../widgets/table/table-widget.component.css | 10 +-
.../widgets/table/table-widget.component.html | 50 +-
.../widgets/table/table-widget.component.ts | 52 +-
.../widgets/trafficlight/traffic-light-config.ts | 48 +-
.../traffic-light-widget.component.css | 14 +-
.../traffic-light-widget.component.html | 54 +-
.../trafficlight/traffic-light-widget.component.ts | 52 +-
.../widgets/wordcloud/wordcloud-config.ts | 57 +-
.../wordcloud/wordcloud-widget.component.html | 22 +-
.../wordcloud/wordcloud-widget.component.scss | 32 +-
.../wordcloud/wordcloud-widget.component.ts | 245 +++--
.../dashboard/dashboard.can-deactivate.guard.ts | 28 +-
ui/src/app/dashboard/dashboard.module.ts | 156 ++-
ui/src/app/dashboard/dashboard.routes.ts | 9 +-
.../add-visualization-dialog.component.html | 116 +-
.../add-visualization-dialog.component.scss | 8 +-
.../add-visualization-dialog.component.ts | 476 +++++----
.../edit-dashboard-dialog.component.html | 71 +-
.../edit-dashboard-dialog.component.scss | 4 +-
.../edit-dashboard-dialog.component.ts | 17 +-
.../dashboard/registry/widget-config-builder.ts | 190 +++-
ui/src/app/dashboard/registry/widget-registry.ts | 20 +-
.../dashboard/sdk/collected-schema-requirements.ts | 14 +-
ui/src/app/dashboard/sdk/ep-requirements.ts | 182 ++--
.../sdk/extractor/static-property-extractor.ts | 54 +-
.../app/dashboard/sdk/matching/datatype-match.ts | 20 +-
.../sdk/matching/domain-property-match.ts | 15 +-
.../dashboard/sdk/matching/list-property-match.ts | 16 +-
.../sdk/matching/mapping-property-generator.ts | 15 +-
.../sdk/matching/primitive-property-match.ts | 13 +-
.../app/dashboard/sdk/matching/property-match.ts | 13 +-
ui/src/app/dashboard/sdk/matching/schema-match.ts | 11 +-
ui/src/app/dashboard/sdk/model/datatypes.ts | 10 +-
ui/src/app/dashboard/sdk/model/vocabulary.ts | 1 -
.../dashboard/sdk/schema-requirements-builder.ts | 55 +-
ui/src/app/dashboard/services/edit-mode.service.ts | 9 +-
.../services/refresh-dashboard.service.ts | 1 -
.../dashboard/services/reload-pipeline.service.ts | 9 +-
ui/src/app/dashboard/services/resize.service.ts | 1 -
...lorer-widget-appearance-settings.component.html | 41 +-
...xplorer-widget-appearance-settings.component.ts | 60 +-
.../data-explorer-designer-panel.component.html | 136 ++-
.../data-explorer-designer-panel.component.scss | 10 +-
.../data-explorer-designer-panel.component.ts | 119 ++-
...ta-explorer-widget-data-settings.component.html | 259 +++--
...ta-explorer-widget-data-settings.component.scss | 43 +-
...data-explorer-widget-data-settings.component.ts | 375 ++++---
.../field-selection-panel.component.html | 77 +-
.../field-selection-panel.component.scss | 11 +-
.../field-selection-panel.component.ts | 188 ++--
.../field-selection/field-selection.component.html | 27 +-
.../field-selection/field-selection.component.scss | 2 +-
.../field-selection/field-selection.component.ts | 44 +-
.../filter-selection-panel.component.html | 125 ++-
.../filter-selection-panel.component.ts | 150 +--
.../group-selection-panel.component.html | 45 +-
.../group-selection-panel.component.scss | 2 +-
.../group-selection-panel.component.ts | 108 +-
...-explorer-visualisation-settings.component.html | 80 +-
...ta-explorer-visualisation-settings.component.ts | 33 +-
...data-explorer-dashboard-overview.component.html | 244 +++--
...data-explorer-dashboard-overview.component.scss | 4 +-
.../data-explorer-dashboard-overview.component.ts | 224 ++--
.../data-explorer-dashboard-panel.component.css | 8 +-
.../data-explorer-dashboard-panel.component.html | 276 +++--
.../data-explorer-dashboard-panel.component.ts | 617 +++++------
.../time-selector/timeRangeSelector.component.html | 81 +-
.../time-selector/timeRangeSelector.component.scss | 6 +-
.../time-selector/timeRangeSelector.component.ts | 267 ++---
.../widget-view/abstract-widget-view.directive.ts | 252 +++--
.../data-explorer-dashboard-grid.component.html | 41 +-
.../data-explorer-dashboard-grid.component.scss | 7 +-
.../data-explorer-dashboard-grid.component.ts | 136 +--
...ta-explorer-dashboard-slide-view.component.html | 88 +-
...ta-explorer-dashboard-slide-view.component.scss | 32 +-
...data-explorer-dashboard-slide-view.component.ts | 163 +--
.../data-explorer-dashboard-widget.component.html | 220 ++--
.../data-explorer-dashboard-widget.component.scss | 14 +-
.../data-explorer-dashboard-widget.component.ts | 379 +++----
.../components/widget/widget.directive.ts | 4 +-
.../base/base-data-explorer-widget.directive.ts | 513 +++++----
.../components/widgets/base/base-widget-config.ts | 272 ++---
.../widgets/base/data-explorer-widget-data.ts | 33 +-
.../correlation-chart-widget-config.component.html | 46 +-
.../correlation-chart-widget-config.component.ts | 75 +-
.../correlation-chart-widget.component.html | 40 +-
.../correlation-chart-widget.component.ts | 426 ++++----
.../model/correlation-chart-widget.model.ts | 16 +-
...distribution-chart-widget-config.component.html | 115 +-
.../distribution-chart-widget-config.component.ts | 97 +-
.../distribution-chart-widget.component.html | 55 +-
.../distribution-chart-widget.component.ts | 371 +++----
.../model/distribution-chart-widget.model.ts | 19 +-
.../value-heatmap/value-heatmap.component.html | 14 +-
.../value-heatmap/value-heatmap.component.ts | 300 +++---
.../config/heatmap-widget-config.component.html | 20 +-
.../config/heatmap-widget-config.component.ts | 72 +-
.../widgets/heatmap/heatmap-widget.component.html | 40 +-
.../widgets/heatmap/heatmap-widget.component.scss | 6 +-
.../widgets/heatmap/heatmap-widget.component.ts | 500 +++++----
.../widgets/heatmap/model/heatmap-widget.model.ts | 14 +-
.../config/image-widget-config.component.html | 12 +-
.../image/config/image-widget-config.component.ts | 65 +-
.../widgets/image/image-widget.component.css | 10 +-
.../widgets/image/image-widget.component.html | 31 +-
.../widgets/image/image-widget.component.ts | 160 +--
.../widgets/image/model/image-widget.model.ts | 12 +-
.../indicator-chart-widget-config.component.html | 25 +-
.../indicator-chart-widget-config.component.ts | 63 +-
.../indicator-chart-widget.component.html | 36 +-
.../indicator/indicator-chart-widget.component.ts | 218 ++--
.../model/indicator-chart-widget.model.ts | 16 +-
.../map/config/map-widget-config.component.html | 100 +-
.../map/config/map-widget-config.component.ts | 114 +-
.../widgets/map/map-widget.component.html | 31 +-
.../widgets/map/map-widget.component.scss | 8 +-
.../components/widgets/map/map-widget.component.ts | 401 ++++---
.../widgets/map/model/map-widget.model.ts | 25 +-
.../config/table-widget-config.component.html | 25 +-
.../table/config/table-widget-config.component.ts | 75 +-
.../widgets/table/model/table-widget.model.ts | 16 +-
.../widgets/table/table-widget.component.html | 111 +-
.../widgets/table/table-widget.component.scss | 7 +-
.../widgets/table/table-widget.component.ts | 201 ++--
.../time-series-chart-widget-config.component.html | 19 +-
.../time-series-chart-widget-config.component.ts | 277 ++---
.../model/time-series-chart-widget.model.ts | 39 +-
.../time-series-chart/services/color.service.ts | 1 -
.../time-series-chart-widget.component.html | 49 +-
.../time-series-chart-widget.component.scss | 12 +-
.../time-series-chart-widget.component.ts | 968 +++++++++--------
.../aggregate-configuration.component.css | 1 -
.../aggregate-configuration.component.html | 27 +-
.../aggregate-configuration.component.ts | 43 +-
.../components/widgets/utils/color-utils.ts | 35 +-
.../group-configuration.component.css | 1 -
.../group-configuration.component.html | 39 +-
.../group-configuration.component.ts | 63 +-
.../load-data-spinner.component.ts | 17 +-
.../no-data/no-data-in-date-range.component.html | 15 +-
.../no-data/no-data-in-date-range.component.ts | 21 +-
.../select-color-properties.component.html | 167 ++-
.../select-color-properties.component.scss | 14 +-
.../select-color-properties.component.ts | 133 ++-
.../select-properties.component.css | 3 +-
.../select-properties.component.html | 39 +-
.../select-properties.component.ts | 81 +-
.../select-property/select-property.component.html | 25 +-
.../select-property/select-property.component.ts | 31 +-
.../too-much-data/too-much-data.component.html | 33 +-
.../too-much-data/too-much-data.component.scss | 3 +-
.../utils/too-much-data/too-much-data.component.ts | 33 +-
.../data-explorer-panel.can-deactivate.guard.ts | 28 +-
ui/src/app/data-explorer/data-explorer.module.ts | 282 ++---
ui/src/app/data-explorer/data-explorer.routes.ts | 9 +-
...a-explorer-edit-data-view-dialog.component.html | 54 +-
...a-explorer-edit-data-view-dialog.component.scss | 4 +-
...ata-explorer-edit-data-view-dialog.component.ts | 64 +-
.../models/dataview-dashboard.model.ts | 45 +-
.../app/data-explorer/models/multi-series.model.ts | 1 -
.../registry/data-explorer-widget-registry.ts | 1 -
.../registry/data-explorer-widgets.ts | 112 +-
.../data-explorer-field-provider-service.ts | 314 +++---
.../services/refresh-dashboard.service.ts | 1 -
.../app/data-explorer/services/resize.service.ts | 1 -
.../services/time-selection.service.ts | 10 +-
.../services/widget-configuration.service.ts | 10 +-
.../data-explorer/services/widget-type.service.ts | 12 +-
.../output-strategy/base/BaseOutputStrategy.ts | 26 +-
.../custom-output-strategy.component.html | 86 +-
.../custom-output-strategy.component.scss | 1 -
.../custom-output-strategy.component.ts | 101 +-
.../output-strategy/output-strategy.component.html | 44 +-
.../output-strategy/output-strategy.component.scss | 10 +-
.../output-strategy/output-strategy.component.ts | 43 +-
.../property-selection.component.html | 37 +-
.../property-selection.component.scss | 4 +-
.../property-selection.component.ts | 90 +-
.../user-defined-output.component.html | 85 +-
.../user-defined-output.component.scss | 1 -
.../user-defined-output.component.ts | 137 +--
.../pipeline-assembly.component.html | 156 ++-
.../pipeline-assembly.component.scss | 11 +-
.../pipeline-assembly.component.ts | 226 ++--
.../pipeline-element-documentation.component.html | 8 +-
.../pipeline-element-documentation.component.scss | 2 +-
.../pipeline-element-documentation.component.ts | 52 +-
.../pipeline-element-icon-stand-row.component.html | 58 +-
.../pipeline-element-icon-stand-row.component.scss | 84 +-
.../pipeline-element-icon-stand-row.component.ts | 59 +-
.../pipeline-element-icon-stand.component.html | 244 +++--
.../pipeline-element-icon-stand.component.scss | 89 +-
.../pipeline-element-icon-stand.component.ts | 306 +++---
.../pipeline-element-options.component.html | 142 ++-
.../pipeline-element-options.component.ts | 338 +++---
.../pipeline-element-preview.component.html | 17 +-
.../pipeline-element-preview.component.scss | 32 +-
.../pipeline-element-preview.component.ts | 76 +-
.../pipeline-element-recommendation.component.html | 35 +-
.../pipeline-element-recommendation.component.ts | 290 ++---
.../pipeline-element.component.html | 9 +-
.../pipeline-element/pipeline-element.component.ts | 38 +-
.../components/pipeline/pipeline.component.html | 116 +-
.../components/pipeline/pipeline.component.ts | 1107 ++++++++++++--------
ui/src/app/editor/constants/editor.constants.ts | 13 +-
.../compatible-elements.component.html | 41 +-
.../compatible-elements.component.scss | 13 +-
.../compatible-elements.component.ts | 138 +--
.../dialog/customize/customize.component.html | 178 +++-
.../dialog/customize/customize.component.scss | 7 +-
.../editor/dialog/customize/customize.component.ts | 365 ++++---
ui/src/app/editor/dialog/help/help.component.html | 88 +-
ui/src/app/editor/dialog/help/help.component.scss | 8 +-
ui/src/app/editor/dialog/help/help.component.ts | 157 +--
.../matching-error/matching-error.component.html | 39 +-
.../matching-error/matching-error.component.scss | 2 +-
.../matching-error/matching-error.component.ts | 31 +-
.../missing-elements-for-tutorial.component.html | 24 +-
.../missing-elements-for-tutorial.component.scss | 2 +-
.../missing-elements-for-tutorial.component.ts | 24 +-
.../pipeline-element-discovery.component.html | 41 +-
.../pipeline-element-discovery.component.scss | 4 +-
.../pipeline-element-discovery.component.ts | 124 +--
.../save-pipeline/save-pipeline.component.html | 144 ++-
.../save-pipeline/save-pipeline.component.scss | 20 +-
.../save-pipeline/save-pipeline.component.ts | 306 +++---
.../welcome-tour/welcome-tour.component.html | 45 +-
.../welcome-tour/welcome-tour.component.scss | 28 +-
.../dialog/welcome-tour/welcome-tour.component.ts | 69 +-
ui/src/app/editor/editor.component.html | 47 +-
ui/src/app/editor/editor.component.scss | 10 +-
ui/src/app/editor/editor.component.ts | 272 ++---
ui/src/app/editor/editor.module.ts | 19 +-
.../filter/enabled-pipeline-element.filter.ts | 17 +-
ui/src/app/editor/model/editor.model.ts | 86 +-
ui/src/app/editor/model/jsplumb.model.ts | 12 +-
ui/src/app/editor/services/editor.service.ts | 228 ++--
.../app/editor/services/jsplumb-bridge.service.ts | 32 +-
.../app/editor/services/jsplumb-config.service.ts | 314 +++---
.../editor/services/jsplumb-endpoint.service.ts | 80 +-
.../app/editor/services/jsplumb-factory.service.ts | 43 +-
ui/src/app/editor/services/jsplumb.service.ts | 695 +++++++-----
.../app/editor/services/object-provider.service.ts | 74 +-
.../services/pipeline-canvas-scrolling.service.ts | 19 +-
.../app/editor/services/pipeline-editor.service.ts | 23 +-
.../services/pipeline-element-dragged.service.ts | 12 +-
.../services/pipeline-element-group-filter.pipe.ts | 29 +-
.../services/pipeline-element-name-filter.pipe.ts | 28 +-
.../pipeline-element-recommendation.service.ts | 43 +-
.../services/pipeline-element-type-filter.pipe.ts | 25 +-
.../services/pipeline-positioning.service.ts | 362 ++++---
.../app/editor/services/pipeline-style.service.ts | 114 +-
.../editor/services/pipeline-validation.service.ts | 119 ++-
ui/src/app/editor/utils/editor.utils.ts | 127 ++-
ui/src/app/editor/utils/style-sanitizer.ts | 13 +-
.../elements/pipeline-elements-row.component.html | 4 +-
.../preview/pipeline-preview.component.html | 4 +-
428 files changed, 18407 insertions(+), 12829 deletions(-)
delete mode 100644 installer/README.md
copy installer/k8s/templates/external/influxdb/{influxdb-pvc.yaml =>
influxdb2-pvc.yaml} (87%)
create mode 100644
streampipes-client-python/streampipes_client/model/resource/function_definition.py
create mode 100644
streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/DefaultEnvironment.java
create mode 100644
streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/Environment.java
copy
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/HavingClause.java
=>
streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/Environments.java
(83%)
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/{parser/BooleanParser.java
=> environment/variable/BooleanEnvironmentVariable.java} (72%)
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/{exceptions/NoValidSepaTypeException.java
=> environment/variable/EnvResolver.java} (88%)
create mode 100644
streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/variable/EnvironmentVariable.java
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/{parser/IntegerParser.java
=> environment/variable/IntEnvironmentVariable.java} (76%)
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/{parser/StringParser.java
=> environment/variable/StringEnvironmentVariable.java} (75%)
delete mode 100644
streampipes-data-explorer-commons/src/main/java/org/apache/streampipes/dataexplorer/commons/DataExplorerWriter.java
copy
streampipes-security-jwt/src/main/java/org/apache/streampipes/security/jwt/PublicKeyResolver.java
=>
streampipes-data-explorer-commons/src/main/java/org/apache/streampipes/dataexplorer/commons/auth/AuthInterceptor.java
(59%)
create mode 100644
streampipes-data-explorer-commons/src/main/java/org/apache/streampipes/dataexplorer/commons/influx/InfluxClientProvider.java
delete mode 100644 streampipes-extensions/README.md
create mode 100644
streampipes-extensions/streampipes-sinks-databases-jvm/src/test/java/org/apache/streampipes/sinks/databases/jvm/iotdb/TestIotDbParameters.java
create mode 100644
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/svcdiscovery/AbstractConsulTest.java
create mode 100644
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/svcdiscovery/ConsulKvManagementTest.java
create mode 100644
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/svcdiscovery/ConsulSpConfigTest.java
create mode 100644
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/svcdiscovery/ConsulSpServiceDiscoveryTest.java
copy streampipes-service-base/src/main/resources/logback-spring.xml =>
streampipes-integration-tests/src/test/resources/logback-test.xml (67%)
