在 Spark SQL 中,可以使用以下方法将数据帧作为表进行查询:
sqlContext.registerDataFrameAsTable(df, "mytable")
假设我拥有的是
mytable
,如何将其作为 DataFrame 获取或访问?
最佳答案
那么你可以查询它并将结果保存到一个变量中。检查 SQLContext
的方法 sql返回 DataFrame
.
df = sqlContext.sql("SELECT * FROM mytable")
关于apache-spark - 如何将表转换为 Spark Dataframe,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/39191194/