In [ ]:

    

val sqlContext = new org.apache.spark.sql.SQLContext(sc)


    

In [ ]:

    




    

In [ ]:

    

dashdata.registerTempTable("salesdata")


    

In [ ]:

    

dashdata.printSchema


    

In [ ]:

    

dashdata.collect


    

In [ ]:

    

val results = sqlContext.sql("SELECT SALESMAN_ID from salesdata")
results.collect


    

In [ ]:

    

val salesman = sqlContext.sql("select * from salesdata where SALESMAN_ID='NC100'") 
salesman.collect