to_csv

içeren StructType bir sütunu CSV dizesine dönüştürür. Desteklenmeyen bir tür söz konusu olduğunda bir özel durum oluşturur.

Sözdizimi

from pyspark.sql import functions as sf

sf.to_csv(col, options=None)

Parametreler

Parametre	Türü	Description
col	pyspark.sql.Column veya str	Yapı içeren sütunun adı.
options	dict, isteğe bağlı	Dönüştürmeyi denetleme seçenekleri. CSV veri kaynağıyla aynı seçenekleri kabul eder.

İade

pyspark.sql.Column: Verilen StructTypedosyasından dönüştürülen BIR CSV dizesi.

Örnekler

Örnek 1: Basit bir StructType'ı CSV dizesine dönüştürme

from pyspark.sql import Row, functions as sf
data = [(1, Row(age=2, name='Alice'))]
df = spark.createDataFrame(data, ("key", "value"))
df.select(sf.to_csv(df.value)).show()

+-------------+
|to_csv(value)|
+-------------+
|      2,Alice|
+-------------+

Örnek 2: Karmaşık bir StructType'ı CSV dizesine dönüştürme

from pyspark.sql import Row, functions as sf
data = [(1, Row(age=2, name='Alice', scores=[100, 200, 300]))]
df = spark.createDataFrame(data, ("key", "value"))
df.select(sf.to_csv(df.value)).show(truncate=False)

+-------------------------+
|to_csv(value)            |
+-------------------------+
|2,Alice,"[100, 200, 300]"|
+-------------------------+

Örnek 3: Null değerlerle StructType'ı CSV dizesine dönüştürme

from pyspark.sql import Row, functions as sf
from pyspark.sql.types import StructType, StructField, IntegerType, StringType
data = [(1, Row(age=None, name='Alice'))]
schema = StructType([
  StructField("key", IntegerType(), True),
  StructField("value", StructType([
    StructField("age", IntegerType(), True),
    StructField("name", StringType(), True)
  ]), True)
])
df = spark.createDataFrame(data, schema)
df.select(sf.to_csv(df.value)).show()

+-------------+
|to_csv(value)|
+-------------+
|       ,Alice|
+-------------+

Örnek 4: Farklı veri türlerine sahip bir StructType'ı CSV dizesine dönüştürme

from pyspark.sql import Row, functions as sf
data = [(1, Row(age=2, name='Alice', isStudent=True))]
df = spark.createDataFrame(data, ("key", "value"))
df.select(sf.to_csv(df.value)).show()

+-------------+
|to_csv(value)|
+-------------+
| 2,Alice,true|
+-------------+