sparksession创建

在Spark中，SparkSession是一个新的入口点，用于编写Spark应用程序。它将取代旧的SparkContext，SQLContext和HiveContext。SparkSession可以通过以下方式创建：

from pyspark.sql import SparkSession

spark = SparkSession.builder \
    .appName("MyApp") \
    .master("local[*]") \
    .config("spark.some.config.option", "some-value") \
    .getOrCreate()

其中，`appName`指定应用程序名称，`master`指定运行模式（本地模式或集群模式），`config`指定其他配置参数。当调用`getOrCreate()`方法时，如果已经存在一个SparkSession，则返回它，否则创建一个新的SparkSession。

在创建SparkSession之后，你就可以使用它来创建DataFrame、执行SQL查询等。例如：

df = spark.read.csv("path/to/csv")
df.show()

这将读取CSV文件并将其转换为DataFrame，然后通过`show()`方法显示DataFrame的内容。