This is an automated email from the ASF dual-hosted git repository. bossenti pushed a commit to branch rel/0.95.0 in repository https://gitbox.apache.org/repos/asf/streampipes.git
commit 24fc271f9dd32d09440b8f1c3c3ca0577a743f2c Author: yanfeng1992 <[email protected]> AuthorDate: Mon May 13 14:18:14 2024 +0800 fix ToTransformedSchemaConverter set HEADER_PROPERTY (#2850) Signed-off-by: huangyanfeng <[email protected]> --- .../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());
