improve StackOverFlowSurvey

Author: James Lee

src/main/java/com/sparkTutorial/sparkSql/StackOverFlowSurvey.java

@@ -2,6 +2,7 @@
 
 import org.apache.log4j.Level;
 import org.apache.log4j.Logger;
+import org.apache.spark.sql.DataFrameReader;
 import org.apache.spark.sql.Dataset;
 import org.apache.spark.sql.Row;
 import org.apache.spark.sql.SparkSession;
@@ -21,14 +22,13 @@ public static void main(String[] args) throws Exception {
         Logger.getLogger("org").setLevel(Level.ERROR);
         SparkSession session = SparkSession.builder().appName("StackOverFlowSurvey").master("local[1]").getOrCreate();
 
-        Dataset<Row> responses = session.read().option("header","true").csv("in/2016-stack-overflow-survey-responses.csv");
+        DataFrameReader dataFrameReader = session.read();
+
+        Dataset<Row> responses = dataFrameReader.option("header","true").csv("in/2016-stack-overflow-survey-responses.csv");
 
         System.out.println("=== Print out schema ===");
         responses.printSchema();
 
-        System.out.println("=== Creates a temporary view called response ===");
-        responses.createOrReplaceTempView("response");
-
         System.out.println("=== Print 20 records of responses table ===");
         responses.show(20);