scala - How to convert rdd object to dataframe in spark -
how can convert rdd (org.apache.spark.rdd.rdd[org.apache.spark.sql.row]
) dataframe org.apache.spark.sql.dataframe
. converted dataframe rdd using .rdd
. after processing want in dataframe. how can ?
sqlcontext
has number of createdataframe
methods create dataframe
given rdd
. imagine 1 of these work context.
for example:
def createdataframe(rowrdd: rdd[row], schema: structtype): dataframe
creates dataframe rdd containing rows using given schema.
Comments
Post a Comment