Commit d79b8092 authored by 王志伟's avatar 王志伟

repair bug

parent f8443a93
......@@ -57,12 +57,13 @@ object Search_keywords_count {
//搜索次数统计
val search_count = sc.sql(
s"""
|select count(params['query']) as search_num
|select '${stat_date}' as stat_date,count(params['query']) as search_num
|from online.tl_hdfs_maidian_view
|where action = 'search_result_click_search'
|and partition_date ='${partition_date}'
""".stripMargin
)
search_count.show()
val get_result =search_keywords.rdd.map((_, 1)).reduceByKey(_ + _)
.sortBy(_._2,false)
......@@ -71,11 +72,10 @@ object Search_keywords_count {
println(temp(i))
}
println("'${partition_date}'搜索次数:"+ search_count.show())
}
}
}
}
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment