修复sonar规范问题

src/main/java/com/zorkdata/datamask/domain/HDFSLogQueryParam.java → src/main/java/com/zorkdata/datamask/domain/HdfsLogQueryParam.java

@@ -11,7 +11,7 @@ import java.io.Serializable;
  * @Date 2020/10/21 14:33
  */
 @Data
-public class HDFSLogQueryParam implements Serializable {
+public class HdfsLogQueryParam implements Serializable {
 
     private static final long serialVersionUID = 1L;
 
@@ -23,7 +23,7 @@ public class HDFSLogQueryParam implements Serializable {
     private Long startTime;
     private Long endTime;
 
-    public HDFSLogQueryParam(String source, String hdfsSrc, String hdfsDest, String core, String date, Long startTime,
+    public HdfsLogQueryParam(String source, String hdfsSrc, String hdfsDest, String core, String date, Long startTime,
                              Long endTime) {
         this.source = source;
         this.hdfsSrc = hdfsSrc;

src/main/java/com/zorkdata/datamask/hadoop/HadoopMask.java

@@ -5,7 +5,7 @@ import com.alibaba.fastjson.TypeReference;
 import com.zorkdata.datamask.constant.ParamConstants;
 import com.zorkdata.datamask.constant.StrConstants;
 import com.zorkdata.datamask.domain.LogData;
-import com.zorkdata.datamask.domain.HDFSLogQueryParam;
+import com.zorkdata.datamask.domain.HdfsLogQueryParam;
 import com.zorkdata.datamask.domain.TransactionLog;
 import com.zorkdata.datamask.util.DateUtils;
 import com.zorkdata.datamask.util.MaskUtil;
@@ -63,7 +63,7 @@ public class HadoopMask {
         env.setParallelism(1);
         JobConf jobConf = new JobConf();
         jobConf.set("avro.output.schema", TransactionLog.SCHEMA$.toString(true));
-        HDFSLogQueryParam hdfsLogQueryParam = ParamUtils.initHadoopConf(conf);
+        HdfsLogQueryParam hdfsLogQueryParam = ParamUtils.initHadoopConf(conf);
         ParameterTool parameterTool = ParameterTool.fromMap(conf);
         env.getConfig().setGlobalJobParameters(parameterTool);
 

src/main/java/com/zorkdata/datamask/util/MaskUtil.java

@@ -126,15 +126,15 @@ public class MaskUtil implements Serializable {
 
         Map map = new HashMap(DEFAULT_MAP_CAPACITY);
         map.put("姓名", "王海鹰");
-//        map.put("身份证号", "372925199008075158");
-//        map.put("手机号", "15000101879");
-//        map.put("电话", "021-61341606");
-//        map.put("邮箱", "wanghaiying@zork.com");
-//        map.put("住址", "上海市浦东新区碧波路690号1弄");
-//        map.put("住址2", "上海市浦东新区张江微电子港304-2室");
-//        map.put("ip地址", "192.168.70.2");
-//        map.put("mac地址", "3c-78-43-25-80-bd");
-//        map.put("message", "王海鹰,372925199008075158#15000101879");
+        map.put("身份证号", "372925199008075158");
+        map.put("手机号", "15000101879");
+        map.put("电话", "021-61341606");
+        map.put("邮箱", "wanghaiying@zork.com");
+        map.put("住址", "上海市浦东新区碧波路690号1弄");
+        map.put("住址2", "上海市浦东新区张江微电子港304-2室");
+        map.put("ip地址", "192.168.70.2");
+        map.put("mac地址", "3c-78-43-25-80-bd");
+        map.put("message", "王海鹰,372925199008075158#15000101879");
         map.put("messid", "0000011404342B32233DDCDA");
         map.put("bsflag", "0000011404342B32233DDCDA");
         map.put("normalFields", "13811110000-110101199003075517-上海市浦东新区张江微电子港-zorkdata@163.com-123456789-wanghaiying123-王海鹰-192.168.1.1-00-50-56-C0-00-08-6227002470170278192");

src/main/java/com/zorkdata/datamask/util/ParamUtils.java

@@ -2,7 +2,7 @@ package com.zorkdata.datamask.util;
 
 import com.zorkdata.datamask.constant.ParamConstants;
 import com.zorkdata.datamask.constant.RegExpConstants;
-import com.zorkdata.datamask.domain.HDFSLogQueryParam;
+import com.zorkdata.datamask.domain.HdfsLogQueryParam;
 import com.zorkdata.datamask.domain.KafkaMsgQueryParam;
 
 import java.util.HashMap;
@@ -21,7 +21,7 @@ public class ParamUtils {
      *
      * @param conf
      */
-    public static HDFSLogQueryParam initHadoopConf(Map conf) {
+    public static HdfsLogQueryParam initHadoopConf(Map conf) {
         String source = String.valueOf(conf.get(ParamConstants.SOURCE)).trim();
         String hdfsSrc = String.valueOf(conf.get(ParamConstants.HDFS_SRC)).trim();
         String hdfsDest = String.valueOf(conf.get(ParamConstants.HDFS_DEST)).trim();
@@ -29,7 +29,7 @@ public class ParamUtils {
         String date = String.valueOf(conf.get(ParamConstants.DATE)).trim();
         Long startTime = Long.parseLong(String.valueOf(conf.get(ParamConstants.START_TIME)).trim());
         Long endTime = Long.parseLong(String.valueOf(conf.get(ParamConstants.END_TIME)).trim());
-        return new HDFSLogQueryParam(source, hdfsSrc, hdfsDest, core, date, startTime, endTime);
+        return new HdfsLogQueryParam(source, hdfsSrc, hdfsDest, core, date, startTime, endTime);
     }
 
     public static KafkaMsgQueryParam initKafkaConf(Map conf) {