(streampipes) branch dev updated: fix ToTransformedSchemaConverter set HEADER_PROPERTY (#2850)

[bossenti]

This is an automated email from the ASF dual-hosted git repository.

bossenti pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/streampipes.git


The following commit(s) were added to refs/heads/dev by this push:
     new ff6b97eb7c fix ToTransformedSchemaConverter set HEADER_PROPERTY (#2850)
ff6b97eb7c is described below

commit ff6b97eb7cb042e40a50432c6fe83ea4e8581e0b
Author: yanfeng1992 <huangyanfeng1...@gmail.com>
AuthorDate: Mon May 13 14:18:14 2024 +0800

    fix ToTransformedSchemaConverter set HEADER_PROPERTY (#2850)
    
    Signed-off-by: huangyanfeng <huangyanfeng1...@gmail.com>
---
 .../shared/preprocessing/convert/ToTransformedSchemaConverter.java      | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/convert/ToTransformedSchemaConverter.java
 
b/streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/convert/ToTransformedSchemaConverter.java
index b8bec63fa6..37715185ee 100644
--- 
a/streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/convert/ToTransformedSchemaConverter.java
+++ 
b/streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/convert/ToTransformedSchemaConverter.java
@@ -36,6 +36,7 @@ import 
org.apache.streampipes.model.connect.rules.value.UnitTransformRuleDescrip
 import org.apache.streampipes.model.schema.EventProperty;
 import org.apache.streampipes.model.schema.EventPropertyNested;
 import org.apache.streampipes.model.schema.EventPropertyPrimitive;
+import org.apache.streampipes.model.schema.PropertyScope;
 import org.apache.streampipes.model.util.Cloner;
 import org.apache.streampipes.sdk.helpers.EpProperties;
 import org.apache.streampipes.sdk.utils.Datatypes;
@@ -149,6 +150,7 @@ public class ToTransformedSchemaConverter implements 
ITransformationRuleVisitor,
     var property = findPrimitiveProperty(properties, rule.getRuntimeKey());
     
property.setDomainProperties(List.of(URI.create("http://schema.org/DateTime";)));
     property.setRuntimeType(Datatypes.Long.toString());
+    property.setPropertyScope(PropertyScope.HEADER_PROPERTY.toString());
     var metadata = property.getAdditionalMetadata();
     metadata.put("mode", rule.getMode());
     metadata.put("formatString", rule.getFormatString());