pyspark.sql.functions.create_map

pyspark.sql.functions. create_map ( * cols : Union[ColumnOrName, List[ColumnOrName_], Tuple[ColumnOrName_, …]] ) → pyspark.sql.column.Column

创建一个新的地图列。

在版本 2.0.0 中新增。

在版本 3.4.0 中更改： 支持 Spark Connect。

Parameters

cols 列 or str

列名或 Column 被分组为键值对，例如 (key1, value1, key2, value2, …)。

示例

>>> df = spark.createDataFrame([("Alice", 2), ("Bob", 5)], ("name", "age"))
>>> df.select(create_map('name', 'age').alias("map")).collect()
[Row(map={'Alice': 2}), Row(map={'Bob': 5})]
>>> df.select(create_map([df.name, df.age]).alias("map")).collect()
[Row(map={'Alice': 2}), Row(map={'Bob': 5})]

上一个

pyspark.sql.functions.array_join

下一步

pyspark.sql.functions.slice