如何将 table 转换为 Spark Dataframe

Question

在 Spark SQL 中，可以使用以下方法将数据帧查询为 table：

sqlContext.registerDataFrameAsTable(df, "mytable")

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

Answer 1

那么你可以查询它并将结果保存到一个变量中。检查 SQLContext 的方法 sql returns a DataFrame.

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

Answer 2

最干净的方式：

df = sqlContext.table("mytable")

Documentation