saveAsTable

Zapisuje zawartość DataFrame tabeli jako określoną. Jeśli tabela już istnieje, zachowanie zależy od parametru mode (wartość domyślna to zgłoszenie wyjątku). Gdy mode parametr ma 'overwrite'wartość , schemat DataFrame tabeli nie musi być zgodny z istniejącym schematem tabeli.

Składnia

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

Parametry

Parameter	Typ	Opis
name	str	Nazwa tabeli
format	str, opcjonalnie	Format używany do zapisywania.
mode	str, opcjonalnie	Zachowanie, gdy dane już istnieją. Akceptowane wartości to 'append', 'overwrite'lub 'error''errorifexists' (wartość domyślna) i 'ignore'.
partitionBy	str lub list, opcjonalnie	Nazwy kolumn partycjonowania.
**options	słownik	Dodatkowe opcje ciągów.

Zwroty

Żadne

Notatki

Gdy mode wartość to 'append', jeśli tabela już istnieje, używany jest jego format i opcje. W przeciwieństwie do DataFrameWriter.insertIntoelementu DataFrameWriter.saveAsTable używa nazw kolumn do znajdowania prawidłowych pozycji kolumn.

Examples

Utwórz tabelę na podstawie ramki danych i odczytaj ją z powrotem.

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