pandas_udf,其為1行工作,但我試著與多個行得到以下錯誤。
PythonException:“RuntimeError:在標量輸出迭代器的長度熊貓UDF應該相同的輸入;然而,輸出是1的長度和輸入的長度是2。'。
代碼
@func.pandas_udf (StringType ()) def find_data(輸入:迭代器[pd.Series]) (pd - >迭代器。係列:在輸入:輸入——做邏輯回路,如果等產量pd.Series (str (result_json)) df = df.withColumn (“outData find_data (“inputData”))