Remarque
L’accès à cette page nécessite une autorisation. Vous pouvez essayer de vous connecter ou de modifier des répertoires.
L’accès à cette page nécessite une autorisation. Vous pouvez essayer de modifier des répertoires.
Insère le contenu de la DataFrame table spécifiée. Exige que le schéma de la DataFrame table soit identique au schéma de la table.
Syntaxe
insertInto(tableName, overwrite=None)
Paramètres
| Paramètre | Type | Description |
|---|---|---|
tableName |
str | Nom de la table cible. |
overwrite |
bool, facultatif | Si True, remplace les données existantes. Désactivé par défaut. |
Retours
Aucun
Remarques
Contrairement DataFrameWriter.saveAsTableà , DataFrameWriter.insertInto ignore les noms de colonnes et utilise la résolution basée sur la position.
Exemples
Insérez des données dans une table à l’aide d’une résolution basée sur la position, en ignorant les noms de colonnes.
spark.sql("DROP TABLE IF EXISTS tblA")
df = spark.createDataFrame([
(100, "Alice"), (120, "Alice"), (140, "Bob")],
schema=["age", "name"]
)
df.write.saveAsTable("tblA")
df.selectExpr("age AS col1", "name AS col2").write.insertInto("tblA")
spark.read.table("tblA").sort("age").show()
# +---+------------+
# |age| name|
# +---+------------+
# |100|Alice|
# |100|Alice|
# |120|Alice|
# |120|Alice|
# |140| Bob|
# |140| Bob|
# +---+------------+
spark.sql("DROP TABLE tblA")