merge cate

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

@@ -25,7 +25,7 @@ public class FeatureTransformV2 {
     private static final List<String> b11Periods = Arrays.asList("12h", "168h");
     private static final List<String> b13Periods = Arrays.asList("24h", "168h");
     private static final List<String> videoCateAttrs = Arrays.asList(FeatureUtils.cate1Attr, FeatureUtils.cate2Attr, FeatureUtils.festive1Attr,
-            FeatureUtils.channelAttr, FeatureUtils.sourceAttr, FeatureUtils.uidAttr);
+            FeatureUtils.channelAttr, FeatureUtils.sourceAttr, FeatureUtils.uidAttr, FeatureUtils.mergeCate1Attr, FeatureUtils.mergeCate2Attr);
     private static final List<String> videoSimAttrs = Arrays.asList("title", "cate2", "cate2_list", "keywords");
     private static final List<String> hVideoSimAttrs = Arrays.asList("title");
     private static final List<String> cfList = Arrays.asList("share", "return");

src/main/scala/com/aliyun/odps/spark/examples/myUtils/FeatureUtils.java

@@ -17,6 +17,8 @@ public class FeatureUtils {
     public static final String channelAttr = "channel";
     public static final String sourceAttr = "vid_source";
     public static final String uidAttr = "uid";
+    public static final String mergeCate1Attr = "merge_first_level_cate";
+    public static final String mergeCate2Attr = "merge_second_level_cate";
     public static final double twoMonthMs = 2 * 30 * 24 * 3600 * 1000.0;
 
     private static final String goodMorningRegex = "(早安|早上好|早晨好|上午好)";