spark本地读入

在 Spark 中，可以使用 `SparkSession` 对象的 `read` 方法从本地读取数据。这个方法可以读取多种数据源的数据，例如 CSV、JSON、Parquet 等。

以读取 CSV 文件为例，示例代码如下：

from pyspark.sql import SparkSession

# 创建 SparkSession
spark = SparkSession.builder.appName("read_csv_example").getOrCreate()

# 从本地读取 CSV 文件
df = spark.read.csv("path/to/your/csv/file.csv", header=True, inferSchema=True)

# 展示 DataFrame 结构和内容
df.printSchema()
df.show()

其中，`path/to/your/csv/file.csv` 是本地 CSV 文件的路径，`header=True` 表示第一行是列名，`inferSchema=True` 表示自动推断列的数据类型。

读取其他类型的数据源时，可以使用对应的读取方法，例如 `spark.read.json`、`spark.read.parquet` 等。读取方法的参数也会略有不同，具体可以参考 Spark 官方文档。