apache-spark - SQL 中的 Zeppelin 动态表单下拉值

Question

我的 Zeppelin 笔记本中有一个下拉元素
val instrument = z.select("Select Item", Seq(("A", "1"),("B", "2"),("C", "3")))

我想使用这个变量的值 instrument在我的 sql 中。例如，我在笔记本中的下一段包含
%sql select * from table_name where item='<<instrument selected above>>'

这可能吗？如果是，语法会是什么样的？

Answer 1

这是完全可能的，这里有一个例子，同时包含 %spark和 %sql口译员:

单元格 1:

val df = Seq((1,2,"A"),(3,4,"B"),(3,2,"B")).toDF("x","y","item")
df.registerTempTable("table_name")
val instrument = z.select("Select Item", Seq(("A", "1"),("B", "2"),("C", "3")))

单元格 2:

z.show(df.filter($"item"===instrument))

使用 %sql 的替代解决方案 :

%sql select * from table_name where item="${item=A,A|B|C}" 

PS: instrument设置在 B,2