spark 一条数据格式为A:b,c,d 变成 (k,v) (A,b)(A,c)(A,d)

0
rt
已邀请:
0

regan - run! run! run! happy runner! 我是奔跑的小米~ 2017-03-27 回答

val a = "A:b,c,d" val b = a.split(":") val c = b{0} val d = b{1} val e = d.split(",") val f = e.flatMap(s=>List((c,s))) println(f.mkString(","))
 

要回复问题请先登录注册