我能夠獲得以下代碼來創建一個函數，幫助根據輸入的日期和行數生成自動增量值。但是我不能讓它在MySQL中執行。我從來沒有創建一個用戶定義函數，所以請幫助糾正代碼。 （此代碼是從MSSQL查詢轉換） CREATE FUNCTION udf_ComputeColumn (p_id int, p_CreateDate date)
RETURNS char(8)
BEGIN
DECLARE v
我想在Pyspark中定義一個UseDefinedFunction來處理數據幀的實例值，以便基於這些值生成新的屬性。 我有這樣的代碼： # I have a global attribute named 'global_dataframe' which is a dataframe containing some interesant instances.
from pyspark.sql.f
我有下面的代碼： from pyspark.sql.functions import lit
from pyspark.sql.functions import UserDefinedFunction
def aa(a, b):
if (a == 1):
return 3
else:
return 6
example_dataframe = s