diff options
| author | yinjiangyi <[email protected]> | 2021-08-17 15:54:33 +0800 |
|---|---|---|
| committer | yinjiangyi <[email protected]> | 2021-08-17 15:54:33 +0800 |
| commit | bb3f6299caf30f46ede6b62ed292fb9cac429c82 (patch) | |
| tree | 84f346ddbe7b4cf3760d87d6cb8021076aed2e2f /src | |
| parent | b5645b72edb81f572331361f17b5ae85c63c4352 (diff) | |
修改字段名为*_default_value
Diffstat (limited to 'src')
| -rw-r--r-- | src/main/java/cn/mesalab/service/BaselineSingleThread.java | 9 | ||||
| -rw-r--r-- | 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<Integer> 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<Map<String, Object>> completSeries = SeriesUtils.complementSeries(ipDruidData); List<Integer>series = 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天（需要判断周期性） |