지정된 테이블에 내용을 DataFrame 삽입합니다. 스키마가 테이블의 DataFrame 스키마와 동일해야 합니다.
문법
insertInto(tableName, overwrite=None)
매개 변수
| 매개 변수 | 유형 | 설명 |
|---|---|---|
tableName |
str | 대상 테이블의 이름입니다. |
overwrite |
bool, 선택 사항 | 이면 True기존 데이터를 덮어씁니다. 기본적으로 사용하지 않도록 설정되어 있습니다. |
Returns
없음
Notes
달리 DataFrameWriter.saveAsTable열 DataFrameWriter.insertInto 이름은 무시하고 위치 기반 해상도를 사용합니다.
예제
열 이름을 무시하고 위치 기반 해상도를 사용하여 테이블에 데이터를 삽입합니다.
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")