From 3ec7b28d6adf63ac7e7e1ebcf0830130b8201814 Mon Sep 17 00:00:00 2001 From: wangkuan Date: Tue, 22 Oct 2024 17:41:03 +0800 Subject: [PATCH] =?UTF-8?q?=E5=87=BD=E6=95=B0NumberMax=EF=BC=8CNumberMin?= =?UTF-8?q?=E4=BF=AE=E6=94=B9=E4=B8=BAMax=E5=92=8CMin?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ...g_dos_protection_rule_metric_kafka_to_clickhouse.yaml.j2 | 6 +++--- tsg_olap/installation/flink/groot_stream/udf.plugins | 4 ++-- ...g_dos_protection_rule_metric_kafka_to_clickhouse.yaml.j2 | 6 +++--- tsg_olap/upgrade/TSG-24.10/groot_stream/udf.plugins | 4 ++-- 4 files changed, 10 insertions(+), 10 deletions(-) diff --git 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 index 0a4a561..d3fbf24 100644 --- 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 diff --git a/tsg_olap/installation/flink/groot_stream/udf.plugins b/tsg_olap/installation/flink/groot_stream/udf.plugins index 49edca1..1913883 100644 --- 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 \ No newline at end of file +com.geedgenetworks.core.udf.udaf.Max +com.geedgenetworks.core.udf.udaf.Min \ No newline at end of file diff --git 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 index 0a4a561..d3fbf24 100644 --- 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 diff --git a/tsg_olap/upgrade/TSG-24.10/groot_stream/udf.plugins b/tsg_olap/upgrade/TSG-24.10/groot_stream/udf.plugins index 49edca1..1913883 100644 --- 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 \ No newline at end of file +com.geedgenetworks.core.udf.udaf.Max +com.geedgenetworks.core.udf.udaf.Min \ No newline at end of file