Commit d32f0e2d authored by 高雅喆's avatar 高雅喆

change input data (date condition)

parent ef679a65
...@@ -96,13 +96,12 @@ object Main { ...@@ -96,13 +96,12 @@ object Main {
ti.tidbMapTable(dbName = GmeiConfig.config.getString("tidb.database"),tableName = "data_feed_click") ti.tidbMapTable(dbName = GmeiConfig.config.getString("tidb.database"),tableName = "data_feed_click")
val date8 = GmeiConfig.getMinusNDate(8) // val date8 = GmeiConfig.getMinusNDate(8)
val tidb_inupt = sc.sql( val tidb_inupt = sc.sql(
s""" s"""
|SELECT |SELECT
| service_id,cid | service_id,cid
|FROM nd_data_meigou_cid |FROM nd_data_meigou_cid
|where stat_date > '${date8}'
""".stripMargin """.stripMargin
) )
...@@ -194,8 +193,8 @@ object Main { ...@@ -194,8 +193,8 @@ object Main {
|select a.device_id device_id,b.similarity_cid similarity_cid from |select a.device_id device_id,b.similarity_cid similarity_cid from
|(select device_id,first(cid) as cid from data_feed_click |(select device_id,first(cid) as cid from data_feed_click
|where cid_type='diary' |where cid_type='diary'
|and stat_date > '${date8}' |and cid in (select cid from nd_cid_similarity_matrix)
|group by device_id) a left join |group by device_id order by time desc) a left join
|nd_cid_similarity_matrix b |nd_cid_similarity_matrix b
|on a.cid = b.cid |on a.cid = b.cid
|where b.similarity_cid is not null |where b.similarity_cid is not null
......
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