我有以下PySpark Dataframe :
df = spark.createDataFrame(
[
('31,2', 'foo'),
('33,1', 'bar'),
],
['cost', 'label']
)
我需要将"cost“列转换为浮点型。我的操作如下:
df = df.withColumn('cost', df.cost.cast('float'))
但是,结果是得到的是null
值,而不是cost
列中的数字。
如何将cost
转换为浮点数?
2条答案
按热度按时间zu0ti5jz1#
这应该对你有用。
ldioqlga2#
我认为一个简单的lambda表达式应该可以处理大多数事情。