Megjegyzés
Az oldalhoz való hozzáféréshez engedély szükséges. Megpróbálhat bejelentkezni vagy módosítani a címtárat.
Az oldalhoz való hozzáféréshez engedély szükséges. Megpróbálhatja módosítani a címtárat.
A megadott elérési útvonalon menti a DataFrame CSV formátumban lévő tartalmat.
Szemantika
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)
Paraméterek
| Paraméter | Típus | Leírás |
|---|---|---|
path |
str | Bármely Hadoop által támogatott fájlrendszer elérési útja. |
mode |
str, nem kötelező | A viselkedés, ha az adatok már léteznek. Az elfogadott értékek a következők'append': , 'overwrite', 'ignore'és 'error''errorifexists' (alapértelmezett). |
Visszatérítések
Nincs
Examples
Írjon egy DataFrame-et egy CSV-fájlba, és olvassa vissza.
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|
# +---+----+