使用 %sql 语句设置数据块 python 变量

Question

cell 1 中的代码工作正常。

问题

我只是不知道搜索正确的关键字以查看如何使 cells 2 & 3 中的代码工作。基本上，在 %sql 单元格中，我可以 select 进入一个稍后可以在 python 单元格中使用的变量吗？我意识到这甚至是不可能的。干杯！

cell 1

ds = spark.sql("select * from duamonds")
display(ds)

cell 2

%sql
select * from diamonds

cell 3

display({ sql result })

Answer 1

无法完成。但是，您可以这样做：

Cell1

sqlresult= sqlContext.sql("select * from diamonds")

Cell2

display(sqlresult)

您可以找到有关将 SQL 用于数据帧 HERE 的更多详细信息。