소스 검색

关系表主键修改

xufei 4 년 전
부모
커밋
0c135b5197
1개의 변경된 파일1개의 추가작업 그리고 1개의 파일을 삭제
  1. 1 1
      src/main/scala/com/winhc/bigdata/spark/ng/relation/inc_company_relation_v2.scala

+ 1 - 1
src/main/scala/com/winhc/bigdata/spark/ng/relation/inc_company_relation_v2.scala

@@ -171,7 +171,7 @@ case class inc_company_relation_v2(s: SparkSession,
     sql(
       s"""
          |INSERT INTO TABLE $inc_ads_company_human_relation PARTITION(ds= '$ds')
-         |SELECT  CONCAT_WS('_',a.company_id,hash(a.human_name)) AS rowkey
+         |SELECT  md5(CONCAT_WS('_',company_id,human_pid)) as rowkey
          |        ,a.company_id
          |        ,a.company_name
          |        ,a.human_name