Commitf3f4fe0

authored

Update PairRddFromRegularRdd.java

1 parent98567d9 commitf3f4fe0Copy full SHA for f3f4fe0

File tree

-4

lines changed

-4

lines changed

Lines changed: 3 additions & 4 deletions

Original file line number	Diff line number	Diff line change
`@@ -22,13 +22,12 @@ public static void main(String[] args) throws Exception {`
`22`	`22`
`23`	`23`	`JavaRDD<String>regularRDDs =sc.parallelize(inputStrings);`
`24`	`24`
`25`		`-JavaPairRDD<String,Integer>pairRDD =regularRDDs.mapToPair(getNameAndAgePair());`
	`25`	`+JavaPairRDD<String,Integer>pairRDD =regularRDDs.mapToPair(getPairFunction());`
`26`	`26`
`27`	`27`	`pairRDD.coalesce(1).saveAsTextFile("out/pair_rdd_from_regular_rdd");`
`28`	`28`	`}`
`29`	`29`
`30`		`-privatestaticPairFunction<String,String,Integer>getNameAndAgePair() {`
`31`		`-return (PairFunction<String,String,Integer>)s ->newTuple2<>(s.split(" ")[0],`
`32`		`-Integer.valueOf(s.split(" ")[1]));`
	`30`	`+privatestaticPairFunction<String,String,Integer>getPairFunction() {`
	`31`	`+returns ->newTuple2<>(s.split(" ")[0],Integer.valueOf(s.split(" ")[1]));`
`33`	`32`	`}`
`34`	`33`	`}`

Comments

(0)