Примечание.
Для доступа к этой странице требуется авторизация. Вы можете попробовать войти или изменить каталоги.
Для доступа к этой странице требуется авторизация. Вы можете попробовать изменить каталоги.
Создает столбец структуры.
Синтаксис
from pyspark.sql import functions as sf
sf.struct(*cols)
Параметры
| Параметр | Тип | Description |
|---|---|---|
cols |
перечисление, задание pyspark.sql.Column или имя столбца |
Имена столбцов или столбцы, содержащиеся в выходной структуре. |
Возвраты
pyspark.sql.Column: столбец типа структуры для заданных столбцов.
Примеры
import pyspark.sql.functions as sf
df = spark.createDataFrame([("Alice", 2), ("Bob", 5)], ("name", "age"))
df.select("*", sf.struct('age', df.name)).show()
+-----+---+-----------------+
| name|age|struct(age, name)|
+-----+---+-----------------+
|Alice| 2| {2, Alice}|
| Bob| 5| {5, Bob}|
+-----+---+-----------------+