File tree 2 files changed +1
-12
lines changed
src/main/scala/com/sparkTutorial/sparkSql
2 files changed +1
-12
lines changed Original file line number Diff line number Diff line change 1
1
group ' jameslee'
2
2
version ' 1.0-SNAPSHOT'
3
3
4
- apply plugin : ' java'
5
4
apply plugin : ' scala'
6
5
apply plugin : ' idea'
7
6
apply plugin : ' eclipse'
8
7
9
- sourceCompatibility = 1.8
10
-
11
- idea {
12
- project {
13
- jdkName = ' 1.8'
14
- languageLevel = ' 1.8'
15
- }
16
- }
17
-
18
8
repositories {
19
9
mavenCentral()
20
10
}
Original file line number Diff line number Diff line change @@ -2,7 +2,7 @@ package com.sparkTutorial.sparkSql
2
2
3
3
import com .sparkTutorial .commons .Utils
4
4
import org .apache .log4j .{Level , Logger }
5
- import org .apache .spark .sql .{ SQLContext , SparkSession }
5
+ import org .apache .spark .sql .SparkSession
6
6
import org .apache .spark .{SparkConf , SparkContext }
7
7
8
8
@@ -13,7 +13,6 @@ object RddDatasetConversion extends Serializable{
13
13
val conf = new SparkConf ().setAppName(" StackOverFlowSurvey" ).setMaster(" local[1]" )
14
14
15
15
val sc = new SparkContext (conf)
16
- val sqlContext = new SQLContext (sc)
17
16
18
17
val session = SparkSession .builder().appName(" StackOverFlowSurvey" ).master(" local[1]" ).getOrCreate()
19
18
You can’t perform that action at this time.
0 commit comments