python - 使用 %sql 语句设置 databricks python 变量

Question

单元格 1 中的代码运行良好。

问题

我只是不知道要搜索的正确关键字，以了解如何使单元格 2 和 3 中的代码正常工作。基本上，在 %sql 单元中，我可以选择一个稍后可以在 python 单元中使用的变量吗？我意识到这甚至是不可能的。干杯!

单元格 1

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

单元格 2

%sql
select * from diamonds

单元格 3

display({ sql result })

Answer 1

这是不可能的。但是，您可以这样做:

单元格1

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

Cell2

display(sqlresult)

您可以找到有关将 SQL 与数据帧结合使用的更多详细信息 HERE .