Commit d4eaf07d authored by 王志伟's avatar 王志伟

统计like项目

parent 20f49c13
......@@ -593,7 +593,7 @@ object alpha_ctr {
)
expoure_count_recommend.rdd.map(row =>{
val s = row.getAs[List[String]]("exposure_cards")
(stat_date,s.length)
(stat_date,s)
})
//.reduceByKey((x,y) => x + y)
.toDF("stat_date","count").show()
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment