現在業務需要向phoenix的表中持續寫入歷史資料,但是目前用的
df.write.mode(SaveMode.Overwrite)
.options(Map("table" -> "",
"zkUrl" -> ""))
.format("org.apache.phoenix.spark")
.save()
這種方法只支持Overwrite模式,要保留以前的資料,只能把以前的資料也讀出來合并后再寫入,以后資料量大了必然不是長久之計,還有其他方法嗎?
uj5u.com熱心網友回復:
我知道2中方法。saveastable,fetchsize 都是批量插入轉載請註明出處,本文鏈接:https://www.uj5u.com/qita/34006.html
標籤:Spark
上一篇:求助spark
