Преглед на файлове

use offline join feat instead of meta feat

yuehailiang преди 4 месеца
родител
ревизия
f3bbabab25
променени са 1 файла, в които са добавени 3 реда и са изтрити 4 реда
  1. 3 4
      src/main/scala/com/aliyun/odps/spark/examples/makedata_ad/v20240718/makedata_ad_31_originData_20250623.scala

+ 3 - 4
src/main/scala/com/aliyun/odps/spark/examples/makedata_ad/v20240718/makedata_ad_31_originData_20250623.scala

@@ -354,10 +354,9 @@ object makedata_ad_31_originData_20250623 {
             if (c1.containsKey("user_has_conver_1y") && c1.getInteger("user_has_conver_1y") != null) {
               featureMap.put("user_has_conver_1y", c1.getInteger("user_has_conver_1y"))
             }
-            val h1: JSONObject = if (!mateFeature.containsKey("alg_mid_feature_adver_action")) new JSONObject() else
-              mateFeature.getJSONObject("alg_mid_feature_adver_action")
-            val h2: JSONObject = if (!mateFeature.containsKey("alg_mid_feature_sku_action")) new JSONObject() else
-              mateFeature.getJSONObject("alg_mid_feature_sku_action")
+
+            val h1: JSONObject = if (record.isNull("h1_feature")) new JSONObject() else JSON.parseObject(record.getString("h1_feature"))
+            val h2: JSONObject = if (record.isNull("h2_feature")) new JSONObject() else JSON.parseObject(record.getString("h2_feature"))
 
             // 定义时间维度和对应的前缀
             val timeDimensions = Seq("3d", "7d", "30d")