Skip to content

F
ffm-baseline
Commit 3bc913ed authored by 高雅喆's avatar 高雅喆
Browse files
Options

bug fix

parent eda7f39a
Hide whitespace changes
Inline Side-by-side
Showing with 4 additions and 4 deletions
eda/feededa/src/main/scala/com/gmei/EsmmData.scala
View file @ 3bc913ed
...@@ -477,8 +477,8 @@ object GetPortrait { ...@@ -477,8 +477,8 @@ object GetPortrait {
val test1 = sc.sql( val test1 = sc.sql(
s""" s"""
|select a.diary_id,a.tag_id,b.tag_type,b.level1_id,b.level2_id,b.level3_id |select a.diary_id,a.tag_id,b.tag_type,b.level1_id,b.level2_id,b.level3_id
| from tl_hdfs_diary_tags_view a | from online.tl_hdfs_diary_tags_view a
| left join bl_tag_hierarchy_detail b | left join online.bl_tag_hierarchy_detail b
| on a.tag_id = b.id | on a.tag_id = b.id
| where a.partition_date = '20181218' | where a.partition_date = '20181218'
| and b.partition_date = '20181218' | and b.partition_date = '20181218'
...@@ -493,8 +493,8 @@ object GetPortrait { ...@@ -493,8 +493,8 @@ object GetPortrait {
| concat_ws(',',collect_set(cast(c.level2_id as string))) as level2_ids, | concat_ws(',',collect_set(cast(c.level2_id as string))) as level2_ids,
| concat_ws(',',collect_set(cast(c.level3_id as string))) as level3_ids from | concat_ws(',',collect_set(cast(c.level3_id as string))) as level3_ids from
| (select a.diary_id,a.tag_id,b.tag_type,b.level1_id,b.level2_id,b.level3_id | (select a.diary_id,a.tag_id,b.tag_type,b.level1_id,b.level2_id,b.level3_id
| from tl_hdfs_diary_tags_view a | from online.tl_hdfs_diary_tags_view a
| left join bl_tag_hierarchy_detail b | left join online.bl_tag_hierarchy_detail b
| on a.tag_id = b.id | on a.tag_id = b.id
| where a.partition_date = '20181218' | where a.partition_date = '20181218'
| and b.partition_date = '20181218') c | and b.partition_date = '20181218') c
......
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