使用负索引从pyspark字符串列的最后一个索引对多个字符进行子字符串化

使用负索引从pyspark字符串列的最后一个索引对多个字符进行子字符串化

这就是你的用法

substring

。您的位置将是-3，长度是3。

pyspark.sql.functions.substring(str, pos, len)

您需要将子字符串函数调用更改为：

from pyspark.sql.functions import substringdf.select(substring(df['number'], -3, 3), 'event_type').show(2)#+------------------------+----------+#|substring(number, -3, 3)|event_type|#+------------------------+----------+#|          022|        11|#|          715|        11|#+------------------------+----------+