【发布时间】:2018-03-18 20:15:37
【问题描述】:
我们在服务器上保存了parquet 数据,我正在尝试通过以下方式使用SparkR sql() 函数
df <- sql("SELECT * FROM parquet.`<path to parquet file`")
head(df)
show(df) # returns "<SQL> SELECT * FROM parquet.`<path to parquet file`"
和
createOrReplaceTempView(df, "table")
df2 <- sql("SELECT * FROM table")
show(df2) # returns "<SQL> SELECT * FROM table"
在这两种情况下,我得到的是字符串格式的 sql 查询,而不是 spark 数据框。有谁知道为什么会发生这种情况以及为什么我没有得到数据框?
谢谢
【问题讨论】: