improve filter and mapValues examples

Author: James Lee

src/main/java/com/sparkTutorial/pairRdd/filter/AirportsNotInUsaProblem.java

@@ -0,0 +1,22 @@
+package com.sparkTutorial.pairRdd.filter;
+
+public class AirportsNotInUsaProblem {
+
+    public static void main(String[] args) throws Exception {
+
+        /* Create a Spark program to read the airport data from in/airports.text;
+           generate a pair RDD with airport name being the key and country name being the value.
+           Then remove all the airports which are NOT located in United States and output the pair RDD to out/airports_not_in_usa_pair_rdd.text
+
+           Each row of the input file contains the following columns:
+           Airport ID, Name of airport, Main city served by airport, Country where airport is located,
+           IATA/FAA code, ICAO Code, Latitude, Longitude, Altitude, Timezone, DST, Timezone in Olson format
+
+           Sample output:
+
+           ("Kamloops", "Canada")
+           ("Wewak Intl", "Papua New Guinea")
+           ...
+         */
+    }
+}

src/main/java/com/sparkTutorial/pairRdd/filter/AirportsSolution.java renamed to src/main/java/com/sparkTutorial/pairRdd/filter/AirportsNotInUsaSolution.java

@@ -7,11 +7,11 @@
 import org.apache.spark.api.java.function.PairFunction;
 import scala.Tuple2;
 
-public class AirportsSolution {
+public class AirportsNotInUsaSolution {
 
     public static void main(String[] args) throws Exception {
 
-        SparkConf conf = new SparkConf().setAppName("airports").setMaster("local[*]");
+        SparkConf conf = new SparkConf().setAppName("airports").setMaster("local");
 
         JavaSparkContext sc = new JavaSparkContext(conf);
 
@@ -21,7 +21,7 @@ public static void main(String[] args) throws Exception {
 
         JavaPairRDD<String, String> airportsNotInUSA = airportPairRDD.filter(keyValue -> !keyValue._2().equals("\"United States\""));
 
-        airportsNotInUSA.saveAsTextFile("out/airports_pair_rdd.text");
+        airportsNotInUSA.saveAsTextFile("out/airports_not_in_usa_pair_rdd.text");
     }
 
     private static PairFunction<String, String, String> getAirportNameAndCountryNamePair() {

src/main/java/com/sparkTutorial/pairRdd/filter/AirportsProblem.java

@@ -0,0 +1,23 @@
+package com.sparkTutorial.pairRdd.mapValues;
+
+public class AirportsUppercaseProblem {
+
+    public static void main(String[] args) throws Exception {
+
+        /* Create a Spark program to read the airport data from in/airports.text, generate a pair RDD with airport name
+           being the key and country name being the value. Then convert the country name to uppercase and
+           output the pair RDD to out/airports_uppercase.text
+
+           Each row of the input file contains the following columns:
+
+           Airport ID, Name of airport, Main city served by airport, Country where airport is located, IATA/FAA code,
+           ICAO Code, Latitude, Longitude, Altitude, Timezone, DST, Timezone in Olson format
+
+           Sample output:
+
+           ("Kamloops", "CANADA")
+           ("Wewak Intl", "PAPUA NEW GUINEA")
+           ...
+         */
+    }
+}

src/main/java/com/sparkTutorial/pairRdd/mapValues/AirportsProblem.java

@@ -7,11 +7,11 @@
 import org.apache.spark.api.java.function.PairFunction;
 import scala.Tuple2;
 
-public class AirportsSolution {
+public class AirportsUppercaseSolution {
 
     public static void main(String[] args) throws Exception {
 
-        SparkConf conf = new SparkConf().setAppName("airports").setMaster("local[*]");
+        SparkConf conf = new SparkConf().setAppName("airports").setMaster("local");
 
         JavaSparkContext sc = new JavaSparkContext(conf);
 
@@ -21,7 +21,7 @@ public static void main(String[] args) throws Exception {
 
         JavaPairRDD<String, String> upperCase = airportPairRDD.mapValues(countryName -> countryName.toUpperCase());
 
-        upperCase.saveAsTextFile("out/airports_pair_rdd_value_uppercase.text");
+        upperCase.saveAsTextFile("out/airports_uppercase.text");
     }
 
     private static PairFunction<String, String, String> getAirportNameAndCountryNamePair() {