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 2020/10/29 19:51:47 UTC
[incubator-streampipes] branch dev updated: [hotfix] Consider
alternatives for mapping property calculation
This is an automated email from the ASF dual-hosted git repository.
riemer pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git
The following commit(s) were added to refs/heads/dev by this push:
new f4dcb7d [hotfix] Consider alternatives for mapping property calculation
f4dcb7d is described below
commit f4dcb7d32c235ae669738763124e56ae3381baf3
Author: Dominik Riemer <ri...@fzi.de>
AuthorDate: Thu Oct 29 20:51:29 2020 +0100
[hotfix] Consider alternatives for mapping property calculation
---
.../streampipes/manager/matching/PipelineVerificationHandler.java | 3 +++
1 file changed, 3 insertions(+)
diff --git a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/PipelineVerificationHandler.java b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/PipelineVerificationHandler.java
index ff80bdb..210c8c4 100644
--- a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/PipelineVerificationHandler.java
+++ b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/PipelineVerificationHandler.java
@@ -132,6 +132,9 @@ public class PipelineVerificationHandler {
} else if (property instanceof StaticPropertyGroup) {
updateStaticProperties(inputStreams, property.as(StaticPropertyGroup.class).getStaticProperties());
} else if (property instanceof StaticPropertyAlternatives) {
+ ((StaticPropertyAlternatives) property)
+ .getAlternatives()
+ .forEach(al -> updateStaticProperty(inputStreams, al.getStaticProperty()));
// TODO
} else if (property instanceof CollectionStaticProperty) {
CollectionStaticProperty collection = property.as(CollectionStaticProperty.class);