Commitbcc5210

authored

Update AirportsByCountrySolution.java

1 parentf158696 commitbcc5210Copy full SHA for bcc5210

File tree

-3

lines changed

src/main/java/com/sparkTutorial/pairRdd/groupbykey
- AirportsByCountrySolution.java

-3

lines changed

Lines changed: 3 additions & 3 deletions

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 ->newTuple2<>(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`	`}`

Comments

(0)