Forráskód Böngészése

修改jk列获取

xueyiming 8 órája
szülő
commit
0ef28d8073

+ 16 - 16
src/main/scala/com/aliyun/odps/spark/examples/makedata_ad/v20240718/makedata_ad_33_bucketDataFromOriginToHive_20260810.scala

@@ -170,22 +170,22 @@ object makedata_ad_33_bucketDataFromOriginToHive_20260810 {
               val b7: JSONObject = getJsonFromMeta(mateFeature, "alg_cid_feature_hour_action")
               val b8: JSONObject = getJsonFromMeta(mateFeature, "alg_cid_feature_brand_action")
               val b9: JSONObject = getJsonFromMeta(mateFeature, "alg_cid_feature_weChatVersion_action")
-              // j/k 已并入 metafeature
-              val j1: JSONObject = getJsonFromMeta(mateFeature, "j1_feature")
-              val j2: JSONObject = getJsonFromMeta(mateFeature, "j2_feature")
-              val j3: JSONObject = getJsonFromMeta(mateFeature, "j3_feature")
-              val j4: JSONObject = getJsonFromMeta(mateFeature, "j4_feature")
-              val j5: JSONObject = getJsonFromMeta(mateFeature, "j5_feature")
-              val j6: JSONObject = getJsonFromMeta(mateFeature, "j6_feature")
-              val j7: JSONObject = getJsonFromMeta(mateFeature, "j7_feature")
-              val j8: JSONObject = getJsonFromMeta(mateFeature, "j8_feature")
-              val j9: JSONObject = getJsonFromMeta(mateFeature, "j9_feature")
-              val j10: JSONObject = getJsonFromMeta(mateFeature, "j10_feature")
-              val j11: JSONObject = getJsonFromMeta(mateFeature, "j11_feature")
-              val k1: JSONObject = getJsonFromMeta(mateFeature, "k1_feature")
-              val k2: JSONObject = getJsonFromMeta(mateFeature, "k2_feature")
-              val k3: JSONObject = getJsonFromMeta(mateFeature, "k3_feature")
-              val k4: JSONObject = getJsonFromMeta(mateFeature, "k4_feature")
+              // j/k:按线上 otherFeature 原表全称从 metafeature 取
+              val j1: JSONObject = getJsonFromMeta(mateFeature, "alg_cid_feature_level_action")
+              val j2: JSONObject = getJsonFromMeta(mateFeature, "alg_cid_feature_level_advertiser_action")
+              val j3: JSONObject = getJsonFromMeta(mateFeature, "alg_cid_feature_level_customer_action")
+              val j4: JSONObject = getJsonFromMeta(mateFeature, "alg_cid_feature_level_profession_action")
+              val j5: JSONObject = getJsonFromMeta(mateFeature, "alg_cid_feature_level_category_action")
+              val j6: JSONObject = getJsonFromMeta(mateFeature, "alg_cid_feature_level_cid_action")
+              val j7: JSONObject = getJsonFromMeta(mateFeature, "alg_cid_feature_landingpage_action")
+              val j8: JSONObject = getJsonFromMeta(mateFeature, "alg_cid_feature_landingpage_advertiser_action")
+              val j9: JSONObject = getJsonFromMeta(mateFeature, "alg_cid_feature_landingpage_customer_action")
+              val j10: JSONObject = getJsonFromMeta(mateFeature, "alg_cid_feature_landingpage_profession_action")
+              val j11: JSONObject = getJsonFromMeta(mateFeature, "alg_cid_feature_landingpage_category_action")
+              val k1: JSONObject = getJsonFromMeta(mateFeature, "alg_feature_level6_landtype_action")
+              val k2: JSONObject = getJsonFromMeta(mateFeature, "alg_feature_level6_landtype_cid_action")
+              val k3: JSONObject = getJsonFromMeta(mateFeature, "alg_feature_level6_landtype_profession_action")
+              val k4: JSONObject = getJsonFromMeta(mateFeature, "alg_feature_level6_landtype_profession_agent_custom_action")
 
               // id 类:直接取表字段
               val cid = Option(record.getString("cid")).getOrElse("")