apache-spark - 如何将 Zeeplein 输入字段值传递给 Spark 程序

Question

Jar文件通过使用 emp-id 的硬代码在 zeppelin 中运行。

%spark
var empObj= new Emp()
empObj.MainMethod("12")

我在 zeppelin 中创建了一个文本字段。

%spark z.input("emp-id")

我如何将text fieldemp-id 值传递给jar文件程序。提交emp-id后，我想执行jar文件程序。

请建议。谢谢。

标签： apache-sparkapache-spark-sqlapache-zeppelin

Answer 1

您可以将它作为参数传递给您的方法：

%spark
var empObj= new Emp()
empObj.MainMethod(z.input("emp-id"))

请参阅文档。