函数NumberMax，NumberMin修改为Max和Min

2024-10-22 17:41:03 +08:00
parent 7daea6cb26
commit 3ec7b28d6a
4 changed files with 10 additions and 10 deletions
--- a/tsg_olap/installation/flink/groot_stream/templates/agg_dos_protection_rule_metric_kafka_to_clickhouse.yaml.j2
+++ b/tsg_olap/installation/flink/groot_stream/templates/agg_dos_protection_rule_metric_kafka_to_clickhouse.yaml.j2
@@ -52,12 +52,12 @@ processing_pipelines:
        lookup_fields: [ client_country ]
      - function: FIRST_VALUE
        lookup_fields: [ server_country ]
-      - function: NUMBER_MIN
+      - function: MIN
        lookup_fields: [ timestamp_ms ]
        output_fields: [ start_timestamp_ms ]
-      - function: NUMBER_MIN
+      - function: MIN
        lookup_fields: [ recv_time ]
-      - function: NUMBER_MAX
+      - function: MAX
        lookup_fields: [ timestamp_ms ]
        output_fields: [ end_timestamp_ms ]
      - function: FIRST_VALUE
--- a/tsg_olap/installation/flink/groot_stream/udf.plugins
+++ b/tsg_olap/installation/flink/groot_stream/udf.plugins
@@ -33,5 +33,5 @@ com.geedgenetworks.core.udf.udtf.PathUnroll
 com.geedgenetworks.core.udf.uuid.Uuid
 com.geedgenetworks.core.udf.uuid.UuidV5
 com.geedgenetworks.core.udf.uuid.UuidV7
-com.geedgenetworks.core.udf.udaf.NumberMax
-com.geedgenetworks.core.udf.udaf.NumberMin
+com.geedgenetworks.core.udf.udaf.Max
+com.geedgenetworks.core.udf.udaf.Min
--- a/tsg_olap/upgrade/TSG-24.10/groot_stream/templates/agg_dos_protection_rule_metric_kafka_to_clickhouse.yaml.j2
+++ b/tsg_olap/upgrade/TSG-24.10/groot_stream/templates/agg_dos_protection_rule_metric_kafka_to_clickhouse.yaml.j2
@@ -52,12 +52,12 @@ processing_pipelines:
        lookup_fields: [ client_country ]
      - function: FIRST_VALUE
        lookup_fields: [ server_country ]
-      - function: NUMBER_MIN
+      - function: MIN
        lookup_fields: [ timestamp_ms ]
        output_fields: [ start_timestamp_ms ]
-      - function: NUMBER_MIN
+      - function: MIN
        lookup_fields: [ recv_time ]
-      - function: NUMBER_MAX
+      - function: MAX
        lookup_fields: [ timestamp_ms ]
        output_fields: [ end_timestamp_ms ]
      - function: FIRST_VALUE
--- a/tsg_olap/upgrade/TSG-24.10/groot_stream/udf.plugins
+++ b/tsg_olap/upgrade/TSG-24.10/groot_stream/udf.plugins
@@ -33,5 +33,5 @@ com.geedgenetworks.core.udf.udtf.PathUnroll
 com.geedgenetworks.core.udf.uuid.Uuid
 com.geedgenetworks.core.udf.uuid.UuidV5
 com.geedgenetworks.core.udf.uuid.UuidV7
-com.geedgenetworks.core.udf.udaf.NumberMax
-com.geedgenetworks.core.udf.udaf.NumberMin
+com.geedgenetworks.core.udf.udaf.Max
+com.geedgenetworks.core.udf.udaf.Min