feat: v8索引工具类

src/main/scala/com/winhc/bigdata/spark/udf/BaseFunc.scala

@@ -21,7 +21,6 @@ trait BaseFunc {
   private val pattern = "[^\\u4e00-\\u9fa5a-zA-Z \\(\\)（）.]+".r
 
 
-
   /* def to_epoch_millis_timestamp(): Unit = {
      spark.udf.register("to_epoch_millis_timestamp", (et: String) => {
        DateUtils.toUnixTimestamp(date = et) * 1000 + 28800000L

src/main/scala/com/winhc/bigdata/spark/utils/CompanyIndexUtils.scala

@@ -1,5 +1,6 @@
 package com.winhc.bigdata.spark.utils
 
+import com.winhc.bigdata.spark.implicits.CaseClass2JsonHelper._
 import com.winhc.bigdata.spark.utils.BaseUtil.cleanup
 import org.apache.commons.lang3.StringUtils
 
@@ -10,18 +11,22 @@ import org.apache.commons.lang3.StringUtils
 
 case class human(id: String, name: String)
 
+case class holder(id: String, `type`: String, name: String)
+
 case class CompanyName(show: String, value: String)
 
 
 object CompanyIndexUtils {
   def getHuman(id: String, name: String): human = human(id, name)
 
+  def get_holder(id: String, `type`: String, name: String): String = holder(id, `type`, name).toJson()
+
 
   def getCompanyName(name: String): CompanyName = {
     if (StringUtils.isEmpty(name)) null
     else {
       val value = cleanup(name)
-      CompanyName(name.replaceAll("\t;","").trim, value)
+      CompanyName(name.replaceAll("\t;", "").trim, value)
     }
   }