Answer-first summary for fast verification
Answer: storesDF.createOrReplaceTempView("stores") spark.sql("SELECT storeId, managerName FROM stores")
To use SQL on a DataFrame, you must first create a temporary view. Option D correctly registers the DataFrame as a temp view named 'stores' using `createOrReplaceTempView("stores")` and then queries it with `spark.sql()`, which returns a new DataFrame. Other options have issues: A misses the view name, B and E use non-existent `query` method for SQL, and C incorrectly calls `createOrReplaceTempView` on SparkSession.
Author: LeetQuiz Editorial Team
Ultimate access to all questions.
Which of the following code blocks uses SQL syntax to create a new DataFrame with columns storeId and managerName from a table derived from the storesDF DataFrame?
A
storesDF.createOrReplaceTempView() spark.sql("SELECT storeId, managerName FROM stores")
B
storesDF.query(”SELECT storeid, managerName from stores")
C
spark.createOrReplaceTempView("storesDF") storesDF.sql("SELECT storeId, managerName from stores")
D
storesDF.createOrReplaceTempView("stores") spark.sql("SELECT storeId, managerName FROM stores")
E
storesDF.createOrReplaceTempView("stores") storesDF.query("SELECT storeId, managerName FROM stores")
No comments yet.