Databricks Certified Associate Developer for Apache Spark
Get started today
Ultimate access to all questions.
Comments
Loading comments...
Ultimate access to all questions.
The following code block contains an error. It is intended to create and register a SQL UDF named "ASSESS_PERFORMANCE" using the Scala function assessPerformance() and apply it to the column customerSatisfaction in the table stores. Identify the error.
Code block:
spark.udf.register("ASSESS_PERFORMANCE", assessPerformance)
spark.sql("SELECT customerSatisfaction, ASSESS_PERFORMANCE(customerSatisfaction) AS result FROM stores")
```_
spark.udf.register("ASSESS_PERFORMANCE", assessPerformance)
spark.sql("SELECT customerSatisfaction, ASSESS_PERFORMANCE(customerSatisfaction) AS result FROM stores")
```_
A
The customerSatisfaction column cannot be called twice inside the SQL statement.
B
Registered UDFs cannot be applied inside of a SQL statement.
C
The order of the arguments to spark.udf.register() should be reversed.
D
The wrong SQL function is used to compute column result - it should be ASSESS_PERFORMANCE instead of assessPerformance._
E
There is no sql() operation - the DataFrame API must be used to apply the UDF assessPerformance().