如何從一行創建一個RDD

-1

我的問題很簡單。我想將下面的行轉換爲RDD。如何從一行創建一個RDD

Row("val1","val2")

你有什麼想法嗎？感謝

來源

2017-07-18 a.moussa

你需要的輸出爲RDD [行]或RDD [字符串]？ – Psidom

要讓行中的每個元素成爲RDD中的記錄，還是希望RDD [Row]只包含單個行對象？ – puhlen

我想要一行兩列，這將是一行Rdd行 –

val abc = Row("val1","val2") 
val rdd = sc.parallelize(Seq(abc)) 
val rowRdd = rdd.map(row => Row(row.toSeq)) 
rowRdd: org.apache.spark.rdd.RDD[org.apache.spark.sql.Row]

來源

2017-07-18 22:43:42

sc.parallelize(List(Row("val1","val2")))

是罰款

來源

2018-01-22 08:56:48

您需要添加一些解釋到您的解決方案，什麼是'sc'，什麼是'parallelize'？ – user7294900

如何從一行創建一個RDD

回答

相關問題