Not
Bu sayfaya erişim yetkilendirme gerektiriyor. Oturum açmayı veya dizinleri değiştirmeyi deneyebilirsiniz.
Bu sayfaya erişim yetkilendirme gerektiriyor. Dizinleri değiştirmeyi deneyebilirsiniz.
öğesinin içeriğini DataFrame belirtilen yola CSV biçiminde kaydeder.
Sözdizimi
csv(path, mode=None, compression=None, sep=None, quote=None, escape=None,
header=None, nullValue=None, escapeQuotes=None, quoteAll=None,
dateFormat=None, timestampFormat=None, ignoreLeadingWhiteSpace=None,
ignoreTrailingWhiteSpace=None, charToEscapeQuoteEscaping=None,
encoding=None, emptyValue=None, lineSep=None)
Parametreler
| Parametre | Türü | Açıklama |
|---|---|---|
path |
str | Hadoop tarafından desteklenen herhangi bir dosya sistemindeki yol. |
mode |
str, isteğe bağlı | Veriler zaten mevcut olduğunda davranış. Kabul edilen değerler , 'append', 'overwrite've 'ignore' veya 'error' (varsayılan) değerleridir'errorifexists'. |
İadeler
Hiçbiri
Örnekler
Bir CSV dosyasına DataFrame yazın ve yeniden okuyun.
import tempfile
with tempfile.TemporaryDirectory(prefix="csv") as d:
df = spark.createDataFrame([{"age": 100, "name": "Alice"}])
df.write.csv(d, mode="overwrite")
spark.read.schema(df.schema).format("csv").option(
"nullValue", "Alice").load(d).show()
# +---+----+
# |age|name|
# +---+----+
# |100|NULL|
# +---+----+