Explanation:
To execute a SQL query in a Python cell with PySpark, you can pass the query string to spark.sql(). By prefixing the string with f, you enable the injection of Python variables or the evaluation of Python expressions within curly braces {}. The correct syntax for injecting variables database_name and table_name into the SQL query is spark.sql(f“SELECT * FROM {database_name}.{table_name}“).
Ultimate access to all questions.
What is the correct method to inject Python variables table_name and database_name into a SQL query for execution using PySpark?
A
spark.sql(f“SELECT * FROM [database_name].[table_name]“)
B
spark.sql(f“SELECT * FROM {database_name}.{table_name}“)
C
spark.sql(f“SELECT * FROM (database_name).(table_name)“)
D
spark.sql(f“SELECT * FROM {database_name}+{table_name}“)
E
spark.sql(“SELECT * FROM .“)
No comments yet.