Commit e90fd86f by WangJinfeng

init id_mapping

parent 69359cfa
...@@ -207,7 +207,6 @@ class IDMappingGraphx extends CommonSparkJob with Serializable { ...@@ -207,7 +207,6 @@ class IDMappingGraphx extends CommonSparkJob with Serializable {
.orc(resultOutPutPath) .orc(resultOutPutPath)
} }
def processData(row: Row, platform: String): Row = { def processData(row: Row, platform: String): Row = {
platform match { platform match {
case "ios" => case "ios" =>
...@@ -316,7 +315,7 @@ class IDMappingGraphx extends CommonSparkJob with Serializable { ...@@ -316,7 +315,7 @@ class IDMappingGraphx extends CommonSparkJob with Serializable {
val jsonObject = new JSONObject() val jsonObject = new JSONObject()
val oneIDType = ids(i) val oneIDType = ids(i)
jsonObject.put("id_type", oneIDType) jsonObject.put("id_type", oneIDType)
jsonObject.put("active_type", date) jsonObject.put("active_date", date)
jsonObject.put("cnt", cnt) jsonObject.put("cnt", cnt)
val oneID = row.getAs[String](String.valueOf(ids(i))) val oneID = row.getAs[String](String.valueOf(ids(i)))
array += ((oneID, (oneID, jsonObject.toJSONString, oneIDType))) array += ((oneID, (oneID, jsonObject.toJSONString, oneIDType)))
......
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