spark读取csv文件
测试spark读取本地和hdfs文件
from pyspark.sql import SparkSessionspark = SparkSession.builder \.appName("Example PySpark Script") \.getOrCreate()# 读取本地csv文件
df = spark.read.csv("/Users/xiaokkk/Desktop/local_projects/spark/intents.csv", header=True, inferSchema=True)
# 显示前几行数据
df.show(5)
# 读取HDFS的csv文件
df = spark.read.csv("hdfs://127.0.0.1:9001/data/intents.csv", header=True, inferSchema=True)
df.show(5)