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

更改object名称

parent b49d205c
...@@ -64,12 +64,12 @@ object data_feed_exposure_precise { ...@@ -64,12 +64,12 @@ object data_feed_exposure_precise {
| cl_id as device_id, | cl_id as device_id,
| channel as device_type, | channel as device_type,
| card_content_type as card_content_type , | card_content_type as card_content_type ,
| business_id as business_id, | card_id as business_id,
| if(card_content_type="diary", concat("diary|", business_id), | if(card_content_type="diary", concat("diary|", card_id),
| if(card_content_type="live", concat("live|", business_id), | if(card_content_type="live", concat("live|", card_id),
| if(card_content_type="question", concat("question|", business_id), | if(card_content_type="question", concat("question|", card_id),
| if(card_content_type="answer", concat("answer|", business_id), | if(card_content_type="answer", concat("answer|", card_id),
| if(card_content_type="article", concat("article|", business_id), null | if(card_content_type="article", concat("article|", card_id), null
| ))))) as cid, | ))))) as cid,
| city_id as city_id | city_id as city_id
|from online.ml_community_precise_exposure_detail |from online.ml_community_precise_exposure_detail
......
...@@ -8,7 +8,7 @@ import org.apache.log4j.{Level, Logger} ...@@ -8,7 +8,7 @@ import org.apache.log4j.{Level, Logger}
import scopt.OptionParser import scopt.OptionParser
import com.gmei.lib.AbstractParams import com.gmei.lib.AbstractParams
object find_bug { object diary_ctr {
Logger.getLogger("org.apache.spark").setLevel(Level.WARN) Logger.getLogger("org.apache.spark").setLevel(Level.WARN)
Logger.getLogger("org.apache.eclipse.jetty.server").setLevel(Level.OFF) Logger.getLogger("org.apache.eclipse.jetty.server").setLevel(Level.OFF)
...@@ -51,8 +51,8 @@ object find_bug { ...@@ -51,8 +51,8 @@ object find_bug {
ti.tidbMapTable(dbName = "jerry_prod", tableName = "merge_queue_table") ti.tidbMapTable(dbName = "jerry_prod", tableName = "merge_queue_table")
// val stat_date = GmeiConfig.getMinusNDate(1) val stat_date = GmeiConfig.getMinusNDate(1)
val stat_date = param.date // val stat_date = param.date
//println(param.date) //println(param.date)
val partition_date = stat_date.replace("-","") val partition_date = stat_date.replace("-","")
val decive_id_oldUser = sc.sql( val decive_id_oldUser = sc.sql(
......
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