ソースを参照

feat:修改推荐补数据脚本

zhaohaipeng 1 ヶ月 前
コミット
ffbcc0f07d

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

@@ -59,8 +59,7 @@ object makedata_recsys_41_originData_20250218 {
 
             val featureMap = new JSONObject()
             val vid = if (record.isNull("vid")) "" else record.getString("vid")
-            // vid 已经提取了
-            val ts = record.getString("ts").toLong
+            val ts = if (record.isNull("ts")) 0 else record.getString("ts").toLong
             // a 视频特征
             val b1: JSONObject = if (record.isNull("b1_feature")) new JSONObject() else JSON.parseObject(record.getString("b1_feature"))
             val b2: JSONObject = if (record.isNull("b2_feature")) new JSONObject() else JSON.parseObject(record.getString("b2_feature"))