@@ -57,7 +57,7 @@ object makedata_02_writeredis {
redisFormat.iterator
})
println("用户测特征处理-存完再打印")
- userDataTakeRddRun.foreach(r => {
+ userDataTakeRddRun.take(10).foreach(r => {
r._1+ "\t" + r._2
println("user.action.count="+userDataTakeRddRun.count())