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 a6c0d1f [Streampipes-449] Update Processing Element API in module
streampipes-processors-filters-jvm
a6c0d1f is described below
commit a6c0d1f564f71061988e85eb216e89f6194e4b50
Author: Philipp Zehnder <[email protected]>
AuthorDate: Mon Oct 25 06:56:17 2021 +0200
[Streampipes-449] Update Processing Element API in module
streampipes-processors-filters-jvm
---
.../org/apache/streampipes/processors/filters/jvm/FiltersJvmInit.java | 4 ++--
.../{NumericalFilterController.java => NumericalFilterProcessor.java} | 2 +-
2 files changed, 3 insertions(+), 3 deletions(-)
diff --git
a/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/FiltersJvmInit.java
b/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/FiltersJvmInit.java
index fc8ba23..f068f78 100644
---
a/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/FiltersJvmInit.java
+++
b/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/FiltersJvmInit.java
@@ -33,7 +33,7 @@ import
org.apache.streampipes.processors.filters.jvm.processor.compose.ComposeCo
import
org.apache.streampipes.processors.filters.jvm.processor.enrich.MergeByEnrichController;
import
org.apache.streampipes.processors.filters.jvm.processor.limit.RateLimitController;
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.numericalfilter.NumericalFilterProcessor;
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.schema.MergeBySchemaProcessor;
@@ -55,7 +55,7 @@ public class FiltersJvmInit extends StandaloneModelSubmitter {
.registerPipelineElements(
new BooleanFilterProcessor(),
new TextFilterController(),
- new NumericalFilterController(),
+ new NumericalFilterProcessor(),
new ThresholdDetectionController(),
new ProjectionController(),
new MergeByEnrichController(),
diff --git
a/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/numericalfilter/NumericalFilterController.java
b/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/numericalfilter/NumericalFilterProcessor.java
similarity index 98%
rename from
streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/numericalfilter/NumericalFilterController.java
rename to
streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/numericalfilter/NumericalFilterProcessor.java
index 6775275..d55b1eb 100644
---
a/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/numericalfilter/NumericalFilterController.java
+++
b/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/numericalfilter/NumericalFilterProcessor.java
@@ -36,7 +36,7 @@ import
org.apache.streampipes.wrapper.routing.SpOutputCollector;
import org.apache.streampipes.wrapper.standalone.ProcessorParams;
import org.apache.streampipes.wrapper.standalone.StreamPipesDataProcessor;
-public class NumericalFilterController extends StreamPipesDataProcessor {
+public class NumericalFilterProcessor extends StreamPipesDataProcessor {
private static final String NUMBER_MAPPING = "number-mapping";
private static final String VALUE = "value";
