Ram Mettu has uploaded a new patch set (#2).
Change subject: Changes: In kudu-spark, added support to delete rows from Kudu
table in DataSource API. This is done using the SaveMode.ErrorIfExists.
......................................................................
Changes: In kudu-spark, added support to delete rows from Kudu table
in DataSource API. This is done using
the SaveMode.ErrorIfExists.
Usage :
tableDataFrame.write.options(kuduOptions)
.mode(SaveMode.ErrorIfExists).kudu
- this delete all rows in tableDataFrame
- tableDataFrame MUST provide all the cols which are part of the
primary key in Kudu table
* If any column which is part of primary key is missing in the
dataframe, it will give an error
* If there are additional columns along with primary columns,
it is okay, it will delete all the rows
* If tableDataFrame contains any rows which are not present in
the Kudu table, it will give an error for those missing rows
Change-Id: Ibf7207d5ee525c07b54f7544e0ba63deb47e6acd
---
M java/kudu-spark/src/main/scala/org/kududb/spark/kudu/DefaultSource.scala
M java/kudu-spark/src/main/scala/org/kududb/spark/kudu/KuduContext.scala
M java/kudu-spark/src/test/scala/org/kududb/spark/kudu/DefaultSourceTest.scala
3 files changed, 145 insertions(+), 4 deletions(-)
git pull ssh://gerrit.cloudera.org:29418/kudu refs/changes/52/3552/2
--
To view, visit http://gerrit.cloudera.org:8080/3552
To unsubscribe, visit http://gerrit.cloudera.org:8080/settings
Gerrit-MessageType: newpatchset
Gerrit-Change-Id: Ibf7207d5ee525c07b54f7544e0ba63deb47e6acd
Gerrit-PatchSet: 2
Gerrit-Project: kudu
Gerrit-Branch: master
Gerrit-Owner: Ram Mettu <ram.me...@rms.com>
Gerrit-Reviewer: Kudu Jenkins
