You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ze...@apache.org on 2020/02/06 11:10:18 UTC
[incubator-streampipes-extensions] branch dev updated: Add merg
processors to all jvm
This is an automated email from the ASF dual-hosted git repository.
zehnder 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 f5d5926 Add merg processors to all jvm
f5d5926 is described below
commit f5d5926e647d023bdb523434f14a48707a762b70
Author: Philipp Zehnder <ze...@fzi.de>
AuthorDate: Thu Feb 6 12:09:55 2020 +0100
Add merg processors to all jvm
---
.../java/org/apache/streampipes/pe/jvm/AllPipelineElementsInit.java | 4 ++++
1 file changed, 4 insertions(+)
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 6321b29..65ad64a 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
@@ -27,6 +27,8 @@ 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.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;
import org.apache.streampipes.processors.filters.jvm.processor.numericalfilter.NumericalFilterController;
import org.apache.streampipes.processors.filters.jvm.processor.projection.ProjectionController;
import org.apache.streampipes.processors.filters.jvm.processor.textfilter.TextFilterController;
@@ -76,6 +78,8 @@ public class AllPipelineElementsInit extends StandaloneModelSubmitter {
.add(new TextFilterController())
.add(new ProjectionController())
.add(new ComposeController())
+ .add(new MergeByEnrichController())
+ .add(new MergeByTimeController())
.add(new TrendController())
.add(new StreamStopController())
.add(new CountArrayController())