snowflake.snowpark.functions.arrays_zip¶

snowflake.snowpark.functions.arrays_zip(*cols: Union[Column, str]) → Column[source] (https://github.com/snowflakedb/snowpark-python/blob/v1.30.0/snowpark-python/src/snowflake/snowpark/functions.py#L5257-L5315)¶

Returns an array of structured objects, where the N-th object contains the N-th elements of the input arrays.

Parameters:

cols – The columns to zip together.

Returns:

A new array of structured objects.

Examples::

CopyExpand

>>> df = session.sql("select array_construct('10', '20', '30') as A, array_construct(10, 20, 30) as B")
>>> df.select(arrays_zip(df.a, df.b).as_("zipped")).show(statement_params={"enable_arrays_zip_function": "TRUE"})
-------------------
|"ZIPPED"         |
-------------------
|[                |
|  {              |
|    "$1": "10",  |
|    "$2": 10     |
|  },             |
|  {              |
|    "$1": "20",  |
|    "$2": 20     |
|  },             |
|  {              |
|    "$1": "30",  |
|    "$2": 30     |
|  }              |
|]                |
-------------------

>>> df = session.sql("select array_construct('10', '20', '30') as A, array_construct(1, 2) as B, array_construct(1.1) as C")
>>> df.select(arrays_zip(df.a, df.b, df.c).as_("zipped")).show(statement_params={"enable_arrays_zip_function": "TRUE"})
-------------------
|"ZIPPED"         |
-------------------
|[                |
|  {              |
|    "$1": "10",  |
|    "$2": 1,     |
|    "$3": 1.1    |
|  },             |
|  {              |
|    "$1": "20",  |
|    "$2": 2,     |
|    "$3": null   |
|  },             |
|  {              |
|    "$1": "30",  |
|    "$2": null,  |
|    "$3": null   |
|  }              |
|]                |
-------------------

Show lessSee more

Scroll to top