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.
Enregistre le contenu de la DataFrame table spécifiée. Si la table existe déjà, le comportement dépend du mode paramètre (la valeur par défaut consiste à lever une exception). Quand mode c’est 'overwrite'le cas, le schéma du schéma n’a pas besoin de correspondre au schéma de DataFrame table existant.
Syntaxe
saveAsTable(name, format=None, mode=None, partitionBy=None, **options)
Paramètres
| Paramètre | Type | Description |
|---|---|---|
name |
str | Nom de la table. |
format |
str, facultatif | Format utilisé pour enregistrer. |
mode |
str, facultatif | Comportement quand des données existent déjà. Les valeurs acceptées sont 'append', 'overwrite''error'ou 'errorifexists' (par défaut) et 'ignore'. |
partitionBy |
str ou list, facultatif | Noms des colonnes de partitionnement. |
**options |
dictionnaire | Options de chaîne supplémentaires. |
Retours
Aucun
Remarques
Quand mode est 'append', si une table existe déjà, son format et ses options sont utilisés. Contrairement DataFrameWriter.insertIntoà , DataFrameWriter.saveAsTable utilise des noms de colonnes pour rechercher les positions de colonne correctes.
Exemples
Créez une table à partir d’un DataFrame et lisez-la.
spark.sql("DROP TABLE IF EXISTS tblA")
spark.createDataFrame([
(100, "Alice"), (120, "Bob"), (140, "Tom")],
schema=["age", "name"]
).write.saveAsTable("tblA")
spark.read.table("tblA").sort("age").show()
# +---+------------+
# |age| name|
# +---+------------+
# |100|Alice|
# |120|Bob|
# |140| Tom|
# +---+------------+
spark.sql("DROP TABLE tblA")