注销

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

@@ -638,7 +638,9 @@ object alpha_ctr {
 
       val device_duration_avge = sc.sql(
         s"""
-           |SELECT '${stat_date}' as stat_date,sum(a.time_all)/count(a.device_id) as device_duration_avge,count(distinct(a.device_id)) as device_num from (select device_id,sum(params['duration']) as time_all
+           |SELECT '${stat_date}' as stat_date,sum(a.time_all)/count(a.device_id) as device_duration_avge,count(distinct(a.device_id)) as device_num
+           |from
+           |(select device_id,sum(params['duration']) as time_all
            |from bl.bl_alpha_et_mg_maidianlog_inc_d
            |where type='on_app_session_over'
            |and partition_day='${partition_date}'

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

@@ -410,11 +410,11 @@ object Repeated_content_recommendation_moreday {
       val sc = spark_env._2
 
       val ti = new TiContext(sc)
-//      ti.tidbMapTable(dbName = "jerry_prod", tableName = "data_feed_exposure_precise")
-//      ti.tidbMapTable(dbName = "jerry_prod", tableName = "data_feed_click")
-//      ti.tidbMapTable(dbName = "jerry_prod", tableName = "blacklist")
-//      ti.tidbMapTable(dbName = "jerry_prod", tableName = "data_feed_exposure")
-//      ti.tidbMapTable(dbName = "jerry_prod", tableName = "merge_queue_table")
+      ti.tidbMapTable(dbName = "jerry_prod", tableName = "data_feed_exposure_precise")
+      ti.tidbMapTable(dbName = "jerry_prod", tableName = "data_feed_click")
+      ti.tidbMapTable(dbName = "jerry_prod", tableName = "blacklist")
+      ti.tidbMapTable(dbName = "jerry_prod", tableName = "data_feed_exposure")
+      ti.tidbMapTable(dbName = "jerry_prod", tableName = "merge_queue_table")
 
 
       val stat_date = GmeiConfig.getMinusNDate(1)