Commit 462105d0 authored by 高雅喆's avatar 高雅喆

add sortbykey

parent dbf0fec3
......@@ -644,7 +644,8 @@ object GetLevelCount {
ti.tidbMapTable(dbName = "jerry_prod",tableName = "data_feed_click")
ti.tidbMapTable(dbName = "jerry_prod",tableName = "diary_feat")
val diary_queue = sc.read.json(param.path)
val diary_queue = sc.read.json(param.path).rdd.map(x => x(0).toString).distinct().collect().toList.mkString(",")
val diary_level1 = sc.sql(
s"""
|select diary_id,explode(split(level1_ids,';')) from diary_feat
......
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