你可以用 substring 获取字符串直到索引 length - 2 :

import pyspark.sql.functions as F

df2 = df.withColumn(
    'col', 
    F.expr("substring(col, 1, length(col) - 2)")
)

你可以用 regexp_replace :

from pyspark.sql import functions as F

df1 = df.withColumn("value", F.regexp_replace("value", "(.*).{2}", "$1"))

df1.show()

# +-----+

# |value|

# +-----+

# | 1000|

# | 1250|

# | 3000|

# +-----+

或者 regexp_extract :

df1 = df.withColumn("value", F.regexp_extract("value", "(.*).{2}", 1))

你可以使用这个函数 substring_index 要提取周期之前的部分：

df = spark.createDataFrame([['1000.0'], ['2000.0']], ['col'])
df.withColumn('new_col', F.substring_index(F.col('col'), '.', 1))

结果：

+------+-------+
|   col|new_col|
+------+-------+
|1000.0|   1000|
|2000.0|   2000|
+------+-------+