str和ros扩展新特征

src/main/scala/com/aliyun/odps/spark/examples/makedata_recsys/makedata_recsys_41_str2ros_originData_20241209.scala

@@ -171,15 +171,15 @@ object makedata_recsys_41_str2ros_originData_20241209 {
           val middlePeriod = List("1d", "7d", "14d", "30d")
           val longPeriod = List("7d", "35d", "90d", "365d")
           val vidStatFeat = List(
-            ("b20", shortPeriod, getJsonObject(record, "b20_feature")),
-            ("b21", shortPeriod, getJsonObject(record, "b21_feature")),
-            ("b22", shortPeriod, getJsonObject(record, "b22_feature")),
-            ("b28", shortPeriod, getJsonObject(record, "b28_feature")),
-            ("b23", middlePeriod, getJsonObject(record, "b23_feature")),
-            ("b24", middlePeriod, getJsonObject(record, "b24_feature")),
-            ("b25", middlePeriod, getJsonObject(record, "b25_feature")),
-            ("b26", longPeriod, getJsonObject(record, "b26_feature")),
-            ("b27", longPeriod, getJsonObject(record, "b27_feature"))
+            ("b20", shortPeriod, getJsonObject(record, "b20_feature")), // cate2_feature
+            ("b21", shortPeriod, getJsonObject(record, "b21_feature")), // cate1_feature
+            ("b22", shortPeriod, getJsonObject(record, "b22_feature")), // source_feature
+            ("b28", shortPeriod, getJsonObject(record, "b28_feature")), // sence_type_feature
+            ("b23", middlePeriod, getJsonObject(record, "b23_feature")), // cate2_feature_day
+            ("b24", middlePeriod, getJsonObject(record, "b24_feature")), // cate1_feature_day
+            ("b25", middlePeriod, getJsonObject(record, "b25_feature")), // source_feature_day
+            ("b26", longPeriod, getJsonObject(record, "b26_feature")), // unionid_feature_day
+            ("b27", longPeriod, getJsonObject(record, "b27_feature")) // vid_feature_day
           )
           for ((featType, featPeriod, featData) <- vidStatFeat) {
             for (period <- featPeriod) {
@@ -244,6 +244,12 @@ object makedata_recsys_41_str2ros_originData_20241209 {
             }
           }
 
+          // head video & rank video
+          val headVideo = getJsonObject(record, "v2_feature")
+          val rankVideo = getJsonObject(record, "v1_feature")
+          if (headVideo.nonEmpty && rankVideo.nonEmpty) {
+          }
+
           /*