浏览代码

new feature

jch 2 月之前
父节点
当前提交
6602fdcf3d

+ 5 - 1
src/main/scala/com/aliyun/odps/spark/examples/makedata_recsys_r_rate/makedata_recsys_82_originData_20250221.scala

@@ -71,7 +71,11 @@ object makedata_recsys_82_originData_20250221 {
       })
       .leftOuterJoin(midSeqRdd)
       .map(raw => {
-        (raw._2._1, raw._2._2.orNull)
+        if (raw._2._2.isDefined) {
+          (raw._2._1, raw._2._2.get)
+        } else {
+          (raw._2._1, List())
+        }
       })
   }