January 2019
Beginner to intermediate
154 pages
4h 31m
English
This feature enables developers to run SQL queries in a program, and get the result as a DataFrame:
//Scalasales_df.createOrReplaceTempView("sales")val sqlDF = spark.sql("SELECT * FROM sales")sqlDF.show()//Javaimport org.apache.spark.sql.Dataset;import org.apache.spark.sql.Row;sales_df.createOrReplaceTempView("sales");Dataset<Row> sqlDF = spark.sql("SELECT * FROM sales");sqlDF.show();#Pythonsales_df.createOrReplaceTempView("sales")sqlDF = spark.sql("SELECT * FROM sales")sqlDF.show()
Read now
Unlock full access