Poznámka:
Přístup k této stránce vyžaduje autorizaci. Můžete se zkusit přihlásit nebo změnit adresáře.
Přístup k této stránce vyžaduje autorizaci. Můžete zkusit změnit adresáře.
Uloží obsah DataFrame ve formátu CSV na zadanou cestu.
Syntaxe
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)
Parametry
| Parameter | Typ | Description |
|---|---|---|
path |
str | Cesta v libovolném systému souborů podporovaných systémem Hadoop. |
mode |
str, volitelné | Chování, pokud již data existují. Přijaté hodnoty jsou 'append', , 'overwrite''ignore'a nebo 'error''errorifexists' (výchozí). |
Návraty
None
Příklady
Zapište datový rámec do souboru CSV a přečtěte si ho zpátky.
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|
# +---+----+