Skip to content

Commit ff2a128

Browse files
authored
Update CollectExample.scala
1 parent 399c546 commit ff2a128

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/main/scala/com/sparkTutorial/rdd/collect/CollectExample.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@ object CollectExample {
1010
val conf = new SparkConf().setAppName("collect").setMaster("local[*]")
1111
val sc = new SparkContext(conf)
1212

13-
var inputWords = List("spark", "hadoop", "spark", "hive", "pig", "cassandra", "hadoop")
13+
val inputWords = List("spark", "hadoop", "spark", "hive", "pig", "cassandra", "hadoop")
1414
val wordRdd = sc.parallelize(inputWords)
1515

1616
val words = wordRdd.collect()

0 commit comments

Comments
 (0)