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

将应用列表添加到table

parent 532de014
......@@ -106,7 +106,7 @@ object app_list {
)
//app_list.show()
import sc.implicits._
val rdd_df = app_list.rdd.map(x =>(x(0).toString,x(1).toString,x(2).toString))
val rdd_df = app_list.rdd.map(x =>(x(0).toString,x(1).toString,x(2).toString,x(3).toString))
.filter(x => x._3.contains("新氧美容")).map(x => (x._1,x._2,x._3,x._4)).collect().toList.toDF("device_id","user_id","app_list")
rdd_df.show()
//rdd_df.withColumn("stat_date",addCol(rdd_df("device_id")))
......
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