如何将表转换为Spark Dataframe

Question

在Spark SQL中,可以使用以下方法将数据帧作为表进行查询:

sqlContext.registerDataFrameAsTable(df, "mytable")

假设我拥有的是什么,我mytable如何获取或访问它作为DataFrame？

Answer 1

那么你可以查询它并将结果保存到变量中.检查SQLContext方法sql是否返回一个DataFrame.

df = sqlContext.sql("SELECT * FROM mytable")

Answer 2

最干净的方法：

df = sqlContext.table("mytable")

文献资料