saveAsTable

Uloží obsah DataFrame zadané tabulky. Pokud tabulka již existuje, chování závisí na parametru mode (výchozí hodnota je vyvolání výjimky). Pokud mode je 'overwrite'tomu tak, schéma DataFrame nemusí odpovídat existujícímu schématu tabulky.

Syntaxe

saveAsTable(name, format=None, mode=None, partitionBy=None, **options)

Parametry

Parameter	Typ	Description
name	str	Název tabulky.
format	str, volitelné	Formát použitý k uložení.
mode	str, volitelné	Chování, pokud již data existují. Přijaté hodnoty jsou 'append', 'overwrite'nebo 'error''errorifexists' (výchozí) a 'ignore'.
partitionBy	str nebo list, volitelné	Názvy sloupců dělení
**options	slovník	Další možnosti řetězce

Návraty

None

Poznámky

Pokud mode tabulka 'append'již existuje, použije se její formát a možnosti. Na rozdíl od DataFrameWriter.insertIntofunkce používá DataFrameWriter.saveAsTable názvy sloupců k vyhledání správných pozic sloupců.

Příklady

Vytvořte tabulku z datového rámce a přečtěte si ji zpět.

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")