如何将记录添加到分区增量 table?
how add records to a partitioned delta table?
我正在练习 table 的分区,我有这个
df.write.format("delta").mode("overwrite").partitionBy("Month").save(path)
但我不确定如何添加记录,可能是这样的
df2.write.format("delta").mode("append").partitionBy("Month").save(path)
是的,如果你只是需要追加新记录,你需要使用append
模式而不是overwrite
。将来,当您需要更新一些记录并插入其他记录时,您需要查看 MERGE INTO command.
我正在练习 table 的分区,我有这个
df.write.format("delta").mode("overwrite").partitionBy("Month").save(path)
但我不确定如何添加记录,可能是这样的
df2.write.format("delta").mode("append").partitionBy("Month").save(path)
是的,如果你只是需要追加新记录,你需要使用append
模式而不是overwrite
。将来,当您需要更新一些记录并插入其他记录时,您需要查看 MERGE INTO command.