在PySpark数据框中修剪字符串列 [英] Trim string column in PySpark dataframe

问题描述

我是Python和Spark的初学者.从CSV文件创建DataFrame后，我想知道如何修剪列.我已经尝试过:

I'm beginner on Python and Spark. After creating a DataFrame from CSV file, I would like to know how I can trim a column. I've try:

df = df.withColumn("Product", df.Product.strip())

df是我的数据框，Product是我的表中的列

df is my data frame, Product is a column in my table

但是我总是看到错误:

Column object is not callable

您有什么建议吗?

推荐答案

from pyspark.sql.functions import trim

df = df.withColumn("Product", trim(col("Product")))

这篇关于在PySpark数据框中修剪字符串列的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！