修复重复写入generateType问题

This commit is contained in:
yinjiangyi
2021-08-25 10:06:03 +08:00
parent eb6e7f3e16
commit b318da0db1

View File

@@ -101,8 +101,6 @@ public class BaselineSingleThread extends Thread {
int zeroReplaceValue = tuple._3; int zeroReplaceValue = tuple._3;
if ((ipBaseline!= null ) && (ip.length()>0)){ if ((ipBaseline!= null ) && (ip.length()>0)){
hbaseUtils.cachedInPut(putList, ip, ipBaseline, attackType, ApplicationConfig.BASELINE_METRIC_TYPE); hbaseUtils.cachedInPut(putList, ip, ipBaseline, attackType, ApplicationConfig.BASELINE_METRIC_TYPE);
hbaseUtils.cachedInPut(putList, ip, generateType, attackType,
ApplicationConfig.BASELINE_METRIC_TYPE + "_" + ApplicationConfig.HBASE_BASELINE_GENERATION_TYPE_SUFFIX);
hbaseUtils.cachedInPut(putList, ip, generateType, attackType, hbaseUtils.cachedInPut(putList, ip, generateType, attackType,
ApplicationConfig.BASELINE_METRIC_TYPE + "_" + ApplicationConfig.HBASE_BASELINE_GENERATION_TYPE_SUFFIX); ApplicationConfig.BASELINE_METRIC_TYPE + "_" + ApplicationConfig.HBASE_BASELINE_GENERATION_TYPE_SUFFIX);
hbaseUtils.cachedInPut(putList, ip, zeroReplaceValue, attackType, hbaseUtils.cachedInPut(putList, ip, zeroReplaceValue, attackType,