pyspark 自定义函数

一：自定义函数的通常流程html # 1.建立普通的python函数python def to_upper(s): if s is not None: return s.upper() # 2.注册自定义函数 from pyspark.sql.functions import udf from pyspark.sql.types import StringT

>>阅读原文<<