This is an automated email from the ASF dual-hosted git repository.
bossenti pushed a change to branch abstract-data-explorer-from-influx
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from a963cfee1f style: fix import order
add 7b4758e8ec adapt spelling of influx tag
add 79a490c121 change data explorer storage dispatcher to regular class
add 0fdd15d74a feat: Support custom service tags and service selection for
adapters (#2691)
add 775797c9cc monthly update of vulnerability report (#2804)
add c1dd08ab27 chore(deps): bump org.simplejavamail:simple-java-mail
(#2805)
add 28266e7031 chore(deps): bump org.checkerframework:checker-qual (#2807)
add ea776b5096 chore(deps): bump org.apache.inlong:tubemq-client from
1.11.0 to 1.12.0 (#2806)
add 1d37ce4ed7 chore(deps-dev): bump ejs from 3.1.9 to 3.1.10 in /ui
(#2808)
add d69504c915 feat(#2374): Add suggestion to test processing elements
(#2375)
add b3796ae390 Merge remote-tracking branch 'origin/dev' into
abstract-data-explorer-from-influx
No new revisions were added by this update.
Summary of changes:
VULNERABILITY.md | 8 +-
pom.xml | 7 +-
.../apache/streampipes/commons/constants/Envs.java | 7 +-
.../commons/environment/DefaultEnvironment.java | 5 +
.../commons/environment/Environment.java | 2 +
.../management/AdapterMasterManagement.java | 21 +-
.../management/management/GuessManagement.java | 19 +-
.../management/management/WorkerRestClient.java | 8 +-
.../management/management/WorkerUrlProvider.java | 42 ---
.../connect/management/util/WorkerPaths.java | 23 --
.../management/DataExplorerDispatcher.java | 3 +-
.../management/SupportedDataExplorerStorages.java | 2 +-
.../streampipes-processors-filters-jvm/pom.xml | 2 +-
.../numericalfilter/NumericalFilterProcessor.java | 6 +-
.../booleanfilter/TestBooleanFilterProcessor.java | 118 +++----
.../processor/compose/TestComposeProcessor.java | 208 ++++++-------
.../processor/merge/TestMergeByTimeProcessor.java | 276 +++++++++--------
.../NumericalFilterProcessorTest.java | 83 +++++
.../TestSwingingDoorTrendingFilterProcessor.java | 339 +++++++++++++--------
.../textfilter/TestTextFilterProcessor.java | 188 ++++++------
.../sinks/internal/jvm/datalake/DataLakeSink.java | 14 +-
.../model/connect/adapter/AdapterDescription.java | 15 +
.../ExtensionDeploymentConfiguration.java | 46 ++-
.../extensions/svcdiscovery/SpServiceTag.java | 22 ++
.../svcdiscovery/SpServiceTagPrefix.java | 1 +
.../model/runtime/RuntimeOptionsRequest.java | 11 +
.../IExtensionsServiceEndpointGenerator.java | 45 +++
.../streampipes/manager/assets/AssetFetcher.java | 2 +-
.../ExtensionsServiceEndpointGenerator.java | 76 ++---
.../ExtensionsServiceEndpointProvider.java | 32 --
.../execution/task/DiscoverEndpointsTask.java | 9 +-
.../manager/health/PipelineHealthCheck.java | 2 +-
.../CustomTransformOutputSchemaGenerator.java | 6 +-
.../manager/preview/PipelinePreview.java | 9 +-
.../remote/ContainerProvidedOptionsHandler.java | 2 +-
.../template/PipelineElementTemplateVisitor.java | 5 +-
.../streampipes/ps/DataLakeMeasureResourceV4.java | 16 +-
.../apache/streampipes/rest/ResetManagement.java | 10 +-
.../streampipes/rest/impl/ServiceTagResource.java | 27 +-
.../rest/impl/connect/DescriptionResource.java | 18 +-
.../impl/connect/RuntimeResolvableResource.java | 18 +-
.../svcdiscovery/api/ISpServiceDiscovery.java | 9 +-
.../svcdiscovery/SpServiceDiscoveryCore.java | 27 +-
streampipes-service-extensions/pom.xml | 12 +
.../extensions/CustomServiceTagResolver.java | 37 ++-
.../StreamPipesExtensionsServiceBase.java | 2 +
.../extensions/CustomServiceTagResolverTest.java | 68 +++++
.../pom.xml | 41 +--
.../streampipes/test/executors/PrefixStrategy.java | 6 +-
.../executors/ProcessingElementTestExecutor.java | 190 ++++++++++++
.../test/executors/TestConfiguration.java | 30 +-
.../test/executors/TestConfigurationBuilder.java | 62 ++++
ui/package-lock.json | 6 +-
...nt-units.service.ts => service-tags.service.ts} | 13 +-
.../src/lib/model/gen/streampipes-model.ts | 33 +-
.../platform-services/src/public-api.ts | 1 +
.../adapter-deployment-settings.component.html | 78 +++++
.../adapter-deployment-settings.component.ts | 122 ++++++++
.../adapter-settings.component.html | 14 +
.../configuration-group.component.html | 1 +
.../configuration-group.component.ts | 7 +-
ui/src/app/connect/connect.module.ts | 2 +
.../static-alternatives.component.html | 1 +
.../static-alternatives.component.ts | 6 +-
.../static-collection.component.html | 1 +
.../static-collection.component.ts | 6 +-
.../static-group/static-group.component.html | 2 +
.../static-group/static-group.component.ts | 10 +-
.../static-property.component.html | 7 +
.../static-properties/static-property.component.ts | 4 +
.../base-runtime-resolvable-input.ts | 6 +
71 files changed, 1693 insertions(+), 864 deletions(-)
delete mode 100644
streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/management/WorkerUrlProvider.java
create mode 100644
streampipes-extensions/streampipes-processors-filters-jvm/src/test/java/org/apache/streampipes/processors/filters/jvm/processor/numericalfilter/NumericalFilterProcessorTest.java
copy
streampipes-extensions/streampipes-sinks-notifications-jvm/src/main/java/org/apache/streampipes/sinks/notifications/jvm/migrations/OneSignalSinkMigrationV1.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/deployment/ExtensionDeploymentConfiguration.java
(53%)
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/IExtensionsServiceEndpointGenerator.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/endpoint/ExtensionsServiceEndpointProvider.java
copy
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/monitoring/MonitoringResource.java
=>
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/ServiceTagResource.java
(62%)
copy
streampipes-extensions/streampipes-sinks-notifications-jvm/src/main/java/org/apache/streampipes/sinks/notifications/jvm/migrations/OneSignalSinkMigrationV1.java
=>
streampipes-service-extensions/src/main/java/org/apache/streampipes/service/extensions/CustomServiceTagResolver.java
(50%)
create mode 100644
streampipes-service-extensions/src/test/java/org/apache/streampipes/service/extensions/CustomServiceTagResolverTest.java
copy {streampipes-resource-management =>
streampipes-test-utils-executors}/pom.xml (74%)
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/exceptions/NoValidSepTypeException.java
=>
streampipes-test-utils-executors/src/main/java/org/apache/streampipes/test/executors/PrefixStrategy.java
(88%)
create mode 100644
streampipes-test-utils-executors/src/main/java/org/apache/streampipes/test/executors/ProcessingElementTestExecutor.java
copy
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/transform/schema/DeleteTransformationRule.java
=>
streampipes-test-utils-executors/src/main/java/org/apache/streampipes/test/executors/TestConfiguration.java
(57%)
create mode 100644
streampipes-test-utils-executors/src/main/java/org/apache/streampipes/test/executors/TestConfigurationBuilder.java
copy
ui/projects/streampipes/platform-services/src/lib/apis/{measurement-units.service.ts
=> service-tags.service.ts} (78%)
create mode 100644
ui/src/app/connect/components/adapter-configuration/adapter-settings/adapter-deployment-settings/adapter-deployment-settings.component.html
create mode 100644
ui/src/app/connect/components/adapter-configuration/adapter-settings/adapter-deployment-settings/adapter-deployment-settings.component.ts