Catatan
Akses ke halaman ini memerlukan otorisasi. Anda dapat mencoba masuk atau mengubah direktori.
Akses ke halaman ini memerlukan otorisasi. Anda dapat mencoba mengubah direktori.
Membuat kolom struct baru.
Syntax
from pyspark.sql import functions as sf
sf.struct(*cols)
Parameter-parameternya
| Pengaturan | Tipe | Description |
|---|---|---|
cols |
daftar, atur, pyspark.sql.Column atau nama kolom |
Nama kolom atau Kolom yang akan dimuat dalam struktur output. |
Pengembalian Barang
pyspark.sql.Column: kolom jenis struct dari kolom tertentu.
Examples
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}|
+-----+---+-----------------+