spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From issues solution <issues.solut...@gmail.com>
Subject java.lang.java.lang.UnsupportedOperationException
Date Wed, 19 Apr 2017 11:42:17 GMT
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

Mime
View raw message