Oharra
Baimena behar duzu orria atzitzeko. Direktorioetan saioa has dezakezu edo haiek alda ditzakezu.
Baimena behar duzu orria atzitzeko. Direktorioak alda ditzakezu.
Especifica el formato del origen de datos de entrada.
Sintaxis
format(source)
Parámetros
| Parámetro | Tipo | Descripción |
|---|---|---|
source |
str | Nombre del origen de datos, por ejemplo 'json' o 'parquet'. |
Devoluciones
DataFrameReader
Ejemplos
Escriba un DataFrame en un archivo JSON y vuelva a leerlo.
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|
# +---+------------+