Skip to content

Commit 2402739

Browse files
author
James Lee
committed
improve PairRddFromRegularRdd and PairRddFromTupleList
1 parent 0b0c3f8 commit 2402739

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

src/main/java/com/sparkTutorial/pairRdd/create/createPairRDDFromRegularRDD.java renamed to src/main/java/com/sparkTutorial/pairRdd/create/PairRddFromRegularRdd.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,11 +10,11 @@
1010
import java.util.Arrays;
1111
import java.util.List;
1212

13-
public class createPairRDDFromRegularRDD {
13+
public class PairRddFromRegularRdd {
1414

1515
public static void main(String[] args) throws Exception {
1616

17-
SparkConf conf = new SparkConf().setAppName("create").setMaster("local[*]");
17+
SparkConf conf = new SparkConf().setAppName("create").setMaster("local[1]");
1818

1919
JavaSparkContext sc = new JavaSparkContext(conf);
2020

src/main/java/com/sparkTutorial/pairRdd/create/createPairRDDFromTupleList.java renamed to src/main/java/com/sparkTutorial/pairRdd/create/PairRddFromTupleList.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -8,11 +8,11 @@
88
import java.util.Arrays;
99
import java.util.List;
1010

11-
public class createPairRDDFromTupleList {
11+
public class PairRddFromTupleList {
1212

1313
public static void main(String[] args) throws Exception {
1414

15-
SparkConf conf = new SparkConf().setAppName("create").setMaster("local[*]");
15+
SparkConf conf = new SparkConf().setAppName("create").setMaster("local[1]");
1616

1717
JavaSparkContext sc = new JavaSparkContext(conf);
1818

0 commit comments

Comments
 (0)