Commit 543cf2b6 authored by 王志伟's avatar 王志伟

repair bug

parent 40cd7246
...@@ -58,8 +58,10 @@ object testt { ...@@ -58,8 +58,10 @@ object testt {
val clk_count = sc.sql( val clk_count = sc.sql(
s""" s"""
|select sum(params["out"]-params["in"]) |select sum(params["out"]-params["in"])
|from online.tl_hdfs_maidian_view |from online.tl_hdfs_maidian_view tl join diary_id di
|on tl.params["business_id"]=di.diary_id
|where action="page_view" |where action="page_view"
|and params["page_name"]="diary_detail"
|and partition_date ='20180801' |and partition_date ='20180801'
""".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