2017-09-29 65 views
-1

測試=「A1-B1,A2-B2」火花階分裂串並轉換具有兩列

我想此字符串被轉換爲一個數據幀作爲

與列A和B保持到數據幀相應的A1,A2和B1,B2

+0

如果你提供一些代碼,其他人可以提供反饋,你會得到更多的幫助上。你試過什麼了? – Jaquez

回答

2

您可以將字符串轉換成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| 
+---+---+