This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a commit to branch 3179-new-processor-sensorlimitalert
in repository https://gitbox.apache.org/repos/asf/streampipes.git
The following commit(s) were added to
refs/heads/3179-new-processor-sensorlimitalert by this push:
new 419920102b feat(#3179): Add processor suffix to
QualityControlLimitsEnrichmentProcessor
419920102b is described below
commit 419920102bcdcce698dee5b29df4e6cd9a3afa97
Author: Philipp Zehnder <[email protected]>
AuthorDate: Fri Aug 23 10:56:49 2024 +0200
feat(#3179): Add processor suffix to QualityControlLimitsEnrichmentProcessor
---
.../enricher/jvm/EnricherExtensionModuleExport.java | 4 ++--
...va => QualityControlLimitsEnrichmentProcessor.java} | 2 +-
.../QualityControlLimitsEnrichmentTest.java | 18 +++++++++---------
3 files changed, 12 insertions(+), 12 deletions(-)
diff --git
a/streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/EnricherExtensionModuleExport.java
b/streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/EnricherExtensionModuleExport.java
index 1c8fea88fb..7685b986aa 100644
---
a/streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/EnricherExtensionModuleExport.java
+++
b/streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/EnricherExtensionModuleExport.java
@@ -23,7 +23,7 @@ import
org.apache.streampipes.extensions.api.declarer.IExtensionModuleExport;
import org.apache.streampipes.extensions.api.migration.IModelMigrator;
import org.apache.streampipes.extensions.api.pe.IStreamPipesPipelineElement;
import
org.apache.streampipes.processors.enricher.jvm.processor.jseval.JSEvalProcessor;
-import
org.apache.streampipes.processors.enricher.jvm.processor.limitsenrichment.QualityControlLimitsEnrichment;
+import
org.apache.streampipes.processors.enricher.jvm.processor.limitsenrichment.QualityControlLimitsEnrichmentProcessor;
import
org.apache.streampipes.processors.enricher.jvm.processor.math.MathOpProcessor;
import
org.apache.streampipes.processors.enricher.jvm.processor.math.staticmathop.StaticMathOpProcessor;
import
org.apache.streampipes.processors.enricher.jvm.processor.trigonometry.TrigonometryProcessor;
@@ -42,7 +42,7 @@ public class EnricherExtensionModuleExport implements
IExtensionModuleExport {
public List<IStreamPipesPipelineElement<?>> pipelineElements() {
return List.of(
new JSEvalProcessor(),
- new QualityControlLimitsEnrichment(),
+ new QualityControlLimitsEnrichmentProcessor(),
new MathOpProcessor(),
new StaticMathOpProcessor(),
new TrigonometryProcessor(),
diff --git
a/streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/limitsenrichment/QualityControlLimitsEnrichment.java
b/streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/limitsenrichment/QualityControlLimitsEnrichmentProcessor.java
similarity index 98%
rename from
streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/limitsenrichment/QualityControlLimitsEnrichment.java
rename to
streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/limitsenrichment/QualityControlLimitsEnrichmentProcessor.java
index 0262487428..f1601c59a7 100644
---
a/streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/limitsenrichment/QualityControlLimitsEnrichment.java
+++
b/streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/limitsenrichment/QualityControlLimitsEnrichmentProcessor.java
@@ -36,7 +36,7 @@ import org.apache.streampipes.vocabulary.SO;
import org.apache.streampipes.wrapper.params.compat.ProcessorParams;
import org.apache.streampipes.wrapper.standalone.StreamPipesDataProcessor;
-public class QualityControlLimitsEnrichment extends StreamPipesDataProcessor {
+public class QualityControlLimitsEnrichmentProcessor extends
StreamPipesDataProcessor {
protected static final String UPPER_CONTROL_LIMIT_LABEL =
"upperControlLimitInput";
diff --git
a/streampipes-extensions/streampipes-processors-enricher-jvm/src/test/java/org/apache/streampipes/processors/enricher/jvm/processor/limitsenrichment/QualityControlLimitsEnrichmentTest.java
b/streampipes-extensions/streampipes-processors-enricher-jvm/src/test/java/org/apache/streampipes/processors/enricher/jvm/processor/limitsenrichment/QualityControlLimitsEnrichmentTest.java
index d0ae20828a..7e8ffb23a9 100644
---
a/streampipes-extensions/streampipes-processors-enricher-jvm/src/test/java/org/apache/streampipes/processors/enricher/jvm/processor/limitsenrichment/QualityControlLimitsEnrichmentTest.java
+++
b/streampipes-extensions/streampipes-processors-enricher-jvm/src/test/java/org/apache/streampipes/processors/enricher/jvm/processor/limitsenrichment/QualityControlLimitsEnrichmentTest.java
@@ -32,7 +32,7 @@ class QualityControlLimitsEnrichmentTest {
@Test
void onEvent() {
- var processor = new QualityControlLimitsEnrichment();
+ var processor = new QualityControlLimitsEnrichmentProcessor();
List<Map<String, Object>> inputEvents = List.of(Map.of(
"temperature", 10.1
@@ -40,18 +40,18 @@ class QualityControlLimitsEnrichmentTest {
List<Map<String, Object>> outputEvents = List.of(Map.of(
"temperature", 10.1,
- QualityControlLimitsEnrichment.UPPER_CONTROL_LIMIT, 80.0,
- QualityControlLimitsEnrichment.UPPER_WARNING_LIMIT, 70.0,
- QualityControlLimitsEnrichment.LOWER_CONTROL_LIMIT, 30.0,
- QualityControlLimitsEnrichment.LOWER_WARNING_LIMIT, 20.0
+ QualityControlLimitsEnrichmentProcessor.UPPER_CONTROL_LIMIT, 80.0,
+ QualityControlLimitsEnrichmentProcessor.UPPER_WARNING_LIMIT, 70.0,
+ QualityControlLimitsEnrichmentProcessor.LOWER_CONTROL_LIMIT, 30.0,
+ QualityControlLimitsEnrichmentProcessor.LOWER_WARNING_LIMIT, 20.0
));
var configuration = TestConfiguration
.builder()
- .config(QualityControlLimitsEnrichment.UPPER_CONTROL_LIMIT_LABEL, 80.0)
- .config(QualityControlLimitsEnrichment.UPPER_WARNING_LIMIT_LABEL, 70.0)
- .config(QualityControlLimitsEnrichment.LOWER_CONTROL_LIMIT_LABEL, 30.0)
- .config(QualityControlLimitsEnrichment.LOWER_WARNING_LIMIT_LABEL, 20.0)
+
.config(QualityControlLimitsEnrichmentProcessor.UPPER_CONTROL_LIMIT_LABEL, 80.0)
+
.config(QualityControlLimitsEnrichmentProcessor.UPPER_WARNING_LIMIT_LABEL, 70.0)
+
.config(QualityControlLimitsEnrichmentProcessor.LOWER_CONTROL_LIMIT_LABEL, 30.0)
+
.config(QualityControlLimitsEnrichmentProcessor.LOWER_WARNING_LIMIT_LABEL, 20.0)
.prefixStrategy(PrefixStrategy.SAME_PREFIX)
.build();
