Ultimate access to all questions.
Identify the error in the following code block intended to use SQL to return a new DataFrame containing columns storeId
and managerName
from a table created from DataFrame storesDF
:
storesDF.createOrReplaceTempView("stores")
spark.sql("SELECT storeId, managerName FROM stores")