Commit 28b0672f authored by 王志伟's avatar 王志伟

repair bug

parent e3f6b411
...@@ -57,12 +57,10 @@ object testt { ...@@ -57,12 +57,10 @@ object testt {
val clk_count = sc.sql( val clk_count = sc.sql(
s""" s"""
|select sum(params["out"]-params["in"]) as dur_time count(cl_id) as num_clk dur_time/num_clk as avg_dur |select params["out"]
|from online.tl_hdfs_maidian_view tl inner join diary_id |from online.tl_hdfs_maidian_view
|on tl.params["business_id"] = diary_id.diary_id
|where action="page_view" |where action="page_view"
|and partition_date >='20180801' and partition_date <'20181107' |and partition_date ='20180801'
|group by tl.params["business_id"] order by avg_dur desc
""".stripMargin """.stripMargin
) )
......
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