Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-1637 Delete client class methods should return itself like Put, Get, Scan (Jon Gray via Nitay) 

git-svn-id: https://svn.apache.org/repos/asf/hadoop/hbase/trunk@792746 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Nitay Joffe 2009-07-09 23:27:09 +00:00
parent 800f623138
commit 2ec772096e
2 changed files with 19 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
CHANGES.txt
View File

@ -454,6 +454,8 @@ Release 0.20.0 - Unreleased
HBASE-1626 Allow emitting Deletes out of new TableReducer HBASE-1626 Allow emitting Deletes out of new TableReducer
(Lars George via Stack) (Lars George via Stack)
HBASE-1551 HBase should manage multiple node ZooKeeper quorum HBASE-1551 HBase should manage multiple node ZooKeeper quorum
HBASE-1637 Delete client class methods should return itself like Put, Get,
Scan (Jon Gray via Nitay)
OPTIMIZATIONS OPTIMIZATIONS
HBASE-1412 Change values for delete column and column family in KeyValue HBASE-1412 Change values for delete column and column family in KeyValue

24
src/java/org/apache/hadoop/hbase/client/Delete.java
View File

@ -132,8 +132,9 @@ public class Delete implements Writable {
* specified family. * specified family.
* @param family family name * @param family family name
*/ */
public void deleteFamily(byte [] family) { public Delete deleteFamily(byte [] family) {
this.deleteFamily(family, HConstants.LATEST_TIMESTAMP); this.deleteFamily(family, HConstants.LATEST_TIMESTAMP);
return this;
} }
/** /**
@ -145,7 +146,7 @@ public class Delete implements Writable {
* @param family family name * @param family family name
* @param timestamp maximum version timestamp * @param timestamp maximum version timestamp
*/ */
public void deleteFamily(byte [] family, long timestamp) { public Delete deleteFamily(byte [] family, long timestamp) {
List<KeyValue> list = familyMap.get(family); List<KeyValue> list = familyMap.get(family);
if(list == null) { if(list == null) {
list = new ArrayList<KeyValue>(); list = new ArrayList<KeyValue>();
@ -154,6 +155,7 @@ public class Delete implements Writable {
} }
list.add(new KeyValue(row, family, null, timestamp, KeyValue.Type.DeleteFamily)); list.add(new KeyValue(row, family, null, timestamp, KeyValue.Type.DeleteFamily));
familyMap.put(family, list); familyMap.put(family, list);
return this;
} }
/** /**
@ -161,8 +163,9 @@ public class Delete implements Writable {
* @param family family name * @param family family name
* @param qualifier column qualifier * @param qualifier column qualifier
*/ */
public void deleteColumns(byte [] family, byte [] qualifier) { public Delete deleteColumns(byte [] family, byte [] qualifier) {
this.deleteColumns(family, qualifier, HConstants.LATEST_TIMESTAMP); this.deleteColumns(family, qualifier, HConstants.LATEST_TIMESTAMP);
return this;
} }
/** /**
@ -172,7 +175,7 @@ public class Delete implements Writable {
* @param qualifier column qualifier * @param qualifier column qualifier
* @param timestamp maximum version timestamp * @param timestamp maximum version timestamp
*/ */
public void deleteColumns(byte [] family, byte [] qualifier, long timestamp) { public Delete deleteColumns(byte [] family, byte [] qualifier, long timestamp) {
List<KeyValue> list = familyMap.get(family); List<KeyValue> list = familyMap.get(family);
if (list == null) { if (list == null) {
list = new ArrayList<KeyValue>(); list = new ArrayList<KeyValue>();
@ -180,6 +183,7 @@ public class Delete implements Writable {
list.add(new KeyValue(this.row, family, qualifier, timestamp, list.add(new KeyValue(this.row, family, qualifier, timestamp,
KeyValue.Type.DeleteColumn)); KeyValue.Type.DeleteColumn));
familyMap.put(family, list); familyMap.put(family, list);
return this;
} }
/** /**
@ -189,9 +193,10 @@ public class Delete implements Writable {
* @param column colon-delimited family and qualifier * @param column colon-delimited family and qualifier
* @param timestamp maximum version timestamp * @param timestamp maximum version timestamp
*/ */
public void deleteColumns(byte [] column, long timestamp) { public Delete deleteColumns(byte [] column, long timestamp) {
byte [][] parts = KeyValue.parseColumn(column); byte [][] parts = KeyValue.parseColumn(column);
this.deleteColumns(parts[0], parts[1], timestamp); this.deleteColumns(parts[0], parts[1], timestamp);
return this;
} }
/** /**
@ -202,8 +207,9 @@ public class Delete implements Writable {
* @param family family name * @param family family name
* @param qualifier column qualifier * @param qualifier column qualifier
*/ */
public void deleteColumn(byte [] family, byte [] qualifier) { public Delete deleteColumn(byte [] family, byte [] qualifier) {
this.deleteColumn(family, qualifier, HConstants.LATEST_TIMESTAMP); this.deleteColumn(family, qualifier, HConstants.LATEST_TIMESTAMP);
return this;
} }
/** /**
@ -212,7 +218,7 @@ public class Delete implements Writable {
* @param qualifier column qualifier * @param qualifier column qualifier
* @param timestamp version timestamp * @param timestamp version timestamp
*/ */
public void deleteColumn(byte [] family, byte [] qualifier, long timestamp) { public Delete deleteColumn(byte [] family, byte [] qualifier, long timestamp) {
List<KeyValue> list = familyMap.get(family); List<KeyValue> list = familyMap.get(family);
if(list == null) { if(list == null) {
list = new ArrayList<KeyValue>(); list = new ArrayList<KeyValue>();
@ -220,6 +226,7 @@ public class Delete implements Writable {
list.add(new KeyValue( list.add(new KeyValue(
this.row, family, qualifier, timestamp, KeyValue.Type.Delete)); this.row, family, qualifier, timestamp, KeyValue.Type.Delete));
familyMap.put(family, list); familyMap.put(family, list);
return this;
} }
/** /**
@ -227,9 +234,10 @@ public class Delete implements Writable {
* <code>family:qualifier</code> notation. * <code>family:qualifier</code> notation.
* @param column colon-delimited family and qualifier * @param column colon-delimited family and qualifier
*/ */
public void deleteColumn(byte [] column) { public Delete deleteColumn(byte [] column) {
byte [][] parts = KeyValue.parseColumn(column); byte [][] parts = KeyValue.parseColumn(column);
this.deleteColumn(parts[0], parts[1], HConstants.LATEST_TIMESTAMP); this.deleteColumn(parts[0], parts[1], HConstants.LATEST_TIMESTAMP);
return this;
} }
/** /**