diff --git a/src/java/org/apache/hadoop/hbase/client/Delete.java b/src/java/org/apache/hadoop/hbase/client/Delete.java index 1b9cbdc..cd04aed 100644 --- a/src/java/org/apache/hadoop/hbase/client/Delete.java +++ b/src/java/org/apache/hadoop/hbase/client/Delete.java @@ -196,6 +196,11 @@ public class Delete implements Writable { this.row, family, qualifier, timestamp, KeyValue.Type.Delete)); familyMap.put(family, list); } + + public void deleteColumns(byte [] column) { + byte [][] parts = KeyValue.parseColumn(column); + this.deleteColumns(parts[0], parts[1]); + } /** * Delete the latest version of the specified column, given in diff --git a/src/java/org/apache/hadoop/hbase/client/HTable.java b/src/java/org/apache/hadoop/hbase/client/HTable.java index cf3509f..5010554 100644 --- a/src/java/org/apache/hadoop/hbase/client/HTable.java +++ b/src/java/org/apache/hadoop/hbase/client/HTable.java @@ -1411,7 +1411,7 @@ public class HTable { final RowLock rl) throws IOException { Delete d = new Delete(row, ts, rl); - d.deleteColumn(column); + d.deleteColumns(column); delete(d); }