feat:修改脚本

src/main/scala/com/aliyun/odps/spark/zhp/util/AdUtil.java

@@ -0,0 +1,41 @@
+package com.aliyun.odps.spark.zhp.util;
+
+import com.alibaba.fastjson.JSONObject;
+
+import java.util.HashMap;
+import java.util.Map;
+
+public class AdUtil {
+
+    /**
+     * 将线上metaFeature中的Key替换为大数据表中的Key，用于定位问题
+     */
+    public static JSONObject keyReplace(JSONObject featureJson) {
+        JSONObject newJson = new JSONObject();
+        Map<String, String> keyMap = new HashMap<String, String>() {{
+            put("alg_cid_feature_basic_info", "b1_feature");
+            put("alg_cid_feature_adver_action", "b2_feature");
+            put("alg_cid_feature_cid_action", "b3_feature");
+            put("alg_cid_feature_region_action", "b4_feature");
+            put("alg_cid_feature_app_action", "b5_feature");
+            put("alg_cid_feature_week_action", "b6_feature");
+            put("alg_cid_feature_hour_action", "b7_feature");
+            put("alg_cid_feature_brand_action", "b8_feature");
+            put("alg_cid_feature_weChatVersion_action", "b9_feature");
+            put("alg_mid_feature_ad_action", "c1_feature");
+            put("alg_cid_feature_vid_cf", "d1_feature");
+            put("alg_cid_feature_vid_cf_rank", "d2_feature");
+            put("alg_vid_feature_basic_info", "d3_feature");
+            put("alg_mid_feature_return_tags", "e1_feature");
+            put("alg_mid_feature_share_tags", "e2_feature");
+        }};
+
+        for (Map.Entry<String, Object> entry : featureJson.entrySet()) {
+            String key = keyMap.getOrDefault(entry.getKey(), entry.getKey());
+            newJson.put(key, entry.getValue());
+        }
+
+        return newJson;
+    }
+
+}