From bb3f6299caf30f46ede6b62ed292fb9cac429c82 Mon Sep 17 00:00:00 2001 From: yinjiangyi Date: Tue, 17 Aug 2021 15:54:33 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=AD=97=E6=AE=B5=E5=90=8D?= =?UTF-8?q?=E4=B8=BA*=5Fdefault=5Fvalue?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/cn/mesalab/service/BaselineSingleThread.java | 9 ++++++--- src/main/resources/application.properties | 2 +- 2 files changed, 7 insertions(+), 4 deletions(-) diff --git a/src/main/java/cn/mesalab/service/BaselineSingleThread.java b/src/main/java/cn/mesalab/service/BaselineSingleThread.java index 26a0983..329bcde 100644 --- a/src/main/java/cn/mesalab/service/BaselineSingleThread.java +++ b/src/main/java/cn/mesalab/service/BaselineSingleThread.java @@ -143,21 +143,24 @@ public class BaselineSingleThread extends Thread { if (ipDruidData.size()==0){ return null; } - List originSeries = ipDruidData.stream().map(i -> Integer.valueOf(i.get(ApplicationConfig.BASELINE_METRIC_TYPE).toString())).collect(Collectors.toList()); if(Collections.max(originSeries)==0){ return null; } - int baselineGenerationType = 0; + int ipPercentile = SeriesUtils.percentile(originSeries, ApplicationConfig.BASELINE_RATIONAL_PERCENTILE); + if(ipPercentile == 0){ + LOG.error(ip + "-" + "IP zero-replace value is 0 !"); + } + + int baselineGenerationType; int[] baselineArr = new int[baselinePointNum]; // 时间序列缺失值补0 List> completSeries = SeriesUtils.complementSeries(ipDruidData); Listseries = completSeries.stream().map( i -> Integer.valueOf(i.get(ApplicationConfig.BASELINE_METRIC_TYPE).toString())).collect(Collectors.toList()); - int ipPercentile = SeriesUtils.percentile(originSeries, ApplicationConfig.BASELINE_RATIONAL_PERCENTILE); // 判断ip出现频率 float ipFrequency = ipDruidData.size() / (float) completSeries.size(); diff --git a/src/main/resources/application.properties b/src/main/resources/application.properties index 24b01c6..cb915b5 100644 --- a/src/main/resources/application.properties +++ b/src/main/resources/application.properties @@ -36,7 +36,7 @@ baseline.metric.type=session_rate #Hbase字段映射 hbase.baseline.generation.type.suffix=baseline_type -hbase.baseline.zero.replace.value.suffix=zero_replace_value +hbase.baseline.zero.replace.value.suffix=default_value #数据情况 #读取历史N天数据，最小值为3天（需要判断周期性）