Answers for "how to create pyspark session"

2

pyspark session

from pyspark.sql import SparkSession
spark = SparkSession.builder.master("yarn").appName("my app").enableHiveSupport().getOrCreate()
Posted by: Guest on September-04-2020
0

Gets an existing SparkSession or, if there is no existing one, creates a new

# Gets an existing SparkSession or, if there is no one, creates a new

s1 = SparkSession.builder.config("k1", "v1").getOrCreate()
s1.conf.get("k1") == s1.sparkContext.getConf().get("k1") == "v1"
# True

s2 = SparkSession.builder.config("k2", "v2").getOrCreate()
s1.conf.get("k1") == s2.conf.get("k1")
# True
s1.conf.get("k2") == s2.conf.get("k2")
# True
Posted by: Guest on April-19-2020

Python Answers by Framework

Browse Popular Code Answers by Language