add 搜索次数

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

@@ -45,6 +45,7 @@ object Search_keywords_count {
       val stat_date = GmeiConfig.getMinusNDate(1)   //获取昨日日期
       //println(param.date)
       val partition_date = stat_date.replace("-","")
+      //搜索关键词提取
       val search_keywords = sc.sql(
         s"""
            |select params['query'] as search_keywords
@@ -53,7 +54,15 @@ object Search_keywords_count {
            |and partition_date ='${partition_date}'
          """.stripMargin
       )
-      search_keywords.show(100)
+      //搜索次数统计
+      val search_count = sc.sql(
+        s"""
+           |select count(params['query']) as search_num
+           |from online.tl_hdfs_maidian_view
+           |where action = 'search_result_click_search'
+           |and partition_date ='${partition_date}'
+         """.stripMargin
+      )
 
       val get_result =search_keywords.rdd.map((_, 1)).reduceByKey(_ + _)
         .sortBy(_._2,false)
@@ -62,6 +71,8 @@ object Search_keywords_count {
         println(temp(i))
       }
 
+      println("'${partition_date}'搜索次数："+ search_count.show())
+
     }