SqlTest.scala

import org.apache.spark.sql.SparkSession

/**
  * Created by Janis Rumnieks on 16/08/2016.
  */
object SqlTest {

  def main(args: Array[String]): Unit = {

    val sparkSession = SparkSession
      .builder()
      .appName("Sql Test")
      .master("local[*]")
      .config("sparkSession.sql.warehouse.dir", ".")
      .getOrCreate()

    //val peopleSourceFilePath = """C:\Developer\Spark\Spark_2.0.0\spark-2.0.0-bin-hadoop2.7\examples\src\main\resources\people.json"""
    val peopleSourceFilePath = "people.json"

    val peopleDataFrame = sparkSession.read.json(peopleSourceFilePath)

    peopleDataFrame.show()

  }
}