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

统计搜索ctr,修复bug

parent f7bbb62a
......@@ -13,8 +13,6 @@ import com.github.nscala_time.time.Imports._
import java.text.SimpleDateFormat
import java.util.Date
import com.sun.tools.internal.jxc.SchemaGenerator.Runner
import scala.util.parsing.json.JSON
object temp_count {
......@@ -477,6 +475,9 @@ object GetHiveSearchData {
def GetSearchResultData(spark: SparkSession, strExposureAction:String, strClickAction:String) = {
val stat_date = "2019-01-16"
val partition_date = stat_date.replace("-","")
val exposureAccum = spark.sparkContext.longAccumulator("search exposure data")
val exposureSql = spark.sql(
s"""
......
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