Repository: gora Updated Branches: refs/heads/master 9a253e365 -> aa01be9ce
Fixed issue GORA-472 Project: http://git-wip-us.apache.org/repos/asf/gora/repo Commit: http://git-wip-us.apache.org/repos/asf/gora/commit/76c86b96 Tree: http://git-wip-us.apache.org/repos/asf/gora/tree/76c86b96 Diff: http://git-wip-us.apache.org/repos/asf/gora/diff/76c86b96 Branch: refs/heads/master Commit: 76c86b960ea4e4d40e49b9c48fe865ca8e826e8e Parents: 560704c Author: Kiyonari Harigae <[email protected]> Authored: Thu Feb 16 23:28:32 2017 +0900 Committer: Kiyonari Harigae <[email protected]> Committed: Thu Feb 16 23:28:32 2017 +0900 ---------------------------------------------------------------------- .../src/main/java/org/apache/gora/hbase/store/HBaseStore.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/gora/blob/76c86b96/gora-hbase/src/main/java/org/apache/gora/hbase/store/HBaseStore.java ---------------------------------------------------------------------- diff --git a/gora-hbase/src/main/java/org/apache/gora/hbase/store/HBaseStore.java b/gora-hbase/src/main/java/org/apache/gora/hbase/store/HBaseStore.java index 7d9f527..b18787c 100644 --- a/gora-hbase/src/main/java/org/apache/gora/hbase/store/HBaseStore.java +++ b/gora-hbase/src/main/java/org/apache/gora/hbase/store/HBaseStore.java @@ -278,7 +278,7 @@ implements Configurable { delete.addFamily(hcol.getFamily()); } else { // delete.deleteColumn(hcol.getFamily(), qualifier); - delete.addColumn(hcol.getFamily(), qualifier); + delete.addColumns(hcol.getFamily(), qualifier); } } else { // int index = GenericData.get().resolveUnion(schema, o); @@ -301,7 +301,7 @@ implements Configurable { delete.addFamily(hcol.getFamily()); } else { //delete.deleteColumn(hcol.getFamily(), qualifier); - delete.addColumn(hcol.getFamily(), qualifier); + delete.addColumns(hcol.getFamily(), qualifier); } @SuppressWarnings({ "rawtypes", "unchecked" }) Set<Entry> set = ((Map) o).entrySet(); @@ -585,7 +585,7 @@ implements Configurable { delete.addFamily(col.family); break; default: - delete.addColumn(col.family, col.qualifier); + delete.addColumns(col.family, col.qualifier); break; } }
