📌  相关文章
📜  pyspark udf 多输入 - Go 编程语言代码示例

📅  最后修改于: 2022-03-11 14:45:00.002000             🧑  作者: Mango

代码示例1
from pyspark.sql.types import IntegerType
from pyspark.sql.functions import udf

def sum(x, y):
    return x + y

sum_cols = udf(sum, IntegerType())

a=spark.createDataFrame([(101, 1, 16)], ['ID', 'A', 'B'])
a.withColumn('Result', sum_cols('A', 'B')).show()