This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a change to branch
4032-introducing-function-transformation-for-complex-data-handling-in-connect
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from d6ae33cbf5 feat(#4032): Add unit conversion rules to adapter event
preview
add adad277c9b feat(#4032): Fix data type transformation in ui
add c51982a14e feat(#4032): Transformation script works now for pipeline
instances
add 24492be875 feat(#4032): Remove transformation rules
No new revisions were added by this update.
Summary of changes:
.../management/AdapterEventPreviewPipeline.java | 40 +-----
streampipes-connect-shared/pom.xml | 11 ++
.../shared/AdapterPipelineGeneratorBase.java | 85 ++++++++++++-
.../convert/ToOriginalSchemaConverter.java | 72 -----------
.../convert/ToTransformedSchemaConverter.java | 113 -----------------
...va => ScriptTransformationPipelineElement.java} | 35 +++---
...StatefulTransformationRuleGeneratorVisitor.java | 48 -------
...tatelessTransformationRuleGeneratorVisitor.java | 86 -------------
.../schema/AddValueTransformationRule.java | 48 -------
.../transform/schema/DeleteTransformationRule.java | 46 -------
.../transform/schema/MoveTransformationRule.java | 106 ----------------
.../transform/schema/RenameTransformationRule.java | 48 -------
.../value/AddTimestampTransformationRule.java | 39 ------
.../value/CorrectionValueTransformationRule.java | 76 -----------
.../value/DatatypeTransformationRule.java | 8 --
.../transform/value/RegexTransformationRule.java | 71 -----------
.../value/TimestampTransformationRule.java | 91 --------------
.../AdapterTransformationPipelineElementTest.java | 58 ---------
.../schema/DeleteTransformationRuleTest.java | 139 ---------------------
.../schema/MoveTransformationRuleTest.java | 97 --------------
.../schema/RenameTransformationRuleTest.java | 70 -----------
.../schema/SchemaEventTransformerTest.java | 81 ------------
.../transform/value/CorrectionValueTest.java | 138 --------------------
.../value/RegexTransformationRuleTest.java | 96 --------------
.../transform/value/ValueEventTransformerTest.java | 62 ---------
.../connect/TransformationRuleUpdateVisitor.java | 68 +---------
.../connect/adapter/AdapterPipelineGenerator.java | 2 +-
.../iiot/protocol/stream/FileReplayAdapter.java | 21 ----
.../connect/rules/ITransformationRuleVisitor.java | 24 ----
.../rules/schema/DeleteRuleDescription.java | 2 +-
.../connect/rules/schema/MoveRuleDescription.java | 2 +-
.../rules/schema/RenameRuleDescription.java | 2 +-
.../SchemaTransformationRuleDescription.java | 1 +
.../rules/value/AddTimestampRuleDescription.java | 2 +-
.../AddValueTransformationRuleDescription.java | 2 +-
...rrectionValueTransformationRuleDescription.java | 2 +-
.../value/RegexTransformationRuleDescription.java | 2 +-
.../TimestampTranfsformationRuleDescription.java | 2 +-
.../rest/impl/connect/GuessResource.java | 1 -
streampipes-service-extensions/pom.xml | 15 +++
.../StreamPipesExtensionsServiceBase.java | 14 +++
.../event-property-row.component.html | 15 ++-
.../event-property-row.component.ts | 21 ++--
43 files changed, 172 insertions(+), 1790 deletions(-)
copy
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/elements/{AdapterTransformationPipelineElement.java
=> ScriptTransformationPipelineElement.java} (52%)
delete mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/transform/schema/AddValueTransformationRule.java
delete mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/transform/schema/DeleteTransformationRule.java
delete mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/transform/schema/MoveTransformationRule.java
delete mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/transform/schema/RenameTransformationRule.java
delete mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/transform/value/AddTimestampTransformationRule.java
delete mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/transform/value/CorrectionValueTransformationRule.java
delete mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/transform/value/RegexTransformationRule.java
delete mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/transform/value/TimestampTransformationRule.java
delete mode 100644
streampipes-connect-shared/src/test/java/org/apache/streampipes/connect/shared/preprocessing/elements/AdapterTransformationPipelineElementTest.java
delete mode 100644
streampipes-connect-shared/src/test/java/org/apache/streampipes/connect/shared/preprocessing/transform/schema/DeleteTransformationRuleTest.java
delete mode 100644
streampipes-connect-shared/src/test/java/org/apache/streampipes/connect/shared/preprocessing/transform/schema/MoveTransformationRuleTest.java
delete mode 100644
streampipes-connect-shared/src/test/java/org/apache/streampipes/connect/shared/preprocessing/transform/schema/RenameTransformationRuleTest.java
delete mode 100644
streampipes-connect-shared/src/test/java/org/apache/streampipes/connect/shared/preprocessing/transform/schema/SchemaEventTransformerTest.java
delete mode 100644
streampipes-connect-shared/src/test/java/org/apache/streampipes/connect/shared/preprocessing/transform/value/CorrectionValueTest.java
delete mode 100644
streampipes-connect-shared/src/test/java/org/apache/streampipes/connect/shared/preprocessing/transform/value/RegexTransformationRuleTest.java
delete mode 100644
streampipes-connect-shared/src/test/java/org/apache/streampipes/connect/shared/preprocessing/transform/value/ValueEventTransformerTest.java
