统计话题pv

eda/feededa/src/main/scala/com/gmei/temp_count.scala

@@ -326,7 +326,7 @@ object Repeated_content_recommendation_moreday {
       val temp=exp_diary.take(10).foreach(println)
 
       //统计每个用户重复日记个数
-      val count_imp=exp_diary.map(_._2).map(row=>row.map((_, 1)).reduceByKey(_ + _))
+//      val count_imp=exp_diary.map(_._2).map(row=>row.map((_, 1)).reduceByKey(_ + _))
 
 //      exp_diary.show()
 //      exp_diary.createOrReplaceTempView("exp_diary")