Browse Source

feat:修改label

zhaohaipeng 2 months ago
parent
commit
862166d5dd

+ 5 - 2
src/main/scala/com/aliyun/odps/spark/examples/makedata_recsys/makedata_recsys_41_originData_20250218.scala

@@ -123,8 +123,11 @@ object makedata_recsys_41_originData_20250218 {
           //4 处理label信息。
           val labels = new JSONObject
           for (labelKey <- List(
-            "is_play", "is_share", "is_return", "noself_is_return", "return_uv", "noself_return_uv", "total_return_uv",
-            "share_pv", "total_share_uv"
+            "is_share", "share_cnt",
+            "is_return_1", "return_1_uv",
+            "is_return_n", "return_n_uv",
+            "is_return_noself", "return_1_uv_noself",
+            "is_return_n_noself", "return_n_uv_noself"
           )) {
             if (!record.isNull(labelKey)) {
               labels.put(labelKey, record.getString(labelKey))