jch 1 ماه پیش
والد
کامیت
d904b395de

+ 2 - 2
src/main/scala/com/aliyun/odps/spark/examples/myUtils/ConvertV2.java

@@ -70,8 +70,8 @@ public class ConvertV2 {
         map.put("mid_global_feature_20250212", ConvertUtils.getRecordCol(record, "c1_feature"));
         map.put("alg_mid_feature_return_tags", ConvertUtils.getRecordCol(record, "c5_feature"));
         map.put("alg_mid_feature_share_tags", ConvertUtils.getRecordCol(record, "c6_feature"));
-        map.put("alg_mid_feature_sharecf", ConvertUtils.getRecordCol(record, "c7_feature"));
-        map.put("alg_mid_feature_returncf", ConvertUtils.getRecordCol(record, "c8_feature"));
+        // map.put("alg_mid_feature_sharecf", ConvertUtils.getRecordCol(record, "c7_feature"));
+        // map.put("alg_mid_feature_returncf", ConvertUtils.getRecordCol(record, "c8_feature"));
         map.put("alg_recsys_feature_user_share_return_stat", ConvertUtils.getRecordCol(record, "c9_feature"));
         return map;
     }

+ 2 - 2
src/main/scala/com/aliyun/odps/spark/examples/myUtils/FeatureTransformV2.java

@@ -16,7 +16,7 @@ public class FeatureTransformV2 {
     private static final List<String> b1Periods = Arrays.asList("1h", "3h", "6h", "24h", "72h", "168h");
     private static final List<String> b2Periods = Arrays.asList("1h", "3h", "6h", "24h");
     private static final List<String> b3Periods = Arrays.asList("1h", "3h", "6h", "24h", "72h");
-    private static final List<String> b4Periods = Arrays.asList("1h", "3h", "6h", "12h");
+    private static final List<String> b4Periods = Arrays.asList("1h", "3h", "6h", "12h", "24h", "72h");
     private static final List<String> b5Periods = Arrays.asList("1h", "3h", "6h", "12h", "24h", "72h");
     private static final List<String> b6Periods = Arrays.asList("1h", "24h");
     private static final List<String> b7Periods = Arrays.asList("1h", "3h", "6h", "12h", "24h", "72h");
@@ -24,7 +24,7 @@ public class FeatureTransformV2 {
     private static final List<String> b9Periods = Arrays.asList("1h", "3h", "24h");
     private static final List<String> b10Periods = Arrays.asList("1h", "12h");
     private static final List<String> b11Periods = Arrays.asList("1h", "12h");
-    private static final List<String> b13Periods = Arrays.asList("1h", "3h", "24h", "72h");
+    private static final List<String> b13Periods = Arrays.asList("1h", "3h", "6h", "12h", "24h", "72h");
     private static final List<String> b14Periods = Arrays.asList("1h", "2h", "3h", "6h", "12h");
     private static final List<String> b15Periods = Arrays.asList("1h", "2h", "3h", "6h", "12h");
     private static final List<String> videoCateAttrs = Arrays.asList(FeatureUtils.cate1Attr, FeatureUtils.cate2Attr, FeatureUtils.festive1Attr,