You can register udf's by using the in-built udf function as well using (import org.apache.spark.sql.functions._) Something along the lines of val flattenUdf = udf(udfutils.flatten) where udfutils is another object and flatten is a method in it.
On Tue, May 15, 2018 at 3:27 AM Mick Davies <michael.belldav...@gmail.com> wrote: > Hi Gourav, > > I don't think you can register UDTFs via sparkSession.udf.register > > Mick > > > > -- > Sent from: http://apache-spark-user-list.1001560.n3.nabble.com/ > > --------------------------------------------------------------------- > To unsubscribe e-mail: user-unsubscr...@spark.apache.org > > -- Thanks, Ajay
