用于将非流式传输 DataFrame 的内容保存到外部存储的接口。
退货
DataFrameWriter
示例
df = spark.createDataFrame([(2, "Alice"), (5, "Bob")], schema=["age", "name"])
type(df.write)
# <class '...readwriter.DataFrameWriter'>
将 DataFrame 写入表。
df.write.saveAsTable("tab2")
用于将非流式传输 DataFrame 的内容保存到外部存储的接口。
DataFrameWriter
df = spark.createDataFrame([(2, "Alice"), (5, "Bob")], schema=["age", "name"])
type(df.write)
# <class '...readwriter.DataFrameWriter'>
将 DataFrame 写入表。
df.write.saveAsTable("tab2")