all

src/main/scala/com/aliyun/odps/spark/examples/makedata/makedata_08_item2redis.scala

@@ -102,7 +102,7 @@ object makedata_08_item2redis {
         MyHdfsUtils.delete_hdfs_path(savePathPart)
         itemDataTakeRddRun.map(r => r._1 + "\t" + r._2).saveAsTextFile(savePathPart, classOf[GzipCodec])
       }
-      println("item.action.count=" + itemDataTakeRddRun.count())
+      println("item写入成功：item.action.count=" + itemDataTakeRddRun.count())
     }else{
       println("不处理video")
     }

src/main/scala/com/aliyun/odps/spark/examples/makedata/makedata_09_user2redis.scala

@@ -193,7 +193,7 @@ object makedata_09_user2redis {
         redisFormat.clear()
         redisFormat.iterator
       })
-      println("put in redis.count=" + userDataTakeRddRun.count())
+      println("user写入成功：put in redis.count=" + userDataTakeRddRun.count())
     } else {
       println("不处理user的redis写入")
     }