Pass SQL query as parameter to sqlContext
Hi,
I have created a dataframe which contains a sql query. I wanted to use the query in sqlContext. My code is as below:
query = auto.select('column1')
sqlContext.sql(query)
But It throws an error as follows
Could someone guide on it. Thanks in advance!
Best Answer
This works fine
qvar = ''.join(query)
sqlContext.sql("%s" % qvar)
Just use the below code . First you need to create the view from the dataframe , then you can use SparkSession object to query from the view . This will return a dataframe .
dataset.createOrReplaceTempView("dataset") val result:Dataset[Row]=spark.sql("select * from dataset")
Firstly, you have to type https://robloxmusicscode.com/ the in the address bar of your browser and that will lead you to the site...
36 People are following this question.
