Spark RDD将csv文件中的所有字段作为字符串加载

问题描述

我有一个csv文件，并按如下方式加载它：

sc.textFile("market.csv").take(3)

输出是这样的：

['"ID","Area","Postcode","Amount"','"1234/232","City","8479","20000"','"5987/215","Metro","1111","25000"']

此外，通过地图操作加载：

sc.textFile("market.csv").map(lambda line: line.split(","))

给我：

[['"ID"','"Area"','"Postcode"','"Amount"'],['"1234/232"','"City"','"8479"','"20000"'],['"5987/215"','"Metro"','"1111"','"25000"']]

“”和“”太多，不能让我分析结果！

我想要这样的输出：

[["ID","Amount"],["1234/232",8479,20000],["5987/215",1111,25000]]

其中文本值为字符串类型，数字为int / double类型。

我该怎么做？ 谢谢。

解决方法

这是方法。您应该手动执行。

res.status(404).send({error: err.message});