Snowpark调用预编译的Java UDF



我正在处理一个非常简单的Snowflake示例,以便从Intellij调用预编译的Java UDF。我已经用我的Java UDF做了一个jar,并想从Intellij调用它,我正试图在雪花上执行UDF。

我想知道如何将这个罐子上传到雪花中?

session.udf.registerTemporary("sampleJUdf", 
"C:\project_existing\snowpark\src\main\Java\myjarfile.jar")

您可以使用Session.addDependency((上传jar文件,例如

session.addDependency("C:\project_existing\snowpark\src\main\Java\myjarfile.jar")

然后,您需要引用myjarfile.jar中将被UDF使用的函数的名称,例如

session.udf.registerTemporary("sampleJUdf", myFunc)

如果jar是正在运行的应用程序的一部分,SNowpark应该自动尝试上传它,但您需要在代码中导入它,并在registerTemporary中引用函数的名称。

请参阅https://docs.snowflake.com/en/developer-guide/snowpark/creating-udfs.html#specifying-dependencies-for-a-udf了解更多详细信息。

相关内容

  • 没有找到相关文章

最新更新