许家凯 4 lat temu
rodzic
commit
30d0358c11

+ 0 - 9
src/main/scala/com/winhc/bigdata/spark/utils/ChangeExtractUtils.scala

@@ -12,15 +12,6 @@ object ChangeExtractUtils {
   def get_ip_tags(type_val: String, name: String, date: String, no: String): String = {
     s"""{"type":${getValueOrNull(type_val)},"name":${getValueOrNull(name)},"date":${getValueOrNull(date)},"no":${getValueOrNull(no)}}""".trim
   }
-  //获取指定字段集的标签Json
-  def getTags(fldMap: Map[String, String], type_val: String, fields: Array[String]): String = {
-    var json:StringBuilder = new StringBuilder(s"""{"type":${getValueOrNull(type_val)},""")
-    fields.map {item=>
-      json.append(s"${getValueOrNull(item)}")
-      json.append(s":${getValueOrNull(fldMap(item))},")
-    }
-    json.deleteCharAt(json.lastIndexOf(",")).append("}").toString.trim
-  }
 
   //获取指定字段集的标签Json
   def getTags(fldMap: Map[String, String], type_val: String, fields: Array[String]): String = {