Skip to content

Commit d1e465f

Browse files
author
James Lee
committed
fix typo
1 parent 177d973 commit d1e465f

File tree

2 files changed

+2
-4
lines changed

2 files changed

+2
-4
lines changed

src/main/scala/com/sparkTutorial/rdd/take/TakeExample.scala

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,15 +1,14 @@
11
package com.sparkTutorial.rdd.take
22

33
import org.apache.log4j.{Level, Logger}
4-
import org.apache.spark.SparkConf
5-
import org.apache.spark.api.java.JavaSparkContext
4+
import org.apache.spark.{SparkConf, SparkContext}
65

76
object TakeExample {
87

98
def main(args: Array[String]) {
109
Logger.getLogger("org").setLevel(Level.OFF)
1110
val conf = new SparkConf().setAppName("take").setMaster("local[*]")
12-
val sc = new JavaSparkContext(conf)
11+
val sc = new SparkContext(conf)
1312

1413
val inputWords = List("spark", "hadoop", "spark", "hive", "pig", "cassandra", "hadoop")
1514
val wordRdd = sc.parallelize(inputWords)

src/main/scala/com/sparkTutorial/sparkSql/RddDatasetConversion.scala

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,6 @@ import org.apache.log4j.{Level, Logger}
55
import org.apache.spark.sql.SparkSession
66
import org.apache.spark.{SparkConf, SparkContext}
77

8-
98
object RddDatasetConversion extends Serializable{
109

1110
def main(args: Array[String]) {

0 commit comments

Comments
 (0)