Nota
L'accesso a questa pagina richiede l'autorizzazione. È possibile provare ad accedere o modificare le directory.
L'accesso a questa pagina richiede l'autorizzazione. È possibile provare a modificare le directory.
Specifica il formato dell'origine dati di input.
Sintassi
format(source)
Parametri
| Parametro | Tipo | Descrizione |
|---|---|---|
source |
str | Nome dell'origine dati, ad esempio 'json' o 'parquet'. |
Restituzioni
DataFrameReader
Examples
Scrivere un dataframe in un file JSON e leggerlo di nuovo.
import tempfile
with tempfile.TemporaryDirectory(prefix="format") as d:
spark.createDataFrame(
[{"age": 100, "name": "Alice"}]
).write.mode("overwrite").format("json").save(d)
spark.read.format('json').load(d).show()
# +---+------------+
# |age| name|
# +---+------------+
# |100|Alice|
# +---+------------+