Browse Source

增加hive表字段校验

xueyiming 4 days ago
parent
commit
69923cf627

+ 3 - 1
src/main/scala/com/aliyun/odps/spark/examples/makedata_ad/v20240718/test.scala

@@ -62,7 +62,7 @@ object test {
       "user_skuid_view_3d", "user_skuid_view_7d", "user_skuid_view_30d",
       "user_skuid_click_3d", "user_skuid_click_7d", "user_skuid_click_30d",
       "user_skuid_conver_3d", "user_skuid_conver_7d", "user_skuid_conver_30d",
-      "is_weekday", "day_of_the_week")
+      "is_weekday", "day_of_the_week", "user_conver_ad_class")
 
 
     // 2 读取odps表信息
@@ -87,5 +87,7 @@ object test {
     if (invalidFields.nonEmpty) {
       throw new IllegalArgumentException(s"发现未知字段: ${invalidFields.mkString(", ")}")
     }
+
+    println("success")
   }
 }