Aller au contenu principal

format (DataFrameReader)

Spécifie le format de la source de données d'entrée.

Syntaxe

format(source)

parameter

parameter

Type

Description

source

str

Le nom de la source de données, par exemple 'json' ou 'parquet'.

parameter

Type

Description

source

str

Le nom de la source de données, par exemple 'json' ou 'parquet'.

Renvoie

DataFrameReader

Exemples

Écrivez un DataFrame dans un fichier JSON et relisez-le.

Python
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|
# +---+------------+