新统计指标

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

@@ -86,6 +86,7 @@ object testt {
            |and ou.cl_id not in (select device_id from blacklist)
          """.stripMargin
       )
+      diary_meigou_count.show()
 
       //2.日记本点击数
       val diary_clk = sc.sql(
@@ -100,6 +101,7 @@ object testt {
            |and ov.cl_id not in (select device_id from blacklist)
        """.stripMargin
       )
+      diary_clk.show()
 
       //3.日记本曝光数
       val diary_expoure=sc.sql(
@@ -114,6 +116,7 @@ object testt {
            |and od.cl_id not in (select device_id from blacklist)
        """.stripMargin
       )
+      diary_expoure.show()
 
       //4.搜索次数统计
       val search_count = sc.sql(
@@ -127,6 +130,7 @@ object testt {
            |and ov.cl_id  not in (select device_id from blacklist)
          """.stripMargin
       )
+      search_count.show()
 
       //5.登录人数
 
@@ -140,13 +144,14 @@ object testt {
            |and oe.device_id not in (select device_id from blacklist)
          """.stripMargin
       )
+      log_num.show()
 
       val result = diary_meigou_count.join(diary_clk,"stat_date")
         .join(diary_expoure,"stat_date")
         .join(search_count,"stat_date")
         .join(log_num,"stat_date")
 
-      GmeiConfig.writeToJDBCTable(result, "diary_meigou_crv", SaveMode.Overwrite)
+      GmeiConfig.writeToJDBCTable(result, "diary_meigou_crv", SaveMode.Append)
 
 
       }