tag:user-defined-functions

pyspark dataframe UDF 异常处理

我使用 Python 编写了一个要在 Spark 中使用的 UDF。此函数接受一个日期（以字符串形式，例如“2017-01-06”）和一个字符串数组（例如：[2017-01-26、2017-02-26、2017-04-17]）并返回自上次最近日期以来的天数。UDF 是def findClosestPreviousDate(currdate, date_list):date_format = "%Y

2018-05-06