Aller au contenu principal

XML (DataFrameReader)

Charge un fichier XML et renvoie le résultat sous la forme d'un DataFrame. Si schema n'est pas spécifié, cette fonction lit l'entrée une fois pour déterminer le schéma d'entrée.

Syntaxe

xml(path, schema=None, **options)

parameter

parameter

Type

Description

path

str, list ou RDD

Un ou plusieurs chemins d'entrée, ou un RDD de chaînes stockant des lignes XML.

schema

StructType ou str, facultatif.

Un schéma d'entrée facultatif en tant qu'objet StructType ou une chaîne au format DDL (par exemple, 'col0 INT, col1 DOUBLE').

parameter

Type

Description

path

str, list ou RDD

Un ou plusieurs chemins d'entrée, ou un RDD de chaînes stockant des lignes XML.

schema

StructType ou str, facultatif.

Un schéma d'entrée facultatif en tant qu'objet StructType ou une chaîne au format DDL (par exemple, 'col0 INT, col1 DOUBLE').

Renvoie

DataFrame

Exemples

Écrire un DataFrame dans un fichier XML et le relire.

Python
import tempfile
with tempfile.TemporaryDirectory(prefix="xml") as d:
spark.createDataFrame(
[{"age": 100, "name": "Alice"}]
).write.mode("overwrite").option("rowTag", "person").format("xml").save(d)

spark.read.option("rowTag", "person").xml(d).show()
# +---+------------+
# |age| name|
# +---+------------+
# |100|Alice|
# +---+------------+