Databricks Certified Data Engineer - Associate
Get started today
Ultimate access to all questions.
A data engineer has a Python variable table_name that they would like to use in a SQL query. They want to construct a Python code block that will run the query using table_name. They have the following incomplete code block:
____(f"SELECT customer_id, spend FROM {table_name}")
____(f"SELECT customer_id, spend FROM {table_name}")
Which of the following can be used to fill in the blank to successfully complete the task?
Real Exam
Community
KKeng
A
spark.delta.sql
B
spark.delta.table
C
spark.table
D
dbutils.sql
E
spark.sql
Explanation:
The correct answer is spark.sql. In Databricks, the spark.sql() method is used to execute SQL queries from Python code. This method takes a SQL query string as an argument and returns a DataFrame. The other options are incorrect:
spark.delta.sqldoes not exist as a valid methodspark.delta.tableis used to access Delta tables but not for executing SQL queriesspark.tableis used to read a table into a DataFrame, not for executing arbitrary SQL queriesdbutils.sqldoes not exist; dbutils has utilities but not SQL execution methods
The code block would be completed as: spark.sql(f"SELECT customer_id, spend FROM {table_name}")
Comments
Loading comments...