将应用列表添加到table

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

@@ -95,7 +95,7 @@ object app_list {
       //获取与新氧用户重合的用户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
+           |select distinct(cl_id) as device_id, user_id as user_id, params['installed_app_info'] as app_list,channel
            |from online.tl_hdfs_maidian_view ov left join agency_id
            |on ov.cl_id = agency_id.device_id
            |where ov.action="user_installed_all_app_info"
@@ -107,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,x._3)).collect().toList.toDF("device_id","user_id","app_list")
+        .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")))
       rdd_df.createOrReplaceTempView("device_id")
@@ -128,7 +128,7 @@ object app_list {
 //所有获得应用列表的用户device_id
       val app_list_all = sc.sql(
         s"""
-           |select distinct(cl_id) as device_id, user_id as user_id,params['installed_app_info'] as app_list
+           |select distinct(cl_id) as device_id, user_id as user_id,params['installed_app_info'] as app_list,channel
            |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"