This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a commit to branch
4246-propertyscope-bug-for-compact-adapter-config
in repository https://gitbox.apache.org/repos/asf/streampipes.git
The following commit(s) were added to
refs/heads/4246-propertyscope-bug-for-compact-adapter-config by this push:
new 0921c78d45 fix(#4246): Accept full and shorthand propertyScope values
in compact adapters
0921c78d45 is described below
commit 0921c78d459cef6ac80a3980952d73cbe6d07983
Author: Philipp Zehnder <[email protected]>
AuthorDate: Thu Mar 12 13:31:26 2026 +0100
fix(#4246): Accept full and shorthand propertyScope values in compact
adapters
---
.../management/compact/SchemaMetadataEnricher.java | 24 ++++++++--------------
1 file changed, 8 insertions(+), 16 deletions(-)
diff --git
a/streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/compact/SchemaMetadataEnricher.java
b/streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/compact/SchemaMetadataEnricher.java
index 41c202651e..f3bb1c412c 100644
---
a/streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/compact/SchemaMetadataEnricher.java
+++
b/streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/compact/SchemaMetadataEnricher.java
@@ -22,7 +22,6 @@ import
org.apache.streampipes.model.connect.adapter.compact.CompactEventProperty
import org.apache.streampipes.model.schema.EventProperty;
import org.apache.streampipes.model.schema.EventPropertyPrimitive;
import org.apache.streampipes.model.schema.PropertyScope;
-import org.apache.streampipes.vocabulary.XSD;
import java.net.URI;
import java.util.Map;
@@ -68,24 +67,17 @@ public class SchemaMetadataEnricher {
}
private PropertyScope convertScope(String scope) {
- if (scope.equalsIgnoreCase("header")) {
- return PropertyScope.HEADER_PROPERTY;
- } else if (scope.equalsIgnoreCase("dimension")) {
- return PropertyScope.DIMENSION_PROPERTY;
- } else if (scope.equalsIgnoreCase("measurement")) {
+ if (scope == null || scope.isBlank()) {
return PropertyScope.MEASUREMENT_PROPERTY;
- } else {
- return PropertyScope.NONE;
}
- }
- private String convertType(String shortRuntimeType) {
- return switch (shortRuntimeType) {
- case "integer" -> XSD.INTEGER.toString();
- case "boolean" -> XSD.BOOLEAN.toString();
- case "float" -> XSD.FLOAT.toString();
- case "double" -> XSD.DOUBLE.toString();
- default -> XSD.STRING.toString();
+ return switch (scope.trim().toUpperCase()) {
+ case "HEADER", "HEADER_PROPERTY" -> PropertyScope.HEADER_PROPERTY;
+ case "DIMENSION", "DIMENSION_PROPERTY" ->
PropertyScope.DIMENSION_PROPERTY;
+ case "MEASUREMENT", "MEASUREMENT_PROPERTY" ->
PropertyScope.MEASUREMENT_PROPERTY;
+ case "NONE" -> PropertyScope.NONE;
+ default -> PropertyScope.MEASUREMENT_PROPERTY;
};
}
+
}