chane

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

@@ -78,7 +78,7 @@ object strategy_clk_imp_oldUser {
         val clk_count_oldUser = sc.sql(
           s"""
              |select '${stat_date}' as stat_date, count(cid_id) as get_clk_count_old
-             |from data_feed_click jd left outer join device_id_old
+             |from data_feed_click jd inner join device_id_old
              |on jd.device_id = device_id_old.decive_id
              |where  (jd.cid_type = 'diary' or jd.cid_type = 'diary_video')
              |and jd.device_id regexp'${strategy}'
@@ -88,11 +88,12 @@ object strategy_clk_imp_oldUser {
              |and device_id_old.decive_id is null
          """.stripMargin
         )
+        clk_count_oldUser.show()
 
         val imp_count_oldUser = sc.sql(
           s"""
              |select '${stat_date}' as stat_date, count(cid_id) as get_imp_count_old
-             |from data_feed_exposure je left outer join device_id_old
+             |from data_feed_exposure je inner join device_id_old
              |on je.device_id = device_id_old.decive_id
              |where je.cid_type = 'diary'
              |and je.device_id regexp'${strategy}'
@@ -102,12 +103,13 @@ object strategy_clk_imp_oldUser {
              |and device_id_old.decive_id is null
          """.stripMargin
         )
+        imp_count_oldUser.show()
 
 
         val clk_count_newUser = sc.sql(
           s"""
              |select '${stat_date}' as stat_date, count(cid_id) as get_clk_count_newUser
-             |from data_feed_click jd left outer join device_id_newUser
+             |from data_feed_click jd inner join device_id_newUser
              |on jd.device_id = device_id_newUser.decive_id
              |where  (jd.cid_type = 'diary' or jd.cid_type = 'diary_video')
              |and jd.device_id regexp'${strategy}'
@@ -117,11 +119,12 @@ object strategy_clk_imp_oldUser {
              |and device_id_newUser.decive_id is null
          """.stripMargin
         )
+        clk_count_newUser.show()
 
         val imp_count_newUser = sc.sql(
           s"""
              |select '${stat_date}' as stat_date, count(cid_id) as get_imp_count_newUser
-             |from data_feed_exposure je left outer join device_id_newUser
+             |from data_feed_exposure je inner join device_id_newUser
              |on je.device_id = device_id_newUser.decive_id
              |where je.cid_type = 'diary'
              |and je.device_id regexp'${strategy}'
@@ -131,6 +134,7 @@ object strategy_clk_imp_oldUser {
              |and device_id_newUser.decive_id is null
          """.stripMargin
         )
+        imp_count_newUser.show()
 
         val result = clk_count_oldUser.join(imp_count_oldUser,"stat_date")
           .join(clk_count_newUser,"stat_date")
@@ -149,4 +153,4 @@ object strategy_clk_imp_oldUser {
 
   }
 
-}
+}
\ No newline at end of file