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

repair bug

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