diff --git a/eda/feededa/src/main/scala/com/gmei/testt.scala b/eda/feededa/src/main/scala/com/gmei/testt.scala index 7803b72070f89caebd24c26e1210893322245147..56da4da22fb319b2e72f19696746a4d8109aa74b 100644 --- a/eda/feededa/src/main/scala/com/gmei/testt.scala +++ b/eda/feededa/src/main/scala/com/gmei/testt.scala @@ -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 )