Skip to content

M
mobvista-dmp
Commit 2b5304c6 by WangJinfeng
Options

init id_mapping

parent ffda3f49
Showing with 1 addition and 3 deletions
src/main/scala/mobvista/dmp/datasource/id_mapping/IDMappingGraphx.scala
...@@ -102,9 +102,7 @@ class IDMappingGraphx extends CommonSparkJob with Serializable { ...@@ -102,9 +102,7 @@ class IDMappingGraphx extends CommonSparkJob with Serializable {
(c1: Set[(String, String, String)], c2: Set[(String, String, String)]) => c1 ++ c2 (c1: Set[(String, String, String)], c2: Set[(String, String, String)]) => c1 ++ c2
) )
val multiOneIDRDD = maxGraph.filter(kv => { val multiOneIDRDD = maxGraph.map(rs => {
kv._2.size > 1
}).map(rs => {
platform match { platform match {
case "ios" => case "ios" =>
updateOneID(rs, Constant.iosMainIDSet) updateOneID(rs, Constant.iosMainIDSet)
......
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