This is an automated email from the ASF dual-hosted git repository.
riemer 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 9e41c7f98c refactor(#4024): Rename event schema components
add a66999d227 Add initial version of script engines
No new revisions were added by this update.
Summary of changes:
pom.xml | 3 +
streampipes-connect-transformer-api/pom.xml | 20 +++++
.../connect/transformer/api/ScriptTransformer.java | 21 +++--
.../transformer/api/TransformationEngine.java | 27 +++----
.../transformer/api/TransformationEngines.java | 19 +++--
.../api/exception/ScriptCompilationException.java | 9 +--
.../api/exception/ScriptExecutionException.java | 10 +--
.../utils/TransformationEngineConversionUtils.java | 39 ++++------
streampipes-connect-transformer-groovy/pom.xml | 31 ++++++++
.../transformer/groovy/GroovyScriptEngine.java | 69 ++++++++++++++++
streampipes-connect-transformer-js/pom.xml | 36 +++++++++
.../transformer/js/GraalJsScriptEngine.java | 91 ++++++++++++++++++++++
.../transformer/js/PolyglotResultConverter.java | 72 +++++++++++++++++
.../connect/SchemaTransformationScriptConfig.java | 7 +-
.../model/connect/adapter/AdapterDescription.java | 11 +++
streampipes-rest/pom.xml | 5 ++
.../rest/impl/connect/GuessResource.java | 23 +++++-
.../minimal/StreamPipesCoreApplicationMinimal.java | 8 +-
streampipes-service-core/pom.xml | 10 +++
.../service/core/StreamPipesCoreApplication.java | 21 ++++-
20 files changed, 461 insertions(+), 71 deletions(-)
create mode 100644 streampipes-connect-transformer-api/pom.xml
copy
streampipes-data-explorer-api/src/main/java/org/apache/streampipes/dataexplorer/api/IDataLakeMeasurementCounter.java
=>
streampipes-connect-transformer-api/src/main/java/org/apache/streampipes/connect/transformer/api/ScriptTransformer.java
(55%)
copy
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/LoadBalancer.java
=>
streampipes-connect-transformer-api/src/main/java/org/apache/streampipes/connect/transformer/api/TransformationEngine.java
(54%)
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/storage/RunningPipelineElementStorage.java
=>
streampipes-connect-transformer-api/src/main/java/org/apache/streampipes/connect/transformer/api/TransformationEngines.java
(61%)
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/parser/PrimitiveTypeParser.java
=>
streampipes-connect-transformer-api/src/main/java/org/apache/streampipes/connect/transformer/api/exception/ScriptCompilationException.java
(78%)
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/exceptions/connect/AdapterException.java
=>
streampipes-connect-transformer-api/src/main/java/org/apache/streampipes/connect/transformer/api/exception/ScriptExecutionException.java
(77%)
copy
streampipes-model/src/main/java/org/apache/streampipes/model/util/SchemaUtils.java
=>
streampipes-connect-transformer-api/src/main/java/org/apache/streampipes/connect/transformer/api/utils/TransformationEngineConversionUtils.java
(51%)
create mode 100644 streampipes-connect-transformer-groovy/pom.xml
create mode 100644
streampipes-connect-transformer-groovy/src/main/java/org/apache/streampipes/connect/transformer/groovy/GroovyScriptEngine.java
create mode 100644 streampipes-connect-transformer-js/pom.xml
create mode 100644
streampipes-connect-transformer-js/src/main/java/org/apache/streampipes/connect/transformer/js/GraalJsScriptEngine.java
create mode 100644
streampipes-connect-transformer-js/src/main/java/org/apache/streampipes/connect/transformer/js/PolyglotResultConverter.java
copy
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/live/ISubscription.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/SchemaTransformationScriptConfig.java
(82%)
