insertInto

öğesinin içeriğini DataFrame belirtilen tabloya ekler. şemasının DataFrame tablo şemasıyla aynı olmasını gerektirir.

Sözdizimi

insertInto(tableName, overwrite=None)

Parametreler

Parametre	Türü	Açıklama
tableName	str	Hedef tablonun adı.
overwrite	bool, isteğe bağlı	ise True, mevcut verilerin üzerine yazar. Varsayılan olarak devre dışıdır.

İadeler

Hiçbiri

Notlar

aksine DataFrameWriter.saveAsTable, DataFrameWriter.insertInto sütun adlarını yoksayar ve konum tabanlı çözümleme kullanır.

Örnekler

Konum tabanlı çözümlemeyi kullanarak sütun adlarını yoksayarak tabloya veri ekleyin.

spark.sql("DROP TABLE IF EXISTS tblA")
df = spark.createDataFrame([
    (100, "Alice"), (120, "Alice"), (140, "Bob")],
    schema=["age", "name"]
)
df.write.saveAsTable("tblA")

df.selectExpr("age AS col1", "name AS col2").write.insertInto("tblA")
spark.read.table("tblA").sort("age").show()
# +---+------------+
# |age|        name|
# +---+------------+
# |100|Alice|
# |100|Alice|
# |120|Alice|
# |120|Alice|
# |140| Bob|
# |140| Bob|
# +---+------------+

spark.sql("DROP TABLE tblA")