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

PySpark - 读取 csv 跳过自己的标题

PySpark - 读取 csv 跳过自己的标题

慕莱坞森 2023-08-08 17:19:53
我遇到的问题是,在使用 Pyspark 读取 CSV 文件时无法跳过我自己的标头read.csv。CSV 文件看起来像这样:°°°°°°°°°°°°°°°°°°°°°°°°°      My Header       °°    Important Data    °°        Data          °°°°°°°°°°°°°°°°°°°°°°°°°MYROW;SECONDROW;THIRDROW290;6848;6648496849684;68463;6384884646;6484;98718我不知道如何跳过所有第一行或“n”行。我尝试过类似的东西:    df_read = spark.read.csv('MyCSV-File.csv', sep=';') \        .rdd.zipWithIndex() \        .filter(lambda x: x[1] > 6) \        .map(lambda x: x[0]) \        .toDF('MYROW','SECONDROW','THIRDROW')是否有可能免排队,特别是它的速度有多快?数据可能是一些GB。谢谢
查看完整描述

1 回答

?
江户川乱折腾

TA贡献1851条经验 获得超5个赞

您可以在第一行添加过滤器:

.filter(lambda line: not line.startswith("°"))

另一种选择是将这些行标记为注释:

.option("comment", "°")


查看完整回答
反对 回复 2023-08-08
  • 1 回答
  • 0 关注
  • 106 浏览
慕课专栏
更多

添加回答

举报

0/150
提交
取消
意见反馈 帮助中心 APP下载
官方微信