You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by wi...@apache.org on 2020/02/12 09:54:13 UTC
[incubator-streampipes-extensions] branch dev updated: add
processors-enricher-jvm to processors-jvm-all
This is an automated email from the ASF dual-hosted git repository.
wiener pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git
The following commit(s) were added to refs/heads/dev by this push:
new 197507a add processors-enricher-jvm to processors-jvm-all
197507a is described below
commit 197507a19b2f12492f6a9f30ddc17105d1ea45c9
Author: Patrick Wiener <wi...@fzi.de>
AuthorDate: Wed Feb 12 10:54:01 2020 +0100
add processors-enricher-jvm to processors-jvm-all
---
streampipes-pipeline-elements-all-jvm/pom.xml | 6 ++++++
.../java/org/apache/streampipes/pe/jvm/AllPipelineElementsInit.java | 4 +++-
2 files changed, 9 insertions(+), 1 deletion(-)
diff --git a/streampipes-pipeline-elements-all-jvm/pom.xml b/streampipes-pipeline-elements-all-jvm/pom.xml
index 307eb24..151a2bb 100644
--- a/streampipes-pipeline-elements-all-jvm/pom.xml
+++ b/streampipes-pipeline-elements-all-jvm/pom.xml
@@ -76,6 +76,12 @@
<version>0.65.1-SNAPSHOT</version>
<classifier>embed</classifier>
</dependency>
+ <dependency>
+ <groupId>org.apache.streampipes</groupId>
+ <artifactId>streampipes-processors-enricher-jvm</artifactId>
+ <version>0.65.1-SNAPSHOT</version>
+ <classifier>embed</classifier>
+ </dependency>
</dependencies>
<build>
diff --git a/streampipes-pipeline-elements-all-jvm/src/main/java/org/apache/streampipes/pe/jvm/AllPipelineElementsInit.java b/streampipes-pipeline-elements-all-jvm/src/main/java/org/apache/streampipes/pe/jvm/AllPipelineElementsInit.java
index 3f7c20f..90587ff 100644
--- a/streampipes-pipeline-elements-all-jvm/src/main/java/org/apache/streampipes/pe/jvm/AllPipelineElementsInit.java
+++ b/streampipes-pipeline-elements-all-jvm/src/main/java/org/apache/streampipes/pe/jvm/AllPipelineElementsInit.java
@@ -26,6 +26,7 @@ import org.apache.streampipes.dataformat.smile.SmileDataFormatFactory;
import org.apache.streampipes.messaging.jms.SpJmsProtocolFactory;
import org.apache.streampipes.messaging.kafka.SpKafkaProtocolFactory;
import org.apache.streampipes.pe.jvm.config.AllPipelineElementsConfig;
+import org.apache.streampipes.processors.enricher.jvm.processor.sizemeasure.SizeMeasureController;
import org.apache.streampipes.processors.filters.jvm.processor.compose.ComposeController;
import org.apache.streampipes.processors.filters.jvm.processor.enrich.MergeByEnrichController;
import org.apache.streampipes.processors.filters.jvm.processor.merge.MergeByTimeController;
@@ -115,7 +116,8 @@ public class AllPipelineElementsInit extends StandaloneModelSubmitter {
.add(new EmailController())
.add(new OneSignalController())
.add(new SlackNotificationController())
- .add(new NumericalTextFilterController());
+ .add(new NumericalTextFilterController())
+ .add(new SizeMeasureController());
DeclarersSingleton.getInstance().registerDataFormats(new JsonDataFormatFactory(),