update TypedDataset

Author: James Lee

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

@@ -3,6 +3,7 @@
 import org.apache.log4j.Level;
 import org.apache.log4j.Logger;
 import org.apache.spark.api.java.function.FilterFunction;
+import org.apache.spark.api.java.function.MapFunction;
 import org.apache.spark.sql.*;
 
 import static org.apache.spark.sql.functions.avg;
@@ -59,8 +60,9 @@ public static void main(String[] args) throws Exception {
                     .show();
 
         System.out.println("=== Group by salary bucket ===");
-        typedDataset.map(response -> response.getSalaryMidPoint() == null ?
-                                     null : Math.round(response.getSalaryMidPoint()/20000) * 20000, Encoders.INT())
+        typedDataset.map((MapFunction<Response, Integer>) response -> response.getSalaryMidPoint() == null ?
+                                                                      null :
+                                                                      Math.round(response.getSalaryMidPoint()/20000) * 20000, Encoders.INT())
                     .withColumnRenamed("value", SALARY_MIDPOINT_BUCKET)
                     .groupBy(SALARY_MIDPOINT_BUCKET)
                     .count()