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

>>阅读原文<<