浏览代码

修改cate获取key

xueyiming 8 小时之前
父节点
当前提交
8426597f21

+ 8 - 8
src/main/scala/com/aliyun/odps/spark/examples/makedata_ad/v20240718/makedata_ad_33_bucketDataFromOriginToHive_20250228.scala

@@ -453,17 +453,17 @@ object makedata_ad_33_bucketDataFromOriginToHive_20250228 {
                 JSON.parseObject(record.getString("g1_feature"))
               val g2: JSONObject = if (record.isNull("g2_feature")) new JSONObject() else
                 JSON.parseObject(record.getString("g2_feature"))
-              if (g1.containsKey("user_vid_play_cate1_14d") && g1.getString("user_vid_play_cate1_14d").nonEmpty) {
-                featureMap.put("user_vid_return_cate1_14d", g1.getString("user_vid_play_cate1_14d"))
+              if (g1.containsKey("cate1_14d") && g1.getString("cate1_14d").nonEmpty) {
+                featureMap.put("user_vid_return_cate1_14d", g1.getString("cate1_14d"))
               }
-              if (g1.containsKey("user_vid_play_cate2_14d") && g1.getString("user_vid_play_cate2_14d").nonEmpty) {
-                featureMap.put("user_vid_return_cate2_14d", g1.getString("user_vid_play_cate2_14d"))
+              if (g1.containsKey("cate2_14d") && g1.getString("cate2_14d").nonEmpty) {
+                featureMap.put("user_vid_return_cate2_14d", g1.getString("cate2_14d"))
               }
-              if (g2.containsKey("user_vid_share_cate1_14d") && g2.getString("user_vid_share_cate1_14d").nonEmpty) {
-                featureMap.put("user_vid_share_cate1_14d", g2.getString("user_vid_share_cate1_14d"))
+              if (g2.containsKey("cate1_14d") && g2.getString("cate1_14d").nonEmpty) {
+                featureMap.put("user_vid_share_cate1_14d", g2.getString("cate1_14d"))
               }
-              if (g2.containsKey("user_vid_share_cate2_14d") && g2.getString("user_vid_share_cate2_14d").nonEmpty) {
-                featureMap.put("user_vid_share_cate2_14d", g2.getString("user_vid_share_cate2_14d"))
+              if (g2.containsKey("cate2_14d") && g2.getString("cate2_14d").nonEmpty) {
+                featureMap.put("user_vid_share_cate2_14d", g2.getString("cate2_14d"))
               }
 
               val d1: JSONObject = if (record.isNull("d1_feature")) new JSONObject() else