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…

Question

Options

• AThe customerSatisfaction column cannot be called twice inside the SQL statement.
• BRegistered UDFs cannot be applied inside of a SQL statement.
• CThe order of the arguments to spark.udf.register() should be reversed.
• DThe wrong SQL function is used to compute column result - it should be
• EThere is no sql() operation - the DataFrame API must be used to apply the UDF

• A
  15% (8)
• B
  2% (1)
• C
  8% (4)
• D
  2% (1)
• E
  74% (39)

Explanation

The error is a name mismatch between the registered UDF and the SQL call. The UDF is registered under the name "ASSESS_PERFORMANCE" (uppercase), but the SQL statement calls assessPerformance(customerSatisfaction) (camelCase). Even though Spark SQL is generally case-insensitive for built-in functions, custom UDF names must match exactly as registered. The SQL query should reference ASSESS_PERFORMANCE(customerSatisfaction) to correctly invoke the registered UDF. The spark.sql() operation itself is valid for calling registered UDFs.

No community discussion yet for this question.