将应用列表添加到table

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

@@ -92,9 +92,7 @@ object app_list {
       agency_id.createOrReplaceTempView("agency_id")
 
 
-
-
-      //获取策略命中用户device_id
+      //获取与新氧用户重合的用户device_id
       val app_list = sc.sql(
         s"""
            |select distinct(cl_id) as device_id, user_id as user_id, params['installed_app_info'] as app_list
@@ -109,7 +107,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))
-        .filter(x => x._3.contains("新氧美容")).map(x => (x._1,x._2)).collect().toList.toDF("device_id","user_id")
+        .filter(x => x._3.contains("新氧美容")).map(x => (x._1,x._2,x._3)).collect().toList.toDF("device_id","user_id","app_list")
       rdd_df.show()
       //rdd_df.withColumn("stat_date",addCol(rdd_df("device_id")))
       rdd_df.createOrReplaceTempView("device_id")
@@ -128,9 +126,9 @@ object app_list {
 
 
 //所有获得应用列表的用户device_id
-/*      val app_list_all = sc.sql(
+      val app_list_all = sc.sql(
         s"""
-           |select distinct(cl_id) as device_id, user_id as user_id
+           |select distinct(cl_id) as device_id, user_id as user_id,params['installed_app_info'] as app_list
            |from online.tl_hdfs_maidian_view ov left join agency_id
            |on ov.cl_id = agency_id.device_id
            |where action="user_installed_all_app_info"
@@ -142,7 +140,7 @@ object app_list {
       val tempp_list=app_list_all.withColumn("stat_date",addCol(app_list_all("device_id")))
 
       GmeiConfig.writeToJDBCTable(tempp_list, "device_id_applist", SaveMode.Append)
-*/
+
 
     }