gfwleak/galaxy-tsg-olap-generate-baseline
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改字段名为*_default_value

Browse Source
This commit is contained in:
yinjiangyi
2021-08-17 15:54:33 +08:00
parent b5645b72ed
commit bb3f6299ca
2 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/main/java/cn/mesalab/service/BaselineSingleThread.java
View File

@@ -143,21 +143,24 @@ public class BaselineSingleThread extends Thread {
if (ipDruidData.size()==0){ if (ipDruidData.size()==0){
return null; return null;
} }
List<Integer> originSeries = ipDruidData.stream().map(i -> List<Integer> originSeries = ipDruidData.stream().map(i ->
Integer.valueOf(i.get(ApplicationConfig.BASELINE_METRIC_TYPE).toString())).collect(Collectors.toList()); Integer.valueOf(i.get(ApplicationConfig.BASELINE_METRIC_TYPE).toString())).collect(Collectors.toList());
if(Collections.max(originSeries)==0){ if(Collections.max(originSeries)==0){
return null; 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]; int[] baselineArr = new int[baselinePointNum];
// 时间序列缺失值补0 // 时间序列缺失值补0
List<Map<String, Object>> completSeries = SeriesUtils.complementSeries(ipDruidData); List<Map<String, Object>> completSeries = SeriesUtils.complementSeries(ipDruidData);
List<Integer>series = completSeries.stream().map( List<Integer>series = completSeries.stream().map(
i -> Integer.valueOf(i.get(ApplicationConfig.BASELINE_METRIC_TYPE).toString())).collect(Collectors.toList()); i -> Integer.valueOf(i.get(ApplicationConfig.BASELINE_METRIC_TYPE).toString())).collect(Collectors.toList());
int ipPercentile = SeriesUtils.percentile(originSeries, ApplicationConfig.BASELINE_RATIONAL_PERCENTILE);
// 判断ip出现频率 // 判断ip出现频率
float ipFrequency = ipDruidData.size() / (float) completSeries.size(); float ipFrequency = ipDruidData.size() / (float) completSeries.size();

2
src/main/resources/application.properties
View File

@@ -36,7 +36,7 @@ baseline.metric.type=session_rate
#Hbase字段映射 #Hbase字段映射
hbase.baseline.generation.type.suffix=baseline_type 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天（需要判断周期性） #读取历史N天数据，最小值为3天（需要判断周期性）