Ram Mettu has uploaded a new change for review.

  http://gerrit.cloudera.org:8080/3552

Change subject: Changes:
......................................................................

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 columns 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/1
-- 
To view, visit http://gerrit.cloudera.org:8080/3552
To unsubscribe, visit http://gerrit.cloudera.org:8080/settings

Gerrit-MessageType: newchange
Gerrit-Change-Id: Ibf7207d5ee525c07b54f7544e0ba63deb47e6acd
Gerrit-PatchSet: 1
Gerrit-Project: kudu
Gerrit-Branch: master
Gerrit-Owner: Ram Mettu <ram.me...@rms.com>

Reply via email to