[incubator-streampipes-extensions] 01/01: STREAMPIPES-72: Add processor to filter for numerical and text values

[wi...@apache.org]

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

commit 69d6cb7e85acdacc4d1f2e3922fd953163dfefbc
Merge: 9078591 f5d5926
Author: Patrick Wiener <wi...@fzi.de>
AuthorDate: Fri Feb 7 15:15:33 2020 +0100

    STREAMPIPES-72: Add processor to filter for numerical and text values

 .../connect/adapters/netio/NetioMQTTAdapter.java          |  1 -
 .../streampipes/connect/utils/MqttConnectUtils.java       | 15 ---------------
 .../streampipes/pe/jvm/AllPipelineElementsInit.java       |  4 ++++
 3 files changed, 4 insertions(+), 16 deletions(-)

diff --cc streampipes-pipeline-elements-all-jvm/src/main/java/org/apache/streampipes/pe/jvm/AllPipelineElementsInit.java
index 3841105,65ad64a..bc672b2
--- 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,8 -27,9 +27,10 @@@ import org.apache.streampipes.messaging
  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.numericaltextfilter.NumericalTextFilterController;
  import org.apache.streampipes.processors.filters.jvm.processor.projection.ProjectionController;
  import org.apache.streampipes.processors.filters.jvm.processor.textfilter.TextFilterController;
  import org.apache.streampipes.processors.filters.jvm.processor.threshold.ThresholdDetectionController;