Tutorial by Examples

import org.apache.spark.sql.functions._ // Create a function that uses the content of the column inside the dataframe val code = (param: String) => if (param == "myCode") 1 else 0 // With that function, create the udf function val myUDF = udf(code) // Apply the udf to a column in...

Page 1 of 1