Scala expert

There is a scala Java udf which should be invoked to pyspark environment using transformed Function and load that transformed data back to hdfs but somehow I am unable to do it. So need to implement whole thing in scala which is call that transform function in scala. Need the extension code.