使用**split内置函数尝试array_min**函数。

• split->拆分字符串并创建数组
• array_min->从数组中获取最小值
  Example:

df = spark.createDataFrame([('111/112',),('113/PAG',),('801/802',),('801/62S',)],['ip'])
df.withColumn("ip",array_min(split(col("ip"),"/"))).show(10,False)
#+---+
#|ip |
#+---+
#|111|
#|113|
#|801|
#|62S|
#+---+

字符串

UPDATE:

from pyspark.sql.functions import *

df = spark.createDataFrame([('111/112',),('113/PAG/PAZ',),('801/802',),('801/62S',)],['ip'])
df.withColumn("temp_ip1", split(col("ip"),"/").cast("array<int>")).\
  withColumn("temp_ip2", split(col("ip"),"/")).\
  withColumn("temp", array_except(col("temp_ip2"),array_except(col("temp_ip1"),array(lit(None))).cast("array<string>"))).\
    withColumn("min_ip", array_min(when(size(col("temp"))>0,col("temp")).otherwise(col("temp_ip2")))).\
      drop(*['temp_ip1','temp_ip2','temp']).\
    show(10,False)

#+-----------+------+
#|ip         |min_ip|
#+-----------+------+
#|111/112    |111   |
#|113/PAG/PAZ|PAG   |
#|801/802    |801   |
#|801/62S    |62S   |
#+-----------+------+

型