pyspark.sql.functions.create_map¶

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

Creates a new map column.

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.column

pyspark.sql.functions.lit