df = spark.read.csv(filename, header = True)
#create SQL table and query it
df.createOrReplaceTempView(schedule)
spark.sql(select * from schedule where station = 'San Jose' ).show()
#inspecting table schma
result = spark.sql(show columns from tablename)
result = spark.sql(select * from tab