saveAsTable

öğesinin içeriğini DataFrame belirtilen tablo olarak kaydeder. Tablo zaten varsa, davranış parametresine mode bağlıdır (varsayılan olarak bir özel durum oluşturur). olduğunda mode'overwrite', şemasının DataFrame mevcut tablo şemasıyla eşleşmesi gerekmez.

Sözdizimi

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

Parametreler

Parametre	Türü	Açıklama
name	str	Tablo adı.
format	str, isteğe bağlı	Kaydetmek için kullanılan biçim.
mode	str, isteğe bağlı	Veriler zaten mevcut olduğunda davranış. Kabul edilen değerler , 'append'veya 'overwrite''error' (varsayılan) ve 'errorifexists'değerleridir'ignore'.
partitionBy	str veya list, isteğe bağlı	Bölümleme sütunlarının adları.
**options	Dict	Ek dize seçenekleri.

İadeler

Hiçbiri

Notlar

olduğunda mode'append', bir tablo zaten varsa, biçimi ve seçenekleri kullanılır. aksine DataFrameWriter.insertInto, DataFrameWriter.saveAsTable doğru sütun konumlarını bulmak için sütun adlarını kullanır.

Örnekler

DataFrame'den bir tablo oluşturun ve yeniden okuyun.

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