Commit b665ff5a authored by 张彦钊's avatar 张彦钊

Merge branch 'master' of git.wanmeizhensuo.com:ML/ffm-baseline

change test
parents e4b11cbb 15b41e11
...@@ -568,6 +568,16 @@ object icon_train_data { ...@@ -568,6 +568,16 @@ object icon_train_data {
) )
meigou_jiache.createOrReplaceTempView("meigou_jiache") meigou_jiache.createOrReplaceTempView("meigou_jiache")
val zixun_meigou=sc.sql(
s"""
|SELECT cl_id as device_id,params['service_id'] as service_id
|from online.tl_hdfs_maidian_view
|where partition_date='${partition_date}'
|and (action='welfare_detail_click_phone' or action='welfare_detail_click_consult' or action='welfare_detail_click_message' or action='welfare_detail_click_curearea_contact')
""".stripMargin
)
zixun_meigou.createOrReplaceTempView("zixun_meigou")
val meigou_all=sc.sql( val meigou_all=sc.sql(
s""" s"""
|SELECT * from meigou_click |SELECT * from meigou_click
...@@ -575,6 +585,8 @@ object icon_train_data { ...@@ -575,6 +585,8 @@ object icon_train_data {
|select * from megou_order |select * from megou_order
|union all |union all
|select * from meigou_jiache |select * from meigou_jiache
|union all
|select * from zixun_meigou
""".stripMargin """.stripMargin
) )
meigou_all.createOrReplaceTempView("meigou_all") meigou_all.createOrReplaceTempView("meigou_all")
...@@ -874,15 +886,15 @@ object test_data { ...@@ -874,15 +886,15 @@ object test_data {
// megou_order.show() // megou_order.show()
//咨询美购数据 //咨询美购数据
val zixun_click=sc.sql( val zixun_meigou=sc.sql(
s""" s"""
|SELECT partition_date,cl_id as device_id,params['service_id'] as service_id |SELECT cl_id as device_id,params['service_id'] as service_id
|from online.tl_hdfs_maidian_view |from online.tl_hdfs_maidian_view
|where partition_date='${partition_date}' |where partition_date='${partition_date}'
|and (action='welfare_detail_click_phone' or action='welfare_detail_click_consult' or action='welfare_detail_click_message' or action='welfare_detail_click_curearea_contact') |and (action='welfare_detail_click_phone' or action='welfare_detail_click_consult' or action='welfare_detail_click_message' or action='welfare_detail_click_curearea_contact')
""".stripMargin """.stripMargin
) )
zixun_click.show() zixun_meigou.show()
// 百科点击数据 // 百科点击数据
......
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