Hi ,
somone can tell  me why i get the folowing error  with udf apply  like udf

def replaceCempty(x):
    if x is None :
        return ""
    else :
        return x.encode('utf-8')
udf_replaceCempty = F.udf(replaceCempty,StringType())

dfTotaleNormalize53 = dfTotaleNormalize52.select([i if i not in
colprocessing  else  udf_replaceCempty(F.col(i)).alias(i) for i in
dfTotaleNormalize52.columns])


java.lang.java.lang.UnsupportedOperationException

 Cannot evaluate expression: PythonUDF#replaceCempty(input[77,string])

??
regards

Reply via email to