Apache - Zeppelin跨段使用变量

Question

我试图在Apache Zeppelin上完成以下用例:例如,当我编写一个sql查询时

%sql SELECT * FROM table1 WHERE column1 = ${column1=1,1|2|3|4}

我得到一个组合框,显示这些值(1,2,3,4)作为选项.我想要做的是使用此列可用的所有不同值填充此列表(或者事实上,我可能希望从变量形式的另一段中获取任何其他值集).所以目前我仍然坚持如何在另一段中的sql语句中使用一个段落中定义的变量？

潜入代码,我看到在Zeppelin解释器中,一个名为Input.java的文件检查模式$ {someColumn = someValues},填充组合框选项,然后创建一个简单的查询,因此我已经删除通过在同一段落中运行查询来填充它的想法.

Answer 1

您可以使用ZeppelinContext来完成此操作，因为它使您能够使用 put() 和 get() 来设置和检索段落之间的对象。

引用链接页面中的示例，请注意z对象是 ZeppelinContext 的默认实例：

// Put object from scala
%spark
val myObject = ...
z.put("objName", myObject)

# Get object from python
%spark.pyspark
myObject = z.get("objName")