dgadiraju
8/1/2017 - 11:17 AM

pyspark-dataframes-sql-native.py

# Register DF as temp table
ordersDF.registerTempTable("orders")

# Run query
sqlContext.sql("select * from orders where order_status = 'COMPLETE' limit 10").show()