为了账号安全,请及时绑定邮箱和手机立即绑定

Apache Spark 读取 CSV 文件 - ClassNotFoundException

Apache Spark 读取 CSV 文件 - ClassNotFoundException

皈依舞 2021-06-03 14:41:00
我编写了读取 CSV 文件并将结果写入控制台的 spark 程序。我在运行它时收到错误。我正在使用火花 2.2.0。示例文件:EmployeeID,FirstName,LastName,DepartmentId,Salaray1,Gowdhaman,Dhandapani,IT,100002,Shaara,Gowdhaman,IT,1500003,Karthiga,Gowdhaman,IT,1200004,Aravind,Gunasekaran,Mech,1000005,Padma,Dhandapani,Home,10000程序:from pyspark.sql import SparkSessiondef read_csv(spark, filename):    df = spark.read.load(filename, format='.csv', sep=',', header = 'true')    return dfdef main():    spark = SparkSession \        .builder \        .appName('Python Spark SQL Basic example') \        .getOrCreate()    emp = read_csv(spark, 'Employee.csv')    emp.show()if __name__ == '__main__':    main()

添加回答

代码语言

举报

0/150
提交
取消
微信客服

购课补贴
联系客服咨询优惠详情

帮助反馈 APP下载

慕课网APP
您的移动学习伙伴

公众号

扫描二维码
关注慕课网微信公众号