转成相同的key

src/main/scala/com/aliyun/odps/spark/examples/makedata_ad/v20240718/diff_data_20250319.scala

@@ -144,13 +144,14 @@ object diff_data_20250319 {
     for (i <- 0 until columns.size()) {
       val column = columns.get(i)
       val name = column.getName
+      var key = name.replace("_x_", "*").replace("_view", "(view)")
       val value = record.get(name)
       value match {
         case byteArray: Array[Byte] =>
           try {
             // 将字节数组转换为字符串，使用 UTF-8 编码
             val str = new String(byteArray, "UTF-8")
-            featureMap.put(name, str)
+            featureMap.put(key, str)
           } catch {
             case e: Exception =>
               println(s"转换过程中出现错误: ${e.getMessage}")
@@ -158,13 +159,9 @@ object diff_data_20250319 {
         case num: java.lang.Number =>
           // 数字类型转换为字符串
           val str = num.toString
-          featureMap.put(name, str)
-        case num: java.lang.Number =>
-          // 数字类型转换为字符串
-          val str = num.toString
-          featureMap.put(name, str)
+          featureMap.put(key, str)
         case _ =>
-          featureMap.put(name, record.get(name))
+          featureMap.put(key, record.get(name))
       }
     }
     featureMap