File tree 1 file changed +3
-3
lines changed
src/main/java/com/sparkTutorial/pairRdd/groupbykey
1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -20,13 +20,13 @@ public static void main(String[] args) throws Exception {
20
20
21
21
JavaRDD <String > lines = sc .textFile ("in/airports.text" );
22
22
23
- JavaPairRDD <String , String > CountryAndAirportNameAndPair =
23
+ JavaPairRDD <String , String > countryAndAirportNameAndPair =
24
24
lines .mapToPair ( airport -> new Tuple2 <>(airport .split (Utils .COMMA_DELIMITER )[3 ],
25
25
airport .split (Utils .COMMA_DELIMITER )[1 ]));
26
26
27
- JavaPairRDD <String , Iterable <String >> AirportsByCountry = CountryAndAirportNameAndPair .groupByKey ();
27
+ JavaPairRDD <String , Iterable <String >> airportsByCountry = countryAndAirportNameAndPair .groupByKey ();
28
28
29
- for (Map .Entry <String , Iterable <String >> airports : AirportsByCountry .collectAsMap ().entrySet ()) {
29
+ for (Map .Entry <String , Iterable <String >> airports : airportsByCountry .collectAsMap ().entrySet ()) {
30
30
System .out .println (airports .getKey () + " : " + airports .getValue ());
31
31
}
32
32
}
You can’t perform that action at this time.
0 commit comments