The code block shown below contains an error. The code block is intended to create and register a SQL UDF named “ASSESS_PERFORMANCE” using the Scala function assessPerformance() and apply it to column customerSatisfaction in the table stores. Identify the error. Code block: spark.udf.register(“ASSESS_PERFORMANCE”, assessPerforance) spark.sql(“SELECT customerSatisfaction, assessPerformance(customerSatisfaction) AS result FROM stores”)
Select an option, then click Submit answer.
- ○ The customerSatisfaction column cannot be called twice inside the SQL statement.
- ○ Registered UDFs cannot be applied inside of a SQL statement.
- ○ The order of the arguments to spark.udf.register() should be reversed.
- ○ The wrong SQL function is used to compute column result - it should be ASSESS_PERFORMANCE instead of assessPerformance.
- ○ There is no sql() operation - the DataFrame API must be used to apply the UDF assessPerformance().