将数组中的元素替换为其在pyspark中的对应数字

from pyspark.sql.functions import when

from pyspark.sql import SparkSession

# 创建SparkSession
spark = SparkSession.builder.getOrCreate()

# 创建示例DataFrame
data = [(1, [1, 2, 3]), (2, [4, 5, 6]), (3, [7, 8, 9])]
df = spark.createDataFrame(data, ["id", "array_col"])
df.show()

+---+---------+
| id|array_col|
+---+---------+
|  1|[1, 2, 3]|
|  2|[4, 5, 6]|
|  3|[7, 8, 9]|
+---+---------+

# 替换数组中的元素为其对应的数字
df = df.withColumn("array_col", when(df.array_col.contains(1), 10)
                                .when(df.array_col.contains(2), 20)
                                .when(df.array_col.contains(3), 30)
                                .otherwise(df.array_col))
df.show()

+---+---------+
| id|array_col|
+---+---------+
|  1|[10, 20, 30]|
|  2| [4, 5, 6]|
|  3| [7, 8, 9]|
+---+---------+