jch il y a 2 mois
Parent
commit
64682b70c3

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

@@ -40,6 +40,7 @@ object makedata_recsys_82_originData_20250221 {
         (mid, record)
       })
       .filter(_._1.nonEmpty)
+      .reduceByKey((a, b) => a)
       .flatMap(raw => {
         val result = new ArrayBuffer[(String, String)]
         for (hVid <- ConvertUtils.getVidList(raw._2.getString("c9_feature"))) {