Commit2402739

James Lee

committed

improve PairRddFromRegularRdd and PairRddFromTupleList

1 parent0b0c3f8 commit2402739Copy full SHA for 2402739

File tree

-4

lines changed

-4

lines changed

Lines changed: 2 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -10,11 +10,11 @@`
`10`	`10`	`importjava.util.Arrays;`
`11`	`11`	`importjava.util.List;`
`12`	`12`
`13`		`-publicclasscreatePairRDDFromRegularRDD {`
	`13`	`+publicclassPairRddFromRegularRdd {`
`14`	`14`
`15`	`15`	`publicstaticvoidmain(String[]args)throwsException {`
`16`	`16`
`17`		`-SparkConfconf =newSparkConf().setAppName("create").setMaster("local[*]");`
	`17`	`+SparkConfconf =newSparkConf().setAppName("create").setMaster("local[1]");`
`18`	`18`
`19`	`19`	`JavaSparkContextsc =newJavaSparkContext(conf);`
`20`	`20`

Lines changed: 2 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -8,11 +8,11 @@`
`8`	`8`	`importjava.util.Arrays;`
`9`	`9`	`importjava.util.List;`
`10`	`10`
`11`		`-publicclasscreatePairRDDFromTupleList {`
	`11`	`+publicclassPairRddFromTupleList {`
`12`	`12`
`13`	`13`	`publicstaticvoidmain(String[]args)throwsException {`
`14`	`14`
`15`		`-SparkConfconf =newSparkConf().setAppName("create").setMaster("local[*]");`
	`15`	`+SparkConfconf =newSparkConf().setAppName("create").setMaster("local[1]");`
`16`	`16`
`17`	`17`	`JavaSparkContextsc =newJavaSparkContext(conf);`
`18`	`18`

Comments

(0)