spark怎么读取本地文件

Spark 读取本地文件通常通过DataFrame API中的`spark.read`函数来进行。首先，你需要创建一个`SparkSession`实例，然后你可以使用`csv`, `text`, 或者`parquet`等特定的数据源读取器，例如：

from pyspark.sql import SparkSession

# 创建SparkSession
spark = SparkSession.builder.getOrCreate()

# 读取CSV文件
data_df = spark.read.format("csv") \
    .option("header", "true") \  # 如果第一行包含列名
    .option("inferSchema", "true") \  # 自动推断数据类型
    .load("/path/to/your/local/file.csv")

# 读取文本文件
text_df = spark.read.text("/path/to/your/local/textfile.txt")

# 读取Parquet文件（二进制压缩）
parquet_df = spark.read.parquet("/path/to/your/local/parquetfile.parquet")

记得替换`"/path/to/your/local/file"`为你实际的文件路径。