将 Spark 'CREATE TEMPORARY FUNCTION' 与 Python 文件一起使用答案

【问题标题】：Using Spark 'CREATE TEMPORARY FUNCTION' with Python file将 Spark 'CREATE TEMPORARY FUNCTION' 与 Python 文件一起使用
【发布时间】：2022-07-20 15:58:04
【问题描述】：

Spark SQL 语法可以register a UDF from SQL 与

CREATE FUNCTION simple_udf AS 'SimpleUdf'
USING JAR '/tmp/SimpleUdf.jar';

是否可以用 Python 做同样的事情？比如：

CREATE FUNCTION simple_udf AS 'SimpleUdf'
USING FILE '/tmp/sample_udf.py';

【问题讨论】：

标签： apache-spark pyspark apache-spark-sql

【解决方案1】：

sparkSessionInstance.udf.register("functionName", functionRef)

【讨论】：