Skip to content

Instantly share code, notes, and snippets.

@ashkrit
Created May 26, 2018 10:08
def newSparkSession(appName: String, master: String) = {
val sparkConf = new SparkConf().setAppName(appName).setMaster(master)
val sparkSession = SparkSession.builder()
.appName(appName)
.config(sparkConf)
.getOrCreate()
sparkSession
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment