修改类型

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

@@ -62,7 +62,7 @@ object makedata_ad_33_addFeatureToHive_20250708 {
 
   }
 
-  def func(record: Record, schema: TableSchema): (String, Map[String, String]) = {
+  def func(record: Record, schema: TableSchema): (Any, Map[String, String]) = {
     // 1. 获取所有列信息
     val columns: Array[Column] = schema.getColumns.toArray(Array.empty[Column])
 
@@ -80,7 +80,7 @@ object makedata_ad_33_addFeatureToHive_20250708 {
     }
 
     // 4. 提取 mid 的值，保留 null（不转换为空字符串）
-    val mid = record.get(midIndex).asInstanceOf[AnyRef].toString // 直接转换，null 会转为 "null" 字符串
+    val mid = record.get(midIndex)
 
     // 5. 将 Record 转换为 Map[String, String]（跳过 mid 字段）
     val recordMap = columns.zipWithIndex