Commit 5bae6a85 authored by 王志伟's avatar 王志伟

统计like项目

parent 84509b99
......@@ -590,10 +590,11 @@ object alpha_ctr {
|and type = 'page_precise_exposure'
|and partition_day='${partition_date}'
""".stripMargin
).rdd.map(row => {
val lenth=row.toSeq.length
(stat_date,lenth)
}).toDF("stat_date","count").show()
).show()
// .rdd.map(row => {
// val lenth=row.toSeq.length
// (stat_date,lenth)
// }).toDF("stat_date","count").show()
/*.rdd
.map(row =>{
val s = row.getAs[List[String]]("exposure_cards")
......
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