insertInto

Menyisipkan isi ke DataFrame dalam tabel yang ditentukan. Mengharuskan skema DataFrame sama dengan skema tabel.

Sintaksis

insertInto(tableName, overwrite=None)

Parameter-parameternya

Parameter	Tipe	Deskripsi
tableName	str	Nama dari tabel target.
overwrite	bool, opsional	Jika True, timpa data yang ada. Dinonaktifkan secara default.

Pengembalian Barang

Tidak

Catatan

Tidak seperti DataFrameWriter.saveAsTable, DataFrameWriter.insertInto mengabaikan nama kolom dan menggunakan resolusi berbasis posisi.

Examples

Sisipkan data ke dalam tabel menggunakan resolusi berbasis posisi, mengabaikan nama kolom.

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