(iotdb) branch master updated: Fix envelope function execution error without frequency parameter (#12233)

[rong]

This is an automated email from the ASF dual-hosted git repository.

rong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new d96556cfc7e Fix envelope function execution error without frequency 
parameter (#12233)
d96556cfc7e is described below

commit d96556cfc7e1a1d4d7a75d509c8bb9b74f8ea78d
Author: Zhijia Cao <caozhi...@126.com>
AuthorDate: Mon Mar 25 22:49:13 2024 +0800

    Fix envelope function execution error without frequency parameter (#12233)
---
 .../org/apache/iotdb/library/frequency/UDFEnvelopeAnalysis.java     | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/library-udf/src/main/java/org/apache/iotdb/library/frequency/UDFEnvelopeAnalysis.java
 
b/library-udf/src/main/java/org/apache/iotdb/library/frequency/UDFEnvelopeAnalysis.java
index 6d04a108640..8180f747d76 100644
--- 
a/library-udf/src/main/java/org/apache/iotdb/library/frequency/UDFEnvelopeAnalysis.java
+++ 
b/library-udf/src/main/java/org/apache/iotdb/library/frequency/UDFEnvelopeAnalysis.java
@@ -60,7 +60,7 @@ public class UDFEnvelopeAnalysis implements UDTF {
         .validate(
             x -> (double) x > 0,
             "The param 'frequency' must > 0.",
-            validator.getParameters().getDoubleOrDefault(FREQUENCY, 0))
+            validator.getParameters().getDoubleOrDefault(FREQUENCY, 
Double.MAX_VALUE))
         .validate(
             x -> (int) x >= 1,
             "The param 'amplification' must >= 1.",
@@ -71,7 +71,7 @@ public class UDFEnvelopeAnalysis implements UDTF {
   public void beforeStart(UDFParameters parameters, UDTFConfigurations 
configurations)
       throws Exception {
     configurations.setAccessStrategy(new 
RowByRowAccessStrategy()).setOutputDataType(Type.DOUBLE);
-    frequency = parameters.getDoubleOrDefault(FREQUENCY, Double.MIN_VALUE);
+    frequency = parameters.getDoubleOrDefault(FREQUENCY, Double.MAX_VALUE);
     amplification = parameters.getIntOrDefault(AMPLIFICATION, 1);
     timestampPrecision = 
parameters.getSystemStringOrDefault(TIMESTAMP_PRECISION, MS_PRECISION);
   }
@@ -87,7 +87,7 @@ public class UDFEnvelopeAnalysis implements UDTF {
   @Override
   public void terminate(PointCollector collector) throws Exception {
     double[] envelopeValues = envelopeAnalyze(signals.toArray());
-    frequency = frequency != Double.MIN_VALUE ? frequency : 
calculateFrequency(timestamps);
+    frequency = frequency != Double.MAX_VALUE ? frequency : 
calculateFrequency(timestamps);
     int signalSize = signals.size();
     double[] frequencies = new double[signalSize / 2];
     for (int i = 0; i < signalSize / 2; i++) {