火花階分裂串並轉換具有兩列

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| 
+---+---+