火花阶分裂串并转换具有两列

Question

测试=“A1-B1，A2-B2”

我想此字符串被转换为一个数据帧作为

与列A和B保持到数据帧相应的A1，A2和B1，B2

Answer 1

您可以将字符串转换成RDD然后将其转换成数据帧：

val s = "a1-b1,a2-b2" 

val df = sc.parallelize(
    s.split(",").map(_.split("-")).map{ case Array(a, b) => (a, b) } 
).toDF("A", "B") 

df.show 
+---+---+ 
| A| B| 
+---+---+ 
| a1| b1| 
| a2| b2| 
+---+---+