pyspark.sql.functions.create_map

pyspark.sql.functions.create_map(*cols)

Creates a new map column.

New in version 2.0.0.

Parameters:

colsColumn or str

column names or Columns that are grouped as key-value pairs, e.g. (key1, value1, key2, value2, …).

Examples

>>> 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.crc32 pyspark.sql.functions.cume_dist