Skip to content

Commit 87fe8ce

Browse files
author
James Lee
committed
improve AirportsNotInUsaProblem
1 parent 88c0a6b commit 87fe8ce

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@ public static void main(String[] args) throws Exception {
66

77
/* Create a Spark program to read the airport data from in/airports.text;
88
generate a pair RDD with airport name being the key and country name being the value.
9-
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
9+
Then remove all the airports which are located in United States and output the pair RDD to out/airports_not_in_usa_pair_rdd.text
1010
1111
Each row of the input file contains the following columns:
1212
Airport ID, Name of airport, Main city served by airport, Country where airport is located,

0 commit comments

Comments
 (0)