I am newbie for pyspark , i could not able to get pyspark exception handling in transformations .
for example i am calling a function on each line of map transformation , i would like to handle few exceptions in that functions and log them .
exampleof my code : .map(lambda eachone : ultility.function1(eachone , somesrgs)) , here in function1 i would like to handle exceptions .
please provide an example for better understanding . thank you .