saveAsTable

Menyimpan konten DataFrame sebagai tabel yang ditentukan. Jika tabel sudah ada, perilaku tergantung pada mode parameter (defaultnya adalah melemparkan pengecualian). Ketika mode adalah 'overwrite', skema DataFrame tidak perlu mencocokkan skema tabel yang ada.

Sintaksis

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

Parameter-parameternya

Parameter	Tipe	Deskripsi
name	str	Nama tabel.
format	str, opsional	Format yang digunakan untuk menyimpan.
mode	str, opsional	Perilaku ketika data sudah ada. Nilai yang diterima adalah 'append', , 'overwrite''error'atau 'errorifexists' (default), dan 'ignore'.
partitionBy	str atau daftar, opsional	Nama kolom partisi.
**options	kamus	Opsi string tambahan.

Pengembalian Barang

Tidak

Catatan

Ketika mode adalah 'append', jika tabel sudah ada, format dan opsinya digunakan. Tidak seperti DataFrameWriter.insertInto, DataFrameWriter.saveAsTable menggunakan nama kolom untuk menemukan posisi kolom yang benar.

Examples

Buat tabel dari DataFrame, dan baca kembali.

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