將RDD [Long，String，Long]轉換爲sql.DataFrame

Question

我有RDD [Long，String，Long]，我想將其轉換爲sql.DataFrame以便對數據執行spark sql。

任何見解？

Answer 1

假設你已經RDD喜歡：

val rdd = Seq((1,"abc",200),(2,"abc",200)) 

toDF可以用來RDD轉換爲DataFrame：

val rdd = Seq((1,"abc",200),(2,"abc",200)).toDF 

注意 - 如果你是不是在火花外殼和寫作類/對象，您需要在轉換之前包括下面的行。

import spark.implicits._ 

這裏spark是SparkSession的一個實例。 希望這有助於。